b保证消息可靠性 就是以Confirm形式发送消息 ack失败则添加到数据库 使用定时任务重新发送

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);
             }
         };
     }

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("保存");
+    }
+}