SpringBoot + WebSocket+STOMP指定推送消息

**Spring Boot + WebSocket + STOMP 指定推送消息**

在现代的Web应用中，实时通信是非常重要的一点。WebSocket是一种用于建立实时通讯的网络协议，它允许客户端和服务器之间进行双向数据传输。STOMP（Simple Text-Oriented Messaging Protocol）是一个用于 WebSocket 的消息代理协议。

在本文中，我们将使用Spring Boot来构建一个简单的聊天室应用，利用WebSocket和STOMP来实现实时通信。

**依赖**

首先，我们需要在pom.xml文件中添加必要的依赖：

xml<dependencies>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-websocket</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-test</artifactId>
 <scope>test</scope>
 </dependency>
</dependencies>

**配置**

在application.properties文件中，我们需要配置WebSocket的端口：

propertiesserver.port=8080

**控制器**

下面是我们的控制器类，用于处理 WebSocket 的连接和消息：

javaimport org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;

@EnableWebSocketMessageBrokerpublic class ChatController implements WebSocketMessageBrokerConfigurer {

 @Override public void registerStompEndpoints(StompEndpointRegistry registry) {
 // 注册 STOMP 端点 registry.addEndpoint("/chat").withSockJS();
 }

 @Override public void configureMessageBroker(MessageBrokerRegistry registry) {
 // 配置消息代理 registry.enableSimpleBroker("/topic");
 }
}

**服务**

下面是我们的服务类，用于处理 WebSocket 的连接和消息：

javaimport org.springframework.web.socket.handler.TextWebSocketHandler;

public class ChatService extends TextWebSocketHandler {

 @Override protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
 // 处理文本消息 System.out.println("Received message: " + message.getText());
 // 推送消息到所有连接的客户端 getSimpleBroker().convertAndSend("/topic/chat", message.getText());
 }
}

**客户端**

下面是我们的客户端代码，用于连接 WebSocket服务：

javascript// 使用 Socket.IO 库来连接 WebSocket服务const socket = io(' />
// 监听消息事件socket.on('message', (data) => {
 console.log(data);
});

// 发送消息到服务端socket.emit('message', 'Hello, world!');

**总结**

在本文中，我们使用Spring Boot来构建一个简单的聊天室应用，利用WebSocket和STOMP来实现实时通信。我们注册了 STOMP 端点，并配置了消息代理。客户端通过 Socket.IO 库连接 WebSocket服务，并监听消息事件。

这只是一个基本示例，实际应用中可能需要更多的功能和配置。但是，这应该足够让你开始使用Spring Boot + WebSocket + STOMP 来构建你的实时通信应用了！