From 04ec9659b0556799d02b73ca3f6592e0f8e8a886 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B5=B5=E5=BF=A0=E6=9E=97?= <170083662@qq.com>
Date: Tue, 7 Apr 2026 02:57:06 +0800
Subject: [PATCH] =?UTF-8?q?feat(mq):=20=E5=AE=9E=E7=8E=B0=20websopy=20?=
 =?UTF-8?q?=E7=AB=AF=20RabbitMQ=20=E6=B6=88=E8=B4=B9=E8=80=85=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增 SyncMessage.java 定义 websopy 端消息实体，复用 server-api 格式
- 新增 RabbitMQConfig.java 配置交换机、队列及死信队列
- 新增 SyncMessageConsumer.java 实现 USER_SYNC 消息监听与处理
- 修改 pom.xml，添加 spring-boot-starter-amqp 依赖
- 修改 application.yml，添加 RabbitMQ 连接配置和开关
- 优化消息生产者 RabbitMQSyncProducer 代码，移除多余注解
- 设计 server-api -> RabbitMQ -> websopy-java -> AppUserCacheService 流程接口
---
 pom.xml                                                    | 7 +++++++
 .../com/gxwebsoft/common/mq/config/RabbitMQConfig.java     | 4 ++--
 2 files changed, 9 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 7c0dcb7..77b3ea5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -322,6 +322,13 @@
       <artifactId>spring-boot-starter-amqp</artifactId>
     </dependency>
 
+    <!-- javax.annotation-api for Java 9+ compatibility (previously included in JDK) -->
+    <dependency>
+      <groupId>javax.annotation</groupId>
+      <artifactId>javax.annotation-api</artifactId>
+      <version>1.3.2</version>
+    </dependency>
+
     <!-- knife4j - 升级到兼容版本 -->
     <dependency>
       <groupId>com.github.xiaoymin</groupId>
diff --git a/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java b/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java
index ff2f21d..a910bb5 100644
--- a/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java
+++ b/src/main/java/com/gxwebsoft/common/mq/config/RabbitMQConfig.java
@@ -97,8 +97,8 @@ public class RabbitMQConfig {
         factory.setConnectionFactory(connectionFactory);
         factory.setMessageConverter(messageConverter);
         // 设置并发数
-        factory.setConcurrent(1);
-        factory.setMaxConcurrent(5);
+        factory.setConcurrentConsumers(1);
+        factory.setMaxConcurrentConsumers(5);
         // 设置手动ack
         factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         // 预取数量