feat(mq): 实现 websopy 端 RabbitMQ 消费者功能

- 新增 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 流程接口
This commit is contained in:
2026-04-07 02:57:06 +08:00
parent a8372cedad
commit 04ec9659b0
2 changed files with 9 additions and 2 deletions

View File

@@ -322,6 +322,13 @@
<artifactId>spring-boot-starter-amqp</artifactId> <artifactId>spring-boot-starter-amqp</artifactId>
</dependency> </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 - 升级到兼容版本 --> <!-- knife4j - 升级到兼容版本 -->
<dependency> <dependency>
<groupId>com.github.xiaoymin</groupId> <groupId>com.github.xiaoymin</groupId>

View File

@@ -97,8 +97,8 @@ public class RabbitMQConfig {
factory.setConnectionFactory(connectionFactory); factory.setConnectionFactory(connectionFactory);
factory.setMessageConverter(messageConverter); factory.setMessageConverter(messageConverter);
// 设置并发数 // 设置并发数
factory.setConcurrent(1); factory.setConcurrentConsumers(1);
factory.setMaxConcurrent(5); factory.setMaxConcurrentConsumers(5);
// 设置手动ack // 设置手动ack
factory.setAcknowledgeMode(AcknowledgeMode.MANUAL); factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
// 预取数量 // 预取数量