在Spring Boot中集成WebSocket并实现服务端向前端推送广播消息，可以按照以下步骤操作： 1. 添加WebSocket依赖：在`pom.xml`文件中添加以下依赖： ```xml <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency> </dependencies> ``` 2. 创建WebSocket配置类：创建一个配置类，用于注册WebSocket处理器和拦截器。 ```java @Configuration @EnableWebSocket public class WebSocketConfig implements WebSocketConfigurer { @Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { registry.addHandler(webSocketHandler(), "/websocket").setAllowedOrigins("*"); } @Bean public WebSocketHandler webSocketHandler() { return new WebSocketHandler(); } } ``` 3. 创建WebSocket处理器：创建一个WebSocket处理器，用于处理WebSocket的连接、断开连接和消息处理。 ```java @Component public class WebSocketHandler 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 { // 处理接收到的消息 } public void broadcast(String message) throws IOException { for (WebSocketSession session : sessions) { session.sendMessage(new TextMessage(message)); } } } ``` 4. 广播消息：在需要发送广播消息的地方，通过注入`WebSocketHandler`，调用`broadcast`方法即可实现消息的广播推送。 ```java @Autowired private WebSocketHandler webSocketHandler; public void sendMessage(String message) throws IOException { webSocketHandler.broadcast(message); } ``` 注意：上述代码仅为示例，具体的业务逻辑需要根据实际需求进行调整。 以上就是使用Spring Boot集成WebSocket实现服务端向前端推送广播消息的基本步骤。希望对你有帮助！ [2024-05-11 12:48:49 | AI写代码神器 | 1936点数解答]