From 8c327d2bd0bb925c8bdb3a69503eee5e8b0ae9c7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=A4=9C=E7=81=AC=E7=9E=AC?= <2431038086@qq.com>
Date: Sat, 24 Jun 2023 15:32:04 +0800
Subject: [PATCH] =?UTF-8?q?b=E4=BF=9D=E8=AF=81=E6=B6=88=E6=81=AF=E5=8F=AF?=
 =?UTF-8?q?=E9=9D=A0=E6=80=A7=20=E5=B0=B1=E6=98=AF=E4=BB=A5Confirm?=
 =?UTF-8?q?=E5=BD=A2=E5=BC=8F=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF=20ack?=
 =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E5=88=99=E6=B7=BB=E5=8A=A0=E5=88=B0=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=BA=93=20=E4=BD=BF=E7=94=A8=E5=AE=9A=E6=97=B6?=
 =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E9=87=8D=E6=96=B0=E5=8F=91=E9=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../config/RabbitTemplateConfig.java           |  8 +++++++-
 .../java/com/shun/placeOrder/util/Mock.java    | 18 ++++++++++++++++++
 2 files changed, 25 insertions(+), 1 deletion(-)
 create mode 100644 a-rabbitMQ/placeOrder/src/main/java/com/shun/placeOrder/util/Mock.java

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