放弃WebSocket？SSE几行代码搞定服务端单向推送

一、简介

在实际项目开发中，实时通讯是常见的需求。我们通常使用 WebSocket 来实现这一功能，但在很多场景下，客户端只是需要从服务器接收消息，而非进行双向通讯。这导致 WebSocket 的全双工特性并没有得到充分的利用。那么，是否有更简单的替代方案呢？

本文将介绍 Server‑Sent Events (SSE)，一种轻量级的方式来实现服务器向客户端推送消息的需求，同时对比 SSE、WebSocket 和传统轮询技术的优劣，帮助开发者选择适合的实时通讯方案。

SSE、轮询、WebSocket 详细对比表：

二、聊聊为什么放弃了 Websocket，我只需要写一两行代码

当我们考虑 WebSocket 时，虽然它是双向通信的强大工具，但在某些场景下确实显得过于“重型”，尤其是你只需要服务器单向推送数据，而不是用户发送信息回来。

以下是 WebSocket 在身份证识别这类场景中不太实用的几点原因，顺便带出 SSE 的优势：

• 权限验证不便 ：WebSocket 通常需要手动处理，通过在 WebSocket 握手时传递 token 等。
• 日志记录复杂
• SSE 集成简单 ：SSE 不需要额外引入依赖。
• 连接管理复杂 ：Websocket 需要额外编写断线重连等代码。
• 定时任务执行不方便 ：Websocket 需要额外编写定时发送消息代码。

三、编写一个统计在线用户的 SSE 接口，看看前端给我的效果

1. 配置自己的 AsyncTaskExecutor

如果不配置 AsyncTaskExecutor，不建议在生产环境下使用，SpringBoot 会给出警告。

@Configuration
@Slf4j
public class WebMvcConfig implements WebMvcConfigurer {

    // 定义自定义的 AsyncTaskExecutor Bean
    @Bean(name = "customAsyncTaskExecutor")
    public AsyncTaskExecutor customAsyncTaskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        int corePoolSize = Runtime.getRuntime().availableProcessors(); // 核心线程数设置为 CPU 核心数
        int maxPoolSize = corePoolSize * 2; // 最大线程数设置为核心数的两倍
        int queueCapacity = 500; // 队列容量

        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.setThreadNamePrefix("AsyncExecutor-");
        executor.setWaitForTasksToCompleteOnShutdown(true); // 关闭时等待任务完成
        executor.setAwaitTerminationSeconds(60); // 关闭时最多等待 60 秒

        executor.initialize(); // 初始化线程池

        return executor;
    }

    @Override
    public void configureAsyncSupport(AsyncSupportConfigurer configurer) {
        configurer.setTaskExecutor(customAsyncTaskExecutor()); // 使用自定义的 AsyncTaskExecutor
        configurer.setDefaultTimeout(5000); // 设置异步请求的默认超时时间（毫秒）
    }
}

2. 编写具体代码

@PreventDuplicateSubmit
@PreAuthorize("@permission.checker('monitor:online-user:list')")
@GetMapping(value = "/user-activity-sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<Integer> streamUserActivitySSE() {
    // 创建一个持续时间为指定秒数的 Flux 流
    return Flux.interval(Duration.ofSeconds(5))
            .flatMap(sequence -> Mono
                    .fromCallable(onlineUserService::getUserActivityNum) // 返回在线用户人数
                    .onErrorReturn(0)
            );
}

3. 看看前端效果

前端页面会实时展示在线用户数量的折线图，每隔 5 秒自动更新，无需手动刷新。

四、聊聊之前开发中应该使用 SSE 却使用了轮询的事

在两年前，我接到了一个需求——对接身份证识别仪器，机器大概长这样（类似读卡器设备）。

因为这个机器是 C++ 编写的，我们后端是 Java，所以需要集成一下。但是这个机器需要你一直调用接口去扫描，它不会主动告诉你身份证识别了没有。

当时，当用户进入需要身份证认证的页面时，我们就开始进行身份证检测。但不知道用户多久会把身份证放到机器上，领导这个功能又催得很急。对接完机器之后，我偷偷和前端说：“我们摸摸鱼，用轮询解决就行。” 前端也是直接开写，最后 10 分钟就搞定了。

在这里 sorry 领导，如果那时候你不催我，我可以告诉你使用 SSE 解决。

五、源码 & 结束语

Websocket 和 SSE 有各自的应用场景，不存在谁好谁坏，有些问题用轮询也能解决。其他还有很多地方可以使用 SSE 编写，比如消息通知等。

前端文章地址：
https://juejin.cn/post/7410965438044012582

后端源码地址：
https://gitee.com/fateyifei/yf/blob/master/yf-boot-admin/yf-admin/src/main/java/com/yf/controller/monitor/OnlineUserController.java

本文由云栈社区整理发布，欢迎交流探讨更多轻量级实时通讯方案。