commit

src/main/java/com/sxtvs/open/api/review/controller/SseController.java

@@ -34,24 +34,10 @@ public class SseController {
     @GetMapping(path = "/sse", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
     @NoAPIResponse
     public SseEmitter handleSse(@RequestParam("token") String token) throws IOException {
-        logger.debug("msg", "1");
         SseEmitter sseEmitter = new SseEmitter(300 * 1000L); // 设置超时时间
-        logger.debug("msg", "3");
         sseService.monitor(token, sseEmitter);
-        logger.debug("msg", "4");
-        poolExecutor.execute(() -> {
-            try {
-                logger.debug("msg", "6");
-                Thread.sleep(1000);
-                sseEmitter.send(SseEmitter.event().name("data").data("data"));
-                Thread.sleep(1000);
-                logger.debug("msg", "7");
-                sseEmitter.complete();
-            } catch (Exception e) {
-                logger.error("error", e);
-            }
-        });
-        logger.debug("msg", "5");
+        sseEmitter.send(SseEmitter.event().name("data").data("data"));
+        sseEmitter.complete();
         return sseEmitter;
     }