問題描述
我正在構建一個使用 Spring Boot、RabbitMQ 和 WebSocket 作為 POC 的網絡聊天,但我被困在最后一點:WebSockets
我希望我的 ws 客戶端連接到特定端點,例如 /room/{id}
并且當新消息到達時,我希望服務器將響應發送給客戶端,但我搜索了類似的東西并沒有找到.
I'm building a webchat with Spring Boot, RabbitMQ and WebSocket as POC, but I'm stucked a the last point: WebSockets
I want my ws clients to connect to a specific endpoint, like /room/{id}
and when a new message arrives, I want the server to send the response to clients, but I searched for something similar and didn't found.
目前,當消息到達時,我使用RabbitMQ對其進行處理,例如
Currently, when the message arrives, I process it with RabbitMQ, like
container.setMessageListener(new MessageListenerAdapter(){
@Override
public void onMessage(org.springframework.amqp.core.Message message, Channel channel) throws Exception {
log.info(message);
log.info("Got: "+ new String(message.getBody()));
}
});
我想要的是,而不是記錄它,我想將它發送給客戶端,例如:websocketManager.sendMessage(new String(message.getBody()))
what I would like is, instead log it , I want to send it to the client, for example: websocketManager.sendMessage(new String(message.getBody()))
推薦答案
好的,我想我明白了,給需要的人,這里是答案:
Ok, I think I got it, for everyone who needs it, here is the answer:
首先,需要在 pom.xml 中添加 WS 依賴
first, you need to add WS dependencies to the pom.xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-messaging</artifactId>
</dependency>
創建一個 WS 端點
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
// the endpoint for websocket connections
registry.addEndpoint("/stomp").withSockJS();
}
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
config.enableSimpleBroker("/");
// use the /app prefix for others
config.setApplicationDestinationPrefixes("/app");
}
}
注意:我使用的是 STOMP,所以客戶端應該像這樣連接
Note: I'm using STOMP, so the clients should connect like this
<script type="text/javascript">
$(document).ready(function() {
var messageList = $("#messages");
// defined a connection to a new socket endpoint
var socket = new SockJS('/stomp');
var stompClient = Stomp.over(socket);
stompClient.connect({ }, function(frame) {
// subscribe to the /topic/message endpoint
stompClient.subscribe("/room.2", function(data) {
var message = data.body;
messageList.append("<li>" + message + "</li>");
});
});
});
</script>
然后,您可以簡單地使用
Then, you can simply wire the ws messenger on your components with
@Autowired
private SimpMessagingTemplate webSocket;
并使用
webSocket.convertAndSend(channel, new String(message.getBody()));
這篇關于Spring:向 websocket 客戶端發送消息的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,也希望大家多多支持html5模板網!