springboot websocket实现群发

以下是使用Spring Boot实现WebSocket群发消息的步骤：

1.添加pom依赖

在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

2.配置WebSocket和监听器

在Spring Boot的配置类中添加以下配置：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new MyWebSocketHandler(), "/websocket").setAllowedOrigins("*");
    }

    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }

    @Bean
    public HttpSessionConfigurator httpSessionConfigurator() {
        return new HttpSessionConfigurator();
    }
}

其中，MyWebSocketHandler是自定义的WebSocket处理器，用于处理WebSocket连接和消息的发送和接收。

3.编写WebSocket处理器

@Component
public class MyWebSocketHandler extends TextWebSocketHandler {

    private static final List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session);
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        for (WebSocketSession s : sessions) {
            s.sendMessage(message);
        }
    }
}

在这个处理器中，我们使用了一个静态的sessions列表来保存所有连接到WebSocket服务器的会话。在连接建立时，我们将会话添加到sessions列表中。在连接关闭时，我们将会话从sessions列表中移除。在处理文本消息时，我们遍历sessions列表，并将消息发送到每个会话。

4.启动应用程序

在Spring Boot的启动类中添加@EnableWebSocket注解，以启用WebSocket支持。

@SpringBootApplication
@EnableWebSocket
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

5.测试

使用浏览器或WebSocket客户端连接到WebSocket服务器的URL（例如：ws://localhost:8080/websocket），并发送消息。所有连接到服务器的会话都将收到相同的消息。