如何使用RabbitMQ、Spring Boot与React构建发布订阅应用

你完全可以借助Spring Boot内置的WebSocket能力完成从RabbitMQ消息消费到定向用户推送的全流程，完全不用额外搭建Netty服务或者引入第三方推送中间件，仅靠Spring Boot生态自带的组件就能落地整套逻辑。

1. Spring Boot侧RabbitMQ消费模块搭建 #

• 在推送服务项目中引入spring-boot-starter-amqp依赖，按标准Spring Boot配置项填写RabbitMQ连接地址、虚拟主机、目标队列、交换机绑定规则
• 编写带@RabbitListener注解的消费逻辑：监听业务队列时完成消息解码，根据消息携带的规则（比如关联用户ID、用户订阅的业务类型标签）完成目标用户匹配，再将匹配到的内容送入WebSocket推送通道
• 核心逻辑参考片段：

  @RabbitListener(queues = "business_detail_push_queue")
  public void handleBusinessMessage(BusinessDetailDTO message) {
      // 按预设业务规则匹配需要接收推送的用户列表
      List<String> matchedUserIds = userMatchService.getMatchedUsers(message);
      // 调用内部WebSocket服务完成定向推送
      pushService.pushToTargetUsers(matchedUserIds, message.getContent());
  }
  

2. Spring Boot内置WebSocket能力集成 #

• 引入spring-boot-starter-websocket依赖，该依赖会自动复用Spring Boot内置的Tomcat容器提供WebSocket服务，无需手动配置独立的WebSocket服务端口
• 核心实现可以选两种模式，按需选择：
  • 原生WebSocket模式：全局维护用户ID-WebSocket会话的映射关系，在连接建立的拦截器中校验用户身份、提取用户ID后将会话注册到映射表；连接断开/异常关闭时及时从映射表移除会话，避免内存泄漏；推送时直接取出目标用户对应的活跃会话，写入推送内容即可
  • STOMP封装模式：如果想少写维护会话的重复代码，可以基于STOMP协议搭建WebSocket通道，直接借助SimpMessagingTemplate的convertAndSendToUser方法完成定向发送，框架会自动结合已登录的用户身份完成消息路由，不需要手动维护会话映射表
• 多实例部署注意事项：不要把会话映射表存在单节点内存中，可以将推送请求通过RabbitMQ广播到所有推送服务节点，每个节点本地检查是否存在目标用户的活跃连接，存在则直接完成推送，避免单节点会话找不到的问题。

3. React前端对接实现 #

• 前端不需要引入重型WebSocket依赖库，直接用浏览器原生WebSocket API就能完成连接建立
• 连接握手阶段，在请求参数或自定义请求头中携带用户身份认证Token，供后端完成身份校验（注意跨域场景下Cookie传参的限制，优先用自定义Header传递认证信息）
• 注册消息接收回调，收到后端推送的内容后直接更新React组件状态，实现页面内容的实时刷新，不需要做轮询拉取。

• RabbitMQ消费端要开启手动消息确认机制，避免消费逻辑异常导致消息丢失
• WebSocket跨域配置需要单独在WebSocket注册拦截器中配置，没法直接复用普通HTTP接口的跨域规则
• 对用户不在线时的未接收推送内容，建议做持久化存储，等用户重新建立WebSocket连接后补发未读消息，避免内容遗漏

内容的提问来源于stack exchange，提问作者Ruchin Amaratunga