阅读量:0
在Java中，使用STOMP（Simple Text Oriented Messaging Protocol）协议实现消息传递的方法如下：
- 添加依赖
首先，你需要在项目中添加STOMP相关的依赖。如果你使用的是Maven，可以在pom.xml文件中添加以下依赖：
<groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-websocket</artifactId> </dependency> - 配置WebSocket和STOMP
创建一个配置类，继承AbstractWebSocketMessageBrokerConfigurer，并重写configureMessageBroker、registerStompEndpoints和configureClientInboundChannel方法。例如：
@Configuration @EnableWebSocketMessageBroker public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer { @Override public void configureMessageBroker(MessageBrokerRegistry config) { config.enableSimpleBroker("/topic"); config.setApplicationDestinationPrefixes("/app"); } @Override public void registerStompEndpoints(StompEndpointRegistry registry) { registry.addEndpoint("/chat").withSockJS(); } @Override public void configureClientInboundChannel(ChannelRegistration registration) { registration.interceptors(new TopicSubscriptionInterceptor()); } } - 创建消息处理器
创建一个消息处理器类，用于处理客户端发送的消息。例如：
@Controller public class ChatController { @MessageMapping("/chat.sendMessage") @SendTo("/topic/public") public ChatMessage sendMessage(@Payload ChatMessage chatMessage) { return chatMessage; } @MessageMapping("/chat.addUser") @SendTo("/topic/public") public ChatMessage addUser(@Payload ChatMessage chatMessage, SimpMessageHeaderAccessor headerAccessor) { headerAccessor.getSessionAttributes().put("username", chatMessage.getSender()); return chatMessage; } } - 创建消息模型
创建一个消息模型类，用于在客户端和服务器之间传递数据。例如：
public class ChatMessage { private String content; private String sender; private MessageType type; // 构造函数、getter和setter方法 } - 前端实现
在前端，你需要使用SockJS和stomp.js库来连接WebSocket服务器并发送和接收消息。例如：
<!DOCTYPE html> <html> <head> <title>Chat</title> <script src="https://cdnjs.cloudflare.com/ajax/libs/sockjs-client/1.5.0/sockjs.min.js"></script> <script src="https://cdnjs.cloudflare.com/ajax/libs/stomp.js/2.3.3/stomp.min.js"></script> </head> <body> <div id="chat"> <!-- 前端代码 --> </div> <script> // 连接WebSocket服务器 var socket = new SockJS('/chat'); var stompClient = Stomp.over(socket); stompClient.connect({}, function (frame) { // 订阅公共主题 stompClient.subscribe('/topic/public', function (message) { // 处理接收到的消息 }); // 发送消息 stompClient.send("/app/chat.sendMessage", {}, JSON.stringify({content: 'Hello', sender: 'User'})); }); </script> </body> </html> 这样，你就实现了使用STOMP协议在Java中进行消息传递的功能。你可以根据自己的需求对代码进行修改和扩展。
