介紹

WebSocket 是一種在單個 TCP 連接上進行全雙工通信的協議，它可以提供實時的、雙向的數據傳輸。Spring Boot 提供了對 WebSocket 的支持，我們可以使用 Spring Boot WebSocket 客戶端來連接到 WebSocket 服務器，并進行實時通信。

本文將介紹如何使用 Spring Boot WebSocket 客戶端來連接到 WebSocket 服務器，并發送和接收消息。我們將通過一個簡單的聊天應用案例來演示 Spring Boot WebSocket 客戶端的使用。

創建 Spring Boot 項目

首先，我們需要創建一個 Spring Boot 項目。可以使用 Spring Initializr（https://start.spring.io/）來快速創建一個空的 Spring Boot 項目。

在創建項目時，需要添加以下依賴：

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-messaging</artifactId></dependency>
</dependencies>

這些依賴將引入 Spring Boot WebSocket 和 Web 相關的功能。

創建 WebSocket 客戶端

接下來，我們需要創建一個 WebSocket 客戶端來連接到 WebSocket 服務器。可以創建一個 WebSocketClient 的實例，并使用 WebSocketClient 來連接到 WebSocket 服務器。

@Configuration
@EnableWebSocket
public class WebSocketClientConfig {@Beanpublic WebSocketClient webSocketClient() {return new StandardWebSocketClient();}@Beanpublic WebSocketHandler webSocketHandler() {return new MyWebSocketHandler();}
}

在上面的示例中，我們使用了 StandardWebSocketClient 作為 WebSocket 客戶端的實現。可以根據需求選擇其他的 WebSocket 客戶端實現。

接下來，我們需要創建一個 WebSocket 處理器（WebSocketHandler）來處理 WebSocket 事件。可以實現 WebSocketHandler 接口，并重寫其中的方法。

