我如何获得EventSource.要工作吗?

Question

如何获取EventSource。要工作吗?

这是我的订阅和推送代码:

public SseEmitter subscribe() throws Exception {
SseEmitter emitter = new SseEmitter(1800000L);
emitters.add(emitter);
emitter.onCompletion(() -> {
synchronized (emitters) {
emitters.remove(emitter);
}
});
emitter.onTimeout(() -> {
emitter.complete();
emitters.remove(emitter);
});
return emitter;
}

@Async
public void pushEventMap(Map<String, Object> pushMap) throws IOException {
List<SseEmitter> deadEmitters = new ArrayList<>();
HashMap<String,Object> map = (HashMap<String,Object>) pushMap;
emitters.forEach(emitter -> {
try {
emitter.send(SseEmitter.event().name("myEvent").data(map));
} catch (Exception e) {
emitter.completeWithError(e);
logger_error.error("pushEvent Exception:" + e);
deadEmitters.add(emitter);
}
});
emitters.removeAll(deadEmitters);
}

上述服务的控制器为:

@RequestMapping(value = "/subscribe", produces = "text/event-stream")
public ResponseEntity<SseEmitter> subscribe() throws Exception {
final SseEmitter emitter = eventService.subscribe();
return new ResponseEntity<>(emitter, HttpStatus.OK);
}
@RequestMapping(value = "/publish")
public void publish() throws IOException {
eventService.pushEventMap(pushMap);
}

我想让客户端通过js接收事件推送的数据。

const eventInit = () => {
console.log("eventInit called");
const url = 'http://localhost:8080/itf/subscribe';
const eventSource = new EventSource(url);
var httpRequest = new XMLHttpRequest();
eventSource.onmessage = (event) => {
const data = JSON.parse(event.data);
console.log('===');
console.log(data);
}
eventSource.onopen = (event) => {
console.log('sse open');
console.log(event);
}
eventSource.onerror = (event) => {
if (event.readyState == EventSource.CLOSED) {
console.log('sse close');
} else {
console.log("onerror", e);
}
}
}

在此状态下，如果我通过邮递员发送事件生成数据，则sse open出现在控制台上。

但是不显示事件的结果。

如果我通过url直接访问/itf/subscribe，事件的结果将显示在屏幕上。但是，我没有通过event.onmessage收到事件的结果。

我想要的是引发一个事件，然后通过onmessage函数接收事件的结果。

我想知道我怎样才能得到事件的结果。

问好

Answer 1

代码没有问题，实际的问题是当我写响应客户端我的响应消息应该如下所示。

PrintWriter out = response.write("data: message"+value+"nn");
out.flush(); //don't forget to flush

在我的代码中，我遗漏了最后一部分"nn"在响应对象中，所以javascript中的source.onmessage(datalist)没有被击中。

Answer 2

eventSource.addEventListener('myEvent', function (event) {
console.log(event);
const data = JSON.parse(event.data);
console.log('addEventListener');
console.log(data);
// console.log(data.siteCode);
eventEffect(data);
}, false);

这是正常工作!