diff --git a/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitTemplateConfig.java b/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitTemplateConfig.java index fa930ca..84c0eaf 100644 --- a/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitTemplateConfig.java +++ b/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/config/RabbitTemplateConfig.java @@ -1,6 +1,7 @@ package com.shun.placeOrder.config; import com.shun.placeOrder.util.GlobalCache; +import com.shun.placeOrder.util.Mock; import jakarta.annotation.Nullable; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.core.Message; @@ -12,6 +13,8 @@ import org.springframework.context.annotation.Bean; import org.springframework.stereotype.Component; import java.util.Arrays; +import java.util.Map; +import java.util.Objects; /** * @author 夜灬瞬 @@ -52,7 +55,10 @@ public class RabbitTemplateConfig { log.info("\n消息发送到Exchange成功!! msgId = " + msgId); GlobalCache.remove(msgId); }else{ - log.info("\n消息发送到Exchange失败!! msgId = " + msgId); + log.error("\n消息发送到Exchange失败!! msgId = " + msgId); + Map value = (Map) GlobalCache.get(msgId); + // 推荐自己玩的时候,用service做增删改操作,控制事务~ + Mock.save(value); } }; } diff --git a/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/util/Mock.java b/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/util/Mock.java new file mode 100644 index 0000000..bec8aa6 --- /dev/null +++ b/a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/util/Mock.java @@ -0,0 +1,18 @@ +package com.shun.placeOrder.util; + +import lombok.extern.slf4j.Slf4j; + +import java.util.Map; + +/** + * 模拟数据库 + * @author 夜灬瞬 + * @since 2023/6/24 15:25 + */ +@Slf4j +public class Mock { + + public static void save(Object value) { + log.info("保存"); + } +}