public class MyWebSocketHandler implements WebSocketHandler {@Overridepublic void afterConnectionEstablished(WebSocketSession session) throws Exception {// 連接建立后的處理邏輯}@Overridepublic void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {// 接收到消息的處理邏輯}@Overridepublic void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {// 發生傳輸錯誤的處理邏輯}@Overridepublic void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {// 連接關閉后的處理邏輯}@Overridepublic boolean supportsPartialMessages() {return false;}
}

在上面的示例中，我們實現了 WebSocketHandler 接口，并重寫了其中的方法。afterConnectionEstablished 方法在 WebSocket 連接建立后被調用，handleMessage 方法在接收到消息時被調用，handleTransportError 方法在發生傳輸錯誤時被調用，afterConnectionClosed 方法在連接關閉后被調用。supportsPartialMessages 方法用于指示是否支持部分消息的處理。

連接到 WebSocket 服務器

在上面的示例中，我們已經定義了 WebSocket 客戶端和 WebSocket 處理器。現在，我們需要創建一個類來連接到 WebSocket 服務器，并發送和接收消息。

@Component
public class WebSocketClientService {private final WebSocketClient webSocketClient;private final WebSocketHandler webSocketHandler;@Autowiredpublic WebSocketClientService(WebSocketClient webSocketClient, WebSocketHandler webSocketHandler) {this.webSocketClient = webSocketClient;this.webSocketHandler = webSocketHandler;}public void connect() {try {WebSocketSession session = webSocketClient.doHandshake(webSocketHandler, "ws://localhost:8080/ws").get();// 連接建立后的邏輯} catch (Exception e) {e.printStackTrace();}}public void sendMessage(String message) {// 發送消息的邏輯}public void disconnect() {// 斷開連接的邏輯}
}

在上面的示例中，我們使用 WebSocketClient 和 WebSocketHandler 的實例來連接到 WebSocket 服務器，并發送和接收消息。在 connect 方法中，我們調用 doHandshake 方法來建立 WebSocket 連接。在 sendMessage 方法中，我們可以調用 session.sendMessage 方法來發送消息。在 disconnect 方法中，我們可以調用 session.close 方法來斷開連接。

使用 WebSocket 客戶端

在上面的示例中，我們已經創建了一個 WebSocket 客戶端，并定義了連接、發送和接收消息的方法。現在，我們可以在任何需要使用 WebSocket 客戶端的地方注入 WebSocketClientService 并調用其方法來連接、發送和接收消息。

@Controller
public class HomeController {private final WebSocketClientService webSocketClientService;@Autowiredpublic HomeController(WebSocketClientService webSocketClientService) {this.webSocketClientService = webSocketClientService;}@GetMapping("/")public String home() {webSocketClientService.connect();return "home";}@PostMapping("/send")public String sendMessage(@RequestParam String message) {webSocketClientService.sendMessage(message);return "home";}@PostMapping("/disconnect")public String disconnect() {webSocketClientService.disconnect();return "home";}
}

在上面的示例中，我們定義了一個控制器（HomeController），并注入了 WebSocketClientService。在 home 方法中，我們調用 webSocketClientService.connect 方法來連接到 WebSocket 服務器。在 sendMessage 方法中，我們調用 webSocketClientService.sendMessage 方法來發送消息。在 disconnect 方法中，我們調用 webSocketClientService.disconnect 方法來斷開連接。

測試 WebSocket 客戶端

在上面的示例中，我們已經創建了一個 WebSocket 客戶端，并定義了連接、發送和接收消息的方法。現在，我們可以運行項目并使用瀏覽器來測試 WebSocket 客戶端。

1. 啟動 Spring Boot 項目。
2. 在瀏覽器中訪問 http://localhost:8080/。
3. 在頁面上填寫要發送的消息并點擊發送按鈕。
4. 在控制臺中可以看到 WebSocket 客戶端接收到的消息。

案例

以下是三個使用 Spring Boot WebSocket 客戶端的案例。

案例一：實時股票行情
假設我們需要實時獲取股票行情數據，并在前端展示。我們可以使用 Spring Boot WebSocket 客戶端來連接到股票行情 WebSocket 服務器，并定時發送請求，獲取最新的股票行情數據。

在 WebSocket 處理器中，我們可以實現 afterConnectionEstablished 方法來發送請求，實現定時獲取股票行情數據的邏輯。在 handleMessage 方法中，我們可以處理收到的股票行情數據，例如將其發送給前端頁面進行展示。

案例二：實時多人游戲
假設我們正在開發一個實時多人游戲，需要在多個玩家之間進行實時通信。我們可以使用 Spring Boot WebSocket 客戶端來連接到游戲服務器，并發送和接收游戲相關的消息。

在 WebSocket 處理器中，我們可以實現 afterConnectionEstablished 方法來發送玩家加入游戲的請求，實現玩家加入游戲的邏輯。在 handleMessage 方法中，我們可以處理接收到的游戲相關的消息，例如更新玩家位置、處理游戲事件等。

案例三：實時聊天應用
假設我們正在開發一個實時聊天應用，需要實現多個用戶之間的實時通信。我們可以使用 Spring Boot WebSocket 客戶端來連接到聊天服務器，并發送和接收聊天消息。

在 WebSocket 處理器中，我們可以實現 afterConnectionEstablished 方法來發送用戶加入聊天室的請求，實現用戶加入聊天室的邏輯。在 handleMessage 方法中，我們可以處理接收到的聊天消息，例如將其發送給其他在線用戶進行實時聊天。

這些案例只是示例，實際應用中可能還有其他的業務邏輯和需求。使用 Spring Boot WebSocket 客戶端，我們可以方便地連接到 WebSocket 服務器，并進行實時通信，滿足各種實時應用的需求。

總結

本文介紹了如何使用 Spring Boot WebSocket 客戶端來連接到 WebSocket 服務器，并發送和接收消息。我們通過一個簡單的聊天應用案例演示了 Spring Boot WebSocket 客戶端的使用。通過注入 WebSocketClient 和 WebSocketHandler 的實例，我們可以在任何需要使用 WebSocket 客戶端的地方連接到 WebSocket 服務器，并進行實時通信。希望本文對你在使用 Spring Boot WebSocket 客戶端時有所幫助。