SpringBoot中怎么使用WebSocket

小億
86
2024-03-07 14:11:27

在Spring Boot中使用WebSocket可以通過(guò)以下步驟實(shí)現(xiàn):

  1. 首先添加WebSocket依賴: 在pom.xml文件中添加以下依賴:
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>
  1. 創(chuàng)建WebSocket配置類: 創(chuàng)建一個(gè)WebSocket配置類,用于配置WebSocket相關(guān)的參數(shù)和處理器。可以參考以下示例:
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new WebSocketHandler(), "/ws").setAllowedOrigins("*");
    }
}
  1. 創(chuàng)建WebSocket處理器: 創(chuàng)建一個(gè)WebSocket處理器類,用于處理WebSocket連接的事件和消息??梢詤⒖家韵率纠?/li>
@Component
public class WebSocketHandler extends TextWebSocketHandler {

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        // 處理收到的消息
        String payload = message.getPayload();
        session.sendMessage(new TextMessage("收到消息:" + payload));
    }
}
  1. 創(chuàng)建WebSocket客戶端: 在前端頁(yè)面中通過(guò)JavaScript來(lái)創(chuàng)建WebSocket連接,并發(fā)送和接收消息。可以參考以下示例:
var socket = new WebSocket("ws://localhost:8080/ws");

socket.onopen = function() {
    console.log("連接成功");
};

socket.onmessage = function(event) {
    console.log("收到消息:" + event.data);
};

socket.send("Hello, WebSocket!");
  1. 運(yùn)行應(yīng)用程序: 啟動(dòng)Spring Boot應(yīng)用程序,訪問(wèn)前端頁(yè)面,測(cè)試WebSocket連接和消息傳輸功能。

以上就是在Spring Boot中使用WebSocket的基本步驟,通過(guò)WebSocket可以實(shí)現(xiàn)實(shí)時(shí)通信和消息推送功能。

0