快捷導(dǎo)航

springboot實(shí)現(xiàn)簡(jiǎn)單的消息對(duì)話的示例代碼

更新時(shí)間：2023年09月03日 15:04:45 作者：曾幾何時(shí)…

本文主要介紹了springboot實(shí)現(xiàn)簡(jiǎn)單的消息對(duì)話的示例代碼,可以使用WebSocket技術(shù),WebSocket是一種在客戶端和服務(wù)器之間提供實(shí)時(shí)雙向通信的協(xié)議,具有一定的參考價(jià)值,感興趣的可以了解一下

一、前言

要在Spring Boot項(xiàng)目中實(shí)現(xiàn)消息對(duì)話，你可以使用WebSocket技術(shù)。WebSocket是一種在客戶端和服務(wù)器之間提供實(shí)時(shí)雙向通信的協(xié)議。

二、實(shí)戰(zhàn)步驟

步驟 1：

添加依賴首先，在您的Spring Boot項(xiàng)目的pom.xml文件中添加以下依賴：

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

步驟 2：

創(chuàng)建WebSocket配置類接下來(lái)，創(chuàng)建一個(gè)配置類來(lái)配置WebSocket相關(guān)的組件。例如，創(chuàng)建一個(gè)名為WebSocketConfig的類，并添加以下代碼：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(chatWebSocketHandler(), "/chat").setAllowedOrigins("*");
    }
    @Bean
    public WebSocketHandler chatWebSocketHandler() {
        return new ChatWebSocketHandler();
    }
}

步驟 3：

創(chuàng)建WebSocket處理程序類然后，創(chuàng)建一個(gè)WebSocket處理程序類來(lái)處理WebSocket連接和消息。例如，創(chuàng)建一個(gè)名為ChatWebSocketHandler的類，并添加以下代碼：

@Component
public class ChatWebSocketHandler extends TextWebSocketHandler {
    private static final List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
    }
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        for (WebSocketSession client : sessions) {
            if (client.isOpen()) {
                client.sendMessage(message);
            }
        }
    }
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session);
    }
}

步驟 4：

創(chuàng)建前端頁(yè)面接下來(lái)，您需要編寫一個(gè)前端頁(yè)面來(lái)與WebSocket進(jìn)行通信。您可以使用JavaScript和HTML來(lái)實(shí)現(xiàn)此功能。以下是一個(gè)簡(jiǎn)單的示例：

<!DOCTYPE html>
<html>
<head>
    <title>Chat</title>
    <script src="https://code.jquery.com/jquery-3.6.0.min.js"></script>
    <script>
        var socket = new WebSocket("ws://localhost:8080/chat");
        socket.onopen = function() {
            console.log("Connected to WebSocket");
        };
        socket.onmessage = function(event) {
            var message = event.data;
            console.log("Received message: " + message);
            // 在頁(yè)面上顯示收到的消息
            $("#messages").append("<p>" + message + "</p>");
        };
        function sendMessage() {
            var message = $("#message").val();
            socket.send(message);
        }
    </script>
</head>
<body>
    <input type="text" id="message" placeholder="Enter a message">
    <button onclick="sendMessage()">Send</button>
    <div id="messages"></div>
</body>
</html>

這是一個(gè)簡(jiǎn)單的聊天界面，用戶可以在輸入框中輸入消息，并通過(guò)點(diǎn)擊“發(fā)送”按鈕將其發(fā)送給服務(wù)器。服務(wù)器將收到的消息廣播給所有連接的客戶端。

到此這篇關(guān)于springboot實(shí)現(xiàn)簡(jiǎn)單的消息對(duì)話的示例代碼的文章就介紹到這了,更多相關(guān)springboot 消息對(duì)話內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: