SpringBoot多实例WebSocket集群：Angular对接Redis消息代理问题

1. Redis是当前场景的正确选择 #

完全没问题，Redis的Pub/Sub机制天然适合解决多实例WebSocket的消息同步问题，而且你已经在用Redis做缓存，复用它能避免新增运维成本，这个选型非常合理。

2. 必须保留@EnableWebSocketMessageBroker配置类 #

你需要保留这个配置类，但要修改消息代理的配置逻辑——不要手动实现Redis的Publisher/Subscriber，而是让Spring WebSocket直接集成Redis作为Stomp消息代理，这样Spring会自动处理跨实例的消息同步，无需你手动编写消息转发代码。

修改后的WebSocket配置类

@Slf4j
@Configuration
@EnableWebSocketMessageBroker
public class ConfigurationWebSocketBroker implements WebSocketMessageBrokerConfigurer {

    private final RedisConnectionFactory redisConnectionFactory;

    // 注入Redis连接工厂，Spring Boot会自动配置这个实例
    public ConfigurationWebSocketBroker(RedisConnectionFactory redisConnectionFactory) {
        this.redisConnectionFactory = redisConnectionFactory;
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        // 保留原有的Stomp端点配置，客户端还是通过这个端点连接
        registry.addEndpoint("/socket")
                .setAllowedOriginPatterns("*")
                .withSockJS();
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        // 替换默认的SimpleBroker为Redis消息代理
        registry.enableStompBrokerRelay("/topic")
                .setRedisConnectionFactory(redisConnectionFactory)
                // 配置心跳，避免连接超时
                .setSystemHeartbeatReceiveInterval(10000)
                .setSystemHeartbeatSendInterval(10000);
        // 保留应用前缀，客户端发送消息还是走/app前缀
        registry.setApplicationDestinationPrefixes("/app");
    }
}

移除手动实现的Redis组件

你之前写的RedisMessagePublisher和RedisMessageSubscriber可以直接删除，因为enableStompBrokerRelay会自动完成以下工作：

• 当某个实例收到客户端发送的消息时，自动将消息发布到Redis对应的频道
• 所有实例都会订阅Redis的频道，收到消息后自动推送给连接到自己的客户端

3. Angular客户端配置无需大改 #

客户端依然通过StompJS连接到/socket端点，和单实例时的逻辑一致。需要注意K8s层面的配置：

• 必须通过Ingress或LoadBalancer暴露服务，不能直接用NodePort（除非客户端直接访问Pod IP，这不符合生产规范）
• 配置Ingress支持WebSocket（以Nginx Ingress为例）：

  apiVersion: networking.k8s.io/v1
  kind: Ingress
  metadata:
    name: app-ingress
    annotations:
      nginx.ingress.kubernetes.io/websocket-services: "your-service-name"
      nginx.ingress.kubernetes.io/proxy-read-timeout: "3600"
      nginx.ingress.kubernetes.io/proxy-send-timeout: "3600"
      nginx.ingress.kubernetes.io/proxy-set-header: "Upgrade $http_upgrade"
      nginx.ingress.kubernetes.io/proxy-set-header: "Connection \"upgrade\""
  spec:
    rules:
    - host: your-app-domain.com
      http:
        paths:
        - path: /
          pathType: Prefix
          backend:
            service:
              name: your-service-name
              port:
                number: 80
  

4. 方案可行性验证 #

这个方案完全可行：

• 客户端连接到任意Pod的Stomp端点后，消息会通过Redis同步到所有实例
• 每个实例只会把消息推送给连接到自己的客户端，避免重复推送
• 复用现有Redis组件，无需新增运维负担

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