WebSocket解决方案(springboot 基于Redis发布订阅)

以下是一个简化的Spring Boot WebSocket解决方案示例，使用Redis作为消息代理进行发布/订阅：

import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.*;
 
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
 
    private final RedisConnectionFactory connectionFactory;
    private final StringRedisTemplate redisTemplate;
 
    public WebSocketConfig(RedisConnectionFactory connectionFactory, StringRedisTemplate redisTemplate) {
        this.connectionFactory = connectionFactory;
        this.redisTemplate = redisTemplate;
    }
 
    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic", "/queue"); // 客户端订阅地址前缀
        config.setApplicationDestinationPrefixes("/app"); // 客户端发送信息的地址前缀
    }
 
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS(); // 注册STOMP协议的节点，并映射指定的URL，并指定使用SockJS协议
    }
 
    @Override
    public void configureClientInboundChannel(ChannelRegistration registration) {
        registration.interceptors(new ChatMessageInterceptor()); // 注册客户端发往服务端的通道的拦截器
    }
 
    @Override
    public void configureClientOutboundChannel(ChannelRegistration registration) {
        // 注册服务端发往客户端的通道的拦截器
    }
 
    @Override
    public void configureMessageConverters(List<MessageConverter> converters) {
        // 配置消息转换器
    }
 
    @Override
    public void configureWebSocketTransport(WebSocketTransportRegistration registration) {
        // 配置WebSocket传输
    }
 
    // 使用RedisMessageListenerContainer来监听Redis订阅频道
    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer() {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(new ChatMessageListener(), topic());
        return container;
    }
 
    // 定义订阅的Redis频道
    @Bean
    public Topic topic() {
        return new ChannelTopic("