中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Spring Boot與WebSocket通信實現

發布時間:2024-11-15 12:22:03 來源:億速云 閱讀:117 作者:小樊 欄目:編程語言

Spring Boot 是一個用于簡化 Spring 應用程序開發的框架,它提供了許多開箱即用的功能,使得開發人員能夠快速構建和部署應用程序。WebSocket 是一種網絡通信協議,它允許在客戶端和服務器之間進行全雙工通信。結合 Spring Boot 和 WebSocket,可以實現實時應用程序的開發。

下面是一個簡單的示例,展示了如何使用 Spring Boot 和 WebSocket 實現通信功能:

  1. 添加依賴

pom.xml 文件中添加 Spring Boot 和 WebSocket 的依賴:

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-websocket</artifactId>
    </dependency>
</dependencies>
  1. 配置 WebSocket

創建一個配置類 WebSocketConfig,繼承 AbstractWebSocketMessageBrokerConfigurer,并配置 WebSocket 的相關信息:

@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("/websocket").withSockJS();
    }
}

這里配置了一個名為 /websocket 的 WebSocket 端點,并使用 SockJS 作為后備選項。同時,啟用了簡單的消息代理,用于將消息發布到 /topic 路徑。

  1. 創建 WebSocket 控制器

創建一個控制器 WebSocketController,用于處理客戶端發送的消息:

@Controller
public class WebSocketController {

    @MessageMapping("/send")
    @SendTo("/topic/messages")
    public String handleMessage(@Payload String message) {
        return "Received message: " + message;
    }
}

這里定義了一個名為 /send 的消息處理方法,使用 @MessageMapping 注解映射到 WebSocket 端點。當客戶端發送消息到 /app/send 時,該方法將被調用,并將消息發布到 /topic/messages

  1. 創建客戶端

創建一個簡單的 HTML 頁面,用于與 WebSocket 服務器進行通信:

<!DOCTYPE html>
<html>
<head>
    <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>
    <script>
        var socket = new SockJS('/websocket');
        var stompClient = Stomp.over(socket);

        stompClient.connect({}, function (frame) {
            console.log('Connected: ' + frame);
            stompClient.subscribe('/topic/messages', function (response) {
                console.log('Received: ' + response.body);
            });
        });

        function sendMessage() {
            var message = document.getElementById('message').value;
            stompClient.send("/app/send", {}, message);
        }
    </script>
</head>
<body>
    <input type="text" id="message" placeholder="Type your message here">
    <button onclick="sendMessage()">Send</button>
</body>
</html>

這里使用 SockJS 和 Stomp.js 庫創建了一個 WebSocket 客戶端,連接到 /websocket 端點,并訂閱了 /topic/messages 主題。當用戶點擊發送按鈕時,客戶端將向服務器發送消息。

現在,你可以運行 Spring Boot 應用程序,并在瀏覽器中打開 HTML 頁面。當用戶在輸入框中輸入消息并點擊發送按鈕時,服務器將接收到消息并將其發布到 /topic/messages 主題,客戶端將接收到并顯示該消息。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

商南县| 宣汉县| 上饶县| 皮山县| 堆龙德庆县| 昭苏县| 个旧市| 惠安县| 博野县| 新津县| 乌兰察布市| 南投市| 界首市| 东方市| 新河县| 彭泽县| 通江县| 长武县| 上杭县| 哈巴河县| 大名县| 奉贤区| 平度市| 施甸县| 临泽县| 仁布县| 怀安县| 常德市| 汝阳县| 二连浩特市| 乌兰察布市| 黑龙江省| 五寨县| 弋阳县| 新平| 武胜县| 县级市| 方山县| 南溪县| 漳平市| 平南县|