Springboot使用SSE推送消息到客戶端的實(shí)現(xiàn)

更新時(shí)間：2026年01月23日 08:25:11 作者：愛(ài)吃的強(qiáng)哥

文章瀏覽閱讀246次,點(diǎn)贊4次,收藏4次,本文介紹了在SpringBoot中實(shí)現(xiàn)SSE（Server-Sent Events）服務(wù)端推送功能,用于Electron桌面應(yīng)用的消息推送,感興趣的可以了解一下

1、場(chǎng)景：

服務(wù)端主動(dòng)推動(dòng)消息到客戶端（Electron 桌面應(yīng)用）

普通的HTTP/HTTPS請(qǐng)求要先客戶端發(fā)送請(qǐng)求，然后服務(wù)端才能返回結(jié)果

服務(wù)端主動(dòng)推送數(shù)據(jù)到客戶端，有兩種方案：

SSE：只能從服務(wù)端主動(dòng)推送數(shù)據(jù)到客戶端（單向），客戶端發(fā)送數(shù)據(jù)還是要使用HTTP/HTTPS請(qǐng)求

Socket 通信：客戶端和服務(wù)端都可以發(fā)送數(shù)據(jù)給對(duì)方（雙向）

先記錄SSE的配置（我的服務(wù)端之前是用nodejs express 寫(xiě)的，已經(jīng)使用 socket.io與客戶端適配好了，現(xiàn)在用Springboot重構(gòu)）

2、實(shí)現(xiàn)：

1、springboot 配置：

1、先實(shí)現(xiàn)Server層，方便其他控制器調(diào)用

package com.xxx.controller;
 
import com.qiang.service.SseService;
import com.qiang.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
 
@RestController
@RequestMapping("/sse")
public class SseController {
 
    // 注入 SSE 服務(wù)類
    @Autowired
    private SseService sseService;
    @Autowired
    private UserService userService;
 
    /**
     * 建立 SSE 連接（調(diào)用 Service 的注冊(cè)方法）
     */
    @GetMapping("/connect")
    public SseEmitter connect(@RequestParam String clientId) {
        // 查詢會(huì)話成員表，userId通過(guò)客戶端id獲取該用戶所有的群聊
        String userId = clientId.split("_")[2].trim();
        List<String> groupIdList = userService.getUserGroupChat(userId);
        Set<String> groupIdSet = new HashSet<>();
        if (groupIdList != null && !groupIdList.isEmpty()) {
            groupIdSet = new HashSet<>(groupIdList); // List → Set，自動(dòng)去重
        }
        return sseService.registerClient(clientId, groupIdSet);
    }
 
    /**
     * 手動(dòng)推送（調(diào)用 Service 的推送方法）
     */
    @PostMapping("/push")
    public String push(@RequestBody Map<String, String> params) {
        String clientId = params.get("clientId");
        String message = params.get("message");
        return sseService.sendMessage(clientId, "business", message);
    }
 
    /**
     * 獲取在線客戶端數(shù)量
     */
    @GetMapping("/count")
    public String getClientCount() {
        return "當(dāng)前在線客戶端數(shù)量：" + sseService.getConnectedClientCount();
    }
}

2、再實(shí)現(xiàn)控制層：

package com.xxx.controller;
 
import com.qiang.service.SseService;
import com.qiang.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
 
@RestController
@RequestMapping("/sse")
public class SseController {
 
    // 注入 SSE 服務(wù)類
    @Autowired
    private SseService sseService;
    @Autowired
    private UserService userService;
 
    /**
     * 建立 SSE 連接（調(diào)用 Service 的注冊(cè)方法）
     */
    @GetMapping("/connect")
    public SseEmitter connect(@RequestParam String clientId) {
        // 查詢會(huì)話成員表，userId通過(guò)客戶端id獲取該用戶所有的群聊
        String userId = clientId.split("_")[2].trim();
        List<String> groupIdList = userService.getUserGroupChat(userId);
        Set<String> groupIdSet = new HashSet<>();
        if (groupIdList != null && !groupIdList.isEmpty()) {
            groupIdSet = new HashSet<>(groupIdList); // List → Set，自動(dòng)去重
        }
        return sseService.registerClient(clientId, groupIdSet);
    }
 
    /**
     * 手動(dòng)推送（調(diào)用 Service 的推送方法）
     */
    @PostMapping("/push")
    public String push(@RequestBody Map<String, String> params) {
        String clientId = params.get("clientId");
        String message = params.get("message");
        return sseService.sendMessage(clientId, "business", message);
    }
 
    /**
     * 獲取在線客戶端數(shù)量
     */
    @GetMapping("/count")
    public String getClientCount() {
        return "當(dāng)前在線客戶端數(shù)量：" + sseService.getConnectedClientCount();
    }
}

2、客戶端（Electron 配置）：

eventsource 是瀏覽器對(duì)象

我是在客戶端主進(jìn)程中接收消息的，要下載依賴。如果是在渲染進(jìn)程或者是普通前端使用則不需要下載依賴

"eventsource": "^2.0.2"

1、工具函數(shù)：

