介绍
在现代的Web应用中，实时通信功能变得越来越重要。与传统的HTTP请求-响应模式不同，实时通信允许服务器主动向客户端推送数据，从而实现实时更新和即时通知。
Spring Boot WebSocket STOMP（Simple Text Oriented Messaging Protocol）是一个强大且易于使用的库，用于为你的Spring Boot应用程序添加实时通信功能。本文将介绍如何使用Spring Boot WebSocket STOMP进行实时通信。
步骤
步骤1：创建Spring Boot项目
首先，我们需要创建一个Spring Boot项目。你可以通过使用Spring Initializr来快速创建一个新的Spring Boot项目，或者从现有的Spring Boot项目开始。
步骤2：添加依赖项
在你的Spring Boot项目的pom.xml文件中，添加下面的依赖项：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
步骤3：配置WebSocket
在你的Spring Boot应用程序的配置类中，添加@EnableWebSocketMessageBroker注解来启用WebSocket消息代理。
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/ws").withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/topic");
registry.setApplicationDestinationPrefixes("/app");
}
}
在上面的配置中，我们注册了一个WebSocket端点/ws，并使用SockJS进行支持。我们还配置了一个消息代理，允许订阅/topic前缀的主题，以及使用/app前缀的目的地。
步骤4：编写WebSocket处理程序
创建一个WebSocket处理程序，来处理WebSocket消息。在处理程序中，你可以定义处理连接、断开连接和消息发送等行为。
@Controller
public class WebSocketController {
@MessageMapping("/hello")
@SendTo("/topic/greetings")
public String greeting(String message) throws Exception {
Thread.sleep(1000); // 模拟处理时间
return "Hello, " + message + "!";
}
}
在上面的处理程序中，我们定义了一个greeting方法，用于处理来自/app/hello目的地的消息。在处理消息后，我们使用@SendTo注解将处理结果发送到/topic/greetings主题。
步骤5：编写HTML页面
在你的Spring Boot项目中，创建一个HTML页面来测试实时通信功能。在HTML页面中，使用JavaScript来连接WebSocket，并发送和接收消息。
<!DOCTYPE html>
<html>
<head>
<title>Spring Boot WebSocket STOMP</title>
<script src="https://code.jquery.com/jquery-3.5.1.min.js"></script>
<script src="/webjars/sockjs-client/1.1.2/sockjs.min.js"></script>
<script src="/webjars/stomp-websocket/2.3.3/stomp.min.js"></script>
</head>
<body>
<script>
var stompClient = null;
function connect() {
var socket = new SockJS('/ws');
stompClient = Stomp.over(socket);
stompClient.connect({}, function (frame) {
stompClient.subscribe('/topic/greetings', function (greeting) {
$("#greetings").append("<tr><td>" + greeting.body + "</td></tr>");
});
});
}
function send() {
var message = $("#message").val();
stompClient.send("/app/hello", {}, message);
}
</script>
<button onclick="connect()">连接</button>
<input type="text" id="message">
<button onclick="send()">发送</button>
<table id="greetings"></table>
</body>
</html>
在上面的HTML页面中，我们使用jQuer、SockJS和STOMP.js来连接到WebSocket并发送/接收消息。当点击"连接"按钮时，我们会连接到WebSocket并订阅/topic/greetings主题。当点击"发送"按钮时，我们会发送/app/hello目的地的消息。
运行应用程序
完成上述步骤后，可以运行Spring Boot应用程序。在浏览器中打开HTML页面，点击"连接"按钮，并在输入框中输入消息并点击"发送"按钮，可以看到接收到的消息将显示在页面上。
结论
使用Spring Boot WebSocket STOMP，你可以轻松地为你的应用程序添加实时通信功能。你可以使用WebSocket进行双向通信，还可以使用STOMP实现目标和主题的订阅和发布。希望本文对你理解和使用Spring Boot WebSocket STOMP有所帮助！
参考链接：
本文来自极简博客，作者：紫色星空下的梦，转载请注明原文链接：Spring Boot WebSocket STOMP: 为你的应用增添实时通信功能
