快捷導(dǎo)航

springboot中websocket簡(jiǎn)單實(shí)現(xiàn)

更新時(shí)間：2023年01月06日 09:03:04 作者：C~LOVER

本文主要介紹了springboot中websocket簡(jiǎn)單實(shí)現(xiàn)，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

websocket簡(jiǎn)單實(shí)現(xiàn)

websocket是HTML5下一種新的協(xié)議，本質(zhì)上websocket是一個(gè)基于tcp的協(xié)議。它實(shí)現(xiàn)了瀏覽器與服務(wù)器之間的雙向通信，能更好的節(jié)省服務(wù)器資源和寬帶并實(shí)現(xiàn)實(shí)時(shí)的通信。
websocket的幾個(gè)優(yōu)點(diǎn)?
1、使用的資源少，因?yàn)樗念^更小。
2、實(shí)時(shí)性更強(qiáng)：服務(wù)端可以通過(guò)連接主動(dòng)向客戶端推送消息。
3、有狀態(tài)：開(kāi)啟連接之后可以不用每次都攜帶狀態(tài)信息。

下面介紹spring集成的websocket的使用方法。

引入依賴包

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

實(shí)現(xiàn)WebSocketHandler 接口重寫相關(guān)方法。

主要有以下幾個(gè)方法：
afterConnectionEstablished：連接成功后調(diào)用。
handleMessage：處理發(fā)送來(lái)的消息。
handleTransportError： WS 連接出錯(cuò)時(shí)調(diào)用。
afterConnectionClosed：連接關(guān)閉后調(diào)用。
supportsPartialMessages：是否支持分片消息。

import cn.hutool.core.collection.CollUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.socket.*;

import java.io.IOException;
import java.util.concurrent.CopyOnWriteArrayList;

/**
 * 測(cè)試websocket
 *
 * @author yjj
 * @version 1.0
 * @since 2022 -12-28 14:55:29
 */
@Slf4j
@Component
public class TestWebsocket implements WebSocketHandler {

    protected static final CopyOnWriteArrayList<WebSocketSession> WEB_SOCKET_SESSIONS = new CopyOnWriteArrayList<>();

    /**
     * 建立連接后操作
     *
     * @param session       連接session信息
     * @throws Exception    exception
     */
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        WEB_SOCKET_SESSIONS.add(session);
        sendMessage("連接成功~~~~~~,sessionId=" + session.getId());
    }

    /**
     * 接收到消息后的處理
     *
     * @param session       連接session信息
     * @param message       信息
     * @throws Exception    exception
     */
    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        sendMessage("接收到的消息為=【"+ message +"】,sessionId=【"+ session.getId() +"】,回復(fù)消息=【你好呀！】");
    }

    /**
     * ws連接出錯(cuò)時(shí)調(diào)用
     *
     * @param session       session連接信息
     * @param exception     exception
     * @throws Exception    exception
     */
    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        if(session.isOpen()){
            sendMessage("ws連接出錯(cuò)，即將關(guān)閉此session,sessionId=【"+ session.getId() +"】");
            session.close();
        }
        WEB_SOCKET_SESSIONS.remove(session);
    }

    /**
     * 連接關(guān)閉后調(diào)用
     *
     * @param session           session連接信息
     * @param closeStatus       關(guān)閉狀態(tài)
     * @throws Exception        exception
     */
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        if(session.isOpen()){
            sendMessage("ws連接即將關(guān)閉此session,sessionId=【"+ session.getId() +"】");
            session.close();
        }
        WEB_SOCKET_SESSIONS.remove(session);
    }

    /**
     * 是否支持分片消息
     */
    @Override
    public boolean supportsPartialMessages() {
        return false;
    }

    /**
     * 發(fā)送消息
     * @param message          消息
     * @throws IOException     ioException
     */
    public void sendMessage(String message) throws IOException {
        if(CollUtil.isNotEmpty(WEB_SOCKET_SESSIONS)){
            for (WebSocketSession webSocketSession : WEB_SOCKET_SESSIONS) {
                webSocketSession.sendMessage(new TextMessage(message));
            }
        }
    }
}

監(jiān)聽(tīng)某個(gè)URL，websocket配置

import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;

import javax.annotation.Resource;
/**
 * websocket配置
 *
 * @author yjj
 * @version 1.0
 * @since 2022 -12-28 15:10:11
 */
@EnableWebSocket
@Configuration
public class WebSocketConfig implements WebSocketConfigurer {

    @Resource
    private TestWebsocket testWebsocket;

    /**
     * Register {@link WebSocketHandler WebSocketHandlers} including SockJS fallback options if desired.
     *
     * @param registry
     */
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(testWebsocket, "/test").setAllowedOrigins("*");
    }
}

測(cè)試
使用websocket工具進(jìn)行連接后效果圖如下:

在這里插入圖片描述

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

您可能感興趣的文章: