Spring Server Sent Event：单个SseEmitter能否共享给多个会话？

结论很明确：你需要为每个用户的活跃会话创建独立的SseEmitter，而非为企业创建单个发射器共享。

为什么不能共享单个企业级SseEmitter？ #

SseEmitter本质是绑定单个HTTP长连接的响应对象，每个用户的浏览器发起的SSE请求都是独立的HTTP连接，单个Emitter只能对应一个客户端连接。如果强行共享，会出现以下问题：

• 后连接的用户会覆盖前一个用户的连接，导致前序客户端收不到消息
• 单个Emitter完成响应（或超时）后会关闭连接，后续用户无法复用
• 并发场景下会出现线程安全问题，导致消息发送异常

正确实现思路 #

按企业维度维护活跃SseEmitter的集合，每个用户连接时将其Emitter加入所属企业的集合，事件触发时遍历集合发送消息：

• 维护一个线程安全的映射结构，比如Map<企业ID, Set<SseEmitter>>，用于关联企业和其下所有活跃用户的Emitter
• 用户发起SSE连接请求时，创建新的SseEmitter，加入对应企业的集合，并注册连接完成/超时的回调，及时移除失效的Emitter
• 当企业事件（如名称变更）发生时，遍历该企业的Emitter集合，逐个发送消息，同时处理发送失败的情况（移除失效Emitter）

代码示例（Spring Boot环境） #

// 全局线程安全的映射：企业ID -> 该企业下活跃的SseEmitter集合
private static final Map<String, Set<SseEmitter>> enterpriseEmitterMap = new ConcurrentHashMap<>();

// 用户连接SSE的端点
@GetMapping("/enterprise/sse")
public SseEmitter connectToEnterpriseSse(@RequestParam String enterpriseId) {
    // 创建Emitter，设置30分钟超时
    SseEmitter emitter = new SseEmitter(30 * 60 * 1000L);
    
    // 将Emitter加入对应企业的集合（不存在则创建）
    enterpriseEmitterMap.computeIfAbsent(enterpriseId, k -> ConcurrentHashMap.newKeySet()).add(emitter);
    
    // 连接完成/超时后，从集合中移除Emitter，避免内存泄漏
    emitter.onCompletion(() -> enterpriseEmitterMap.get(enterpriseId).remove(emitter));
    emitter.onTimeout(() -> enterpriseEmitterMap.get(enterpriseId).remove(emitter));
    
    return emitter;
}

// 触发企业名称变更事件时发送消息
public void broadcastEnterpriseNameChange(String enterpriseId, String newEnterpriseName) {
    Set<SseEmitter> emitters = enterpriseEmitterMap.getOrDefault(enterpriseId, Collections.emptySet());
    Iterator<SseEmitter> iterator = emitters.iterator();
    while (iterator.hasNext()) {
        SseEmitter emitter = iterator.next();
        try {
            emitter.send(SseEmitter.event()
                    .name("enterprise_name_change")
                    .data(newEnterpriseName, MediaType.TEXT_PLAIN));
        } catch (IOException e) {
            // 客户端已断开，移除失效的Emitter
            iterator.remove();
        }
    }
}

关键注意事项 #

• 必须使用线程安全的集合（如ConcurrentHashMap、ConcurrentHashSet），应对多用户并发连接和事件触发场景
• 务必处理Emitter的onCompletion和onTimeout回调，及时清理失效对象，防止内存泄漏
• 发送消息时捕获IO异常，因为客户端可能已主动断开连接，此时对应的Emitter无法再发送消息
• 若企业用户规模极大，可考虑引入Emitter分片、过期清理机制，优化内存占用

内容的提问来源于stack exchange，提问作者César Castro Aroche