httpsse调用

1,定义接口 
public SseEmitter get(@RequestBody  DTO dto){
return SseEmitter Service.getSseEmitter(dto);
}

2，实现ObjectMapper mapper = new ObjectMapper();
String params = mapper.writeValueAsString(Object参数);

EventSourceListener listener = new EventSourceListener() {
@Override
public void onOpen(EventSource eventSource, Response response) {
log.info("建立sse连接成功了哈哈");
}

@Override
public void onEvent(EventSource eventSource, String id, String type, String data) {

ResponseVO pesponseVO = new ResponseVO ();
try {
pesponseVO .setEvent(type);
pesponseVO .setData(data);
sseEmitter.send(pesponseVO );
//
} catch (Exception e) {

throw new RuntimeException(e);
}
}

@Override
public void onClosed(EventSource eventSource) {
log.info("连接关闭哈哈");
sseEmitter.complete();
}

@Override
public void onFailure(EventSource eventSource, Throwable t, Response response) {
log.info("连接失败了哈哈");
sseEmitter.completeWithError(t);
}
};
RequestBody body = RequestBody.create(params, MediaType.parse("application/json"));
Request request = new Request.Builder()
.url(url地址)
.method("POST", body)
.addHeader("Content-Type", "application/json")
.addHeader("Authorization", "你的token")
.build();
OkHttpClient client = new OkHttpClient().newBuilder().build();
EventSource.Factory factory = EventSources.createFactory(client);
factory.newEventSource(request, listener);
return sseEmitter;




备注  okhttp3包的使用