在现代Web应用程序开发中，WebSocket是实现即时通信和实时数据传输的常用技术。Spring Boot框架提供了集成WebSocket的支持，使得开发者可以非常方便地实现推送和通知功能。
本文将介绍Spring Boot中如何使用WebSocket实现推送和通知功能，并演示一个简单的实时在线聊天室的实现。
- 创建Spring Boot项目
首先，我们需要创建一个Spring Boot项目。可以在Spring Initializr网站上使用web和WebSocket依赖来快速创建一个新项目。代码如下：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
</dependencies>- 配置WebSocket
接下来，我们需要配置WebSocket以使其能够在Spring Boot应用中运行。
首先，我们需要在应用程序的配置文件中添加以下属性：
spring.websocket.enabled=true
接着，在Spring Boot的配置类中添加一个@EnableWebSocket注解，启用WebSocket支持。同时，我们需要实现一个WebSocketConfigurer接口，在其中注册处理程序和消息拦截器，以便处理WebSocket请求和消息。
代码如下：
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(new WebSocketHandler(), "/chat").setAllowedOrigins("*").withSockJS();
}
}在上面的代码中，我们注册了一个处理程序（即WebSocketHandler），该处理程序在客户端连接到“/ chat”端点时被调用。使用setAllowedOrigins方法来指定允许的来源，以便进行跨域请求，使用withSockJS方法以启用SockJS支持，以便与不支持WebSocket的浏览器兼容。
- 编写WebSocket处理程序
现在我们需要编写处理程序类，这个类会处理所有的WebSocket请求和消息。
在Spring Boot中，这个类只需要实现WebSocketHandler接口即可。我们将使用SimpeTextWebSocketHandler类，该类提供了处理WebSocket消息的基本功能，并且我们可以在其基础上扩展自己的处理程序。
代码如下：
public class WebSocketHandler extends TextWebSocketHandler {
private 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) {
if (s.isOpen() && !s.equals(session)) {
s.sendMessage(message);
}
}
}
}在上面的代码中，afterConnectionEstablished方法在新的WebSocket会话建立时被调用，afterConnectionClosed方法在WebSocket会话关闭时被调用。handleTextMessage方法处理所有的WebSocket消息，并发送给所有当前连接的客户端。
- 创建WebSocket客户端
现在，我们需要创建一个WebSocket客户端来测试实现的推送和通知功能。可以使用JavaScript的WebSocket API来创建一个WebSocket客户端。
代码如下：
const socket = new WebSocket('ws://localhost:8080/chat');
socket.onopen = function() {
console.log('连接已建立');
};
socket.onmessage = function(event) {
console.log('收到消息:', event.data);
};
socket.onerror = function(error) {
console.log('发生错误:', error);
};
socket.onclose = function() {
console.log('连接已关闭');
};在上面的代码中，我们创建
.........................................................