// src/util/sseClient.js（主進(jìn)程專用）
const EventSource = require('eventsource');
 
class SseClient {
    constructor(clientId) {
        this.clientId = clientId;
        this.isConnected = false; // 標(biāo)記是否真正連接成功
        this.initSse();
    }
 
    initSse() {
        this.close(); // 關(guān)閉舊連接
 
        const sseUrl = `http://localhost:8088/sse/connect?clientId=${this.clientId}`;
        console.log(`[SSE] 嘗試連接：${sseUrl}`);
 
        this.es = new EventSource(sseUrl);
 
        // 1. 連接成功（標(biāo)記真正的連接狀態(tài)）
        this.es.onopen = () => {
            this.isConnected = true;
            console.log('[SSE] 連接成功');
        };
 
        // 2. 優(yōu)化錯(cuò)誤處理（過(guò)濾無(wú)害錯(cuò)誤）
        this.es.onerror = (e) => {
            // 過(guò)濾：連接成功前的無(wú)消息錯(cuò)誤（無(wú)害）
            if (!this.isConnected && e.message === undefined) {
                console.log('[SSE] 初始化階段臨時(shí)錯(cuò)誤（無(wú)害）：', e.type);
                return; // 不打印錯(cuò)誤，避免干擾
            }
 
            // 真正的錯(cuò)誤（連接斷開(kāi)/失敗）
            this.isConnected = false;
            console.error('[SSE] 真正的連接錯(cuò)誤：', {
                type: e.type,
                message: e.message || '未知錯(cuò)誤',
                readyState: this.es.readyState // 0:連接中, 1:已連接, 2:已關(guān)閉
            });
 
            // 僅在連接關(guān)閉時(shí)重連
            if (this.es.readyState === EventSource.CLOSED) {
                console.log(`[SSE] 3秒后嘗試重連...`);
                setTimeout(() => this.initSse(), 3000);
            }
        };
 
        // 3. 正常接收消息
        this.es.onmessage = (e) => {
            try {
                const cleanData = e.data.replace(/^data: /, '').trim();
                const messageObj = JSON.parse(cleanData);
                // 打印解析結(jié)果（驗(yàn)證）
                console.log('[SSE] 解析后的完整對(duì)象：', messageObj);
            } catch (err) {
                // 解析失敗時(shí)的容錯(cuò)
                console.warn('[SSE] 解析失敗，原始數(shù)據(jù)：', e.data);
                console.error('[SSE] 解析錯(cuò)誤詳情：', err);
            }
        };
 
        // 4. 監(jiān)聽(tīng)自定義事件（如 notification/business）
        this.es.addEventListener('notification', (e) => {
            const data = JSON.parse(e.data);
            console.log('[SSE] 通知消息：', data);
        });
    }
 
    close() {
        if (this.es) {
            this.es.close();
            this.es = null;
            this.isConnected = false;
        }
    }
 
    // 手動(dòng)推送（修復(fù)后的 POST 版本）
    async triggerPush(message) {
        if (!this.isConnected) {
            console.warn('[SSE] 未連接，無(wú)法推送');
            return null;
        }
        try {
            const response = await fetch(`${this.serverUrl || 'http://localhost:8088'}/sse/push`, {
                method: 'POST',
                headers: { 'Content-Type': 'application/json' },
                body: JSON.stringify({ clientId: this.clientId, message })
            });
            const result = await response.text();
            console.log('[SSE] 手動(dòng)推送結(jié)果：', result);
            return result;
        } catch (err) {
            console.error('[SSE] 手動(dòng)推送失敗：', err);
            return null;
        }
    }
}
 
module.exports = SseClient;

2、調(diào)用：

// clientId 要唯一，否則服務(wù)端推送消息時(shí)會(huì)有影響 
new SseClient("自定義的clientId");

到此這篇關(guān)于Springboot使用SSE推送消息到客戶端的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Springboot SSE推送內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

Springboot使用SSE推送消息到客戶端的實(shí)現(xiàn)

目錄

1、場(chǎng)景：

2、實(shí)現(xiàn)：

1、springboot 配置：

1、先實(shí)現(xiàn)Server層，方便其他控制器調(diào)用

2、再實(shí)現(xiàn)控制層：

2、客戶端（Electron 配置）：

1、工具函數(shù)：

2、調(diào)用：

相關(guān)文章

最新評(píng)論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线 免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

Springboot使用SSE推送消息到客戶端的實(shí)現(xiàn)

目錄

1、場(chǎng)景：

2、實(shí)現(xiàn)：

1、springboot 配置：

1、先實(shí)現(xiàn)Server層，方便其他控制器調(diào)用

2、再實(shí)現(xiàn)控制層：

2、客戶端（Electron 配置）：

1、工具函數(shù)：

2、調(diào)用：

相關(guān)文章

最新評(píng)論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

2、實(shí)現(xiàn)：

1、先實(shí)現(xiàn)Server層，方便其他控制器調(diào)用

2、再實(shí)現(xiàn)控制層：

2、客戶端（Electron 配置）：

2、調(diào)用：