代码优化

yangys

2024-05-18 cc0bdfb33ef638dfafe3185c92c7076d815e1c9b

 smart-man-boot/src/main/java/com/qianwen/smartman/modules/sync/message/sse/SseEmitterServer.java

@@ -12,12 +12,13 @@
import org.springframework.stereotype.Service;
import org.springframework.web.context.request.async.AsyncRequestTimeoutException;
import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;

/**
 * 服务端主动推送:SSE (Server Send Event)。html5新标准，用来从服务端实时推送数据到浏览器端
 */
@Service
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/sync/message/sse/SseEmitterServer.class */
public class SseEmitterServer {
    private static final Logger log = LoggerFactory.getLogger(SseEmitterServer.class);
    private static final Map<String, SseEmitter> SSE_CACHE = new ConcurrentHashMap();
    private static final Map<String, SseEmitter> SSE_CACHE = new ConcurrentHashMap<>();

    public SseEmitter createSseConnect(String clientId) {
        if (StrUtil.isEmpty(clientId)) {
@@ -69,7 +70,7 @@
    }

    public void sendAll(Object data, String eventId) {
        SSE_CACHE.forEach(k, v -> {
        SSE_CACHE.forEach((k, v) -> {
            sendMsg(k, data, eventId);
        });
    }