|
@@ -36,7 +36,9 @@ public class SseController {
|
|
public SseEmitter handleSse(@RequestParam("token") String token) throws IOException {
|
|
public SseEmitter handleSse(@RequestParam("token") String token) throws IOException {
|
|
SseEmitter sseEmitter = new SseEmitter(300 * 1000L); // 设置超时时间
|
|
SseEmitter sseEmitter = new SseEmitter(300 * 1000L); // 设置超时时间
|
|
sseService.monitor(token, sseEmitter);
|
|
sseService.monitor(token, sseEmitter);
|
|
- sseEmitter.send("data");
|
|
|
|
|
|
+ for (int i = 0; i < 100; i++) {
|
|
|
|
+ sseEmitter.send("data");
|
|
|
|
+ }
|
|
return sseEmitter;
|
|
return sseEmitter;
|
|
}
|
|
}
|
|
|
|
|