core/.workbuddy/memory/2026-04-09.md

2026-04-09 工作记录

UserServiceImpl 添加 MQ 同步功能

在 UserServiceImpl 中统一添加了用户数据变更时的 MQ 消息发送逻辑：

修改内容

1. 添加依赖注入：注入 SyncMessageProducer，使用 @Autowired(required = false) 避免 MQ 未启用时报错
2. saveUser() 方法：用户创建成功后发送 CREATE 事件到 websopy
3. updateUser() 方法：用户更新成功后发送 UPDATE 事件到 websopy
4. addUser() 方法：注释说明已通过 saveUser 发送 MQ，避免重复

触发场景

现在以下操作都会触发 MQ 同步：

• 用户注册（短信登录自动注册、普通注册、管理员注册）
• 后台添加用户
• 用户更新信息
• 扫码绑定手机号（原有逻辑）

日志输出

• 创建：用户创建后发送MQ消息同步到websopy: userId={}, phone={}
• 更新：用户更新后发送MQ消息同步到websopy: userId={}, phone={}

---

MQ 架构改造 - 方案 A 实现

将用户同步架构从 "core 系统消费后 HTTP 转发" 改为 "各子系统直接消费 MQ"。

core 系统改动 (com.gxwebsoft.core)

1. RabbitMQConfig.java

• Exchange 类型：从 DirectExchange 改为 TopicExchange
• 删除队列定义：core 系统不再定义消费队列，只负责发送
• Routing Key 格式：user.sync.{targetSystem}

2. RabbitMQSyncProducer.java

• 动态 Routing Key：根据 targetSystem 构建 routing key
• 代码："user.sync." + targetSystem.toLowerCase()

3. 删除 UserSyncConsumer.java

• core 系统不再消费用户同步消息

4. UserSyncService.java

• 废弃 HTTP 同步逻辑：所有 HTTP 调用方法已删除
• 标记 @Deprecated：保留空实现以兼容旧代码
• 同步方式：现在统一通过 MQ 自动触发

websopy 系统改动 (websopy-java)

1. RabbitMQConfig.java

// websopy 专用队列
public static final String SYNC_QUEUE_WEBSOPY = "user.sync.websopy.queue";
public static final String SYNC_ROUTING_KEY_WEBSOPY = "user.sync.websopy";

// Topic Exchange（与 core 系统共用）
@Bean
public TopicExchange syncExchange() {
    return new TopicExchange(SYNC_EXCHANGE, true, false);
}

// websopy 专用队列绑定
@Bean
public Binding syncBindingWebsopy() {
    return BindingBuilder.bind(syncQueueWebsopy())
            .to(syncExchange())
            .with(SYNC_ROUTING_KEY_WEBSOPY);
}

2. SyncMessageConsumer.java

• 监听队列：改为 SYNC_QUEUE_WEBSOPY (user.sync.websopy.queue)
• 死信队列：改为 DLQ_QUEUE_WEBSOPY (user.sync.websopy.dlq)

新架构流程

用户操作 → UserServiceImpl.saveUser/updateUser 
                ↓
         MQ Producer (routing key = user.sync.websopy)
                ↓
         Topic Exchange (sync.exchange)
                ↓
    ┌───────────┼───────────┐
    ↓           ↓           ↓
websopy      子系统B     子系统C
(消费者)     (消费者)     (消费者)

消息格式

{
  "messageId": "uuid",
  "messageType": "USER_SYNC",
  "eventType": "CREATE|UPDATE|DELETE",
  "targetSystem": "websopy",
  "data": {
    "userId": 123,
    "username": "xxx",
    "nickname": "xxx",
    "avatar": "xxx",
    "phone": "xxx",
    "status": 1,
    "tenantId": 1
  },
  "createTime": "2026-04-09T16:00:00",
  "retryCount": 0
}

优势

• 解耦：core 系统只负责发送，不关心哪些子系统消费
• 扩展性：新增子系统只需添加自己的消费者，无需修改 core
• 可靠性：各子系统独立消费，互不影响
• 符合 MQ 设计：消息广播到多个订阅者