`
zysnba
  • 浏览: 185945 次
  • 性别: Icon_minigender_1
  • 来自: 北京
文章分类
社区版块
存档分类
最新评论

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包的使用
分享到:
评论

相关推荐

    DynamicCustomVI_动态调用_labview_静态调用_

    本话题将深入探讨"动态调用"和"静态调用"这两种在LabVIEW中调用VI的方式,并分析它们之间的差异与优劣。 1. **动态调用(Dynamic Invocation)** 动态调用是LabVIEW中的一种灵活调用方式,它允许在运行时决定要...

    C调用REFPROP_refprop_C++调用refprop_调用REFPROP_C++_C调用REFPROP

    在本文中,我们将深入探讨如何在C++程序中调用REFPROP库,这是一个广泛用于流体性质计算的软件包。REFPROP(Reference Properties of Fluids)由美国国家标准与技术研究所(NIST)开发,提供了精确的流体性质计算,...

    C#与JAVASCRIPT函数的相互调用 C#调用JAVASCRIPT函数的调用 JAVASCRIPT调用C#函数的调用

    C#与JAVASCRIPT函数的相互调用 C#调用JAVASCRIPT函数的调用 JAVASCRIPT调用C#函数的调用

    discuz 调用插件丨discuz js调用插件丨调用discuz插件丨discuz 调用热门帖子

    假如是BBS是二级目录,调用页面在根目录下,则如此调用 <script type="text/javascript" src="bbs/mybbs.php?key=25&m=10&l=15"></script> 至于调用的路径是否正确,你可以自行调整,并且可以修改mybbs.php中的中...

    基于JavaParser的代码调用链分析,可以用于分析Java代码的方法调用链.zip

    3. **构建调用图**:根据找到的方法调用信息,可以构建一个调用图,其中每个节点代表一个方法,边表示方法间的调用关系。 4. **分析调用链**:在调用图的基础上,可以分析最长路径、最短路径、循环调用等,从而揭示...

    ioctl系统调用流程

    ioclt系统调用流程 Ioctl系统调用流程是Linux操作系统中的一种系统调用机制,用于控制设备文件的行为。该机制通过系统调用函数sys_ioctl来实现,下面将详细介绍ioctl系统调用流程。 一、系统调用框架 在Linux操作...

    webservice的动态调用和静态调用

    在开发中,我们通常会遇到两种调用方式:动态调用和静态调用。这两种方法各有特点,适用于不同的场景。 静态调用是通过在项目中添加Web引用或者服务引用来实现的。这种调用方式在编译时就已经确定了服务接口,因此...

    传址调用 传址调用 传址调用 传址调用

    传址调用 传址调用 传址调用 传址调用传址调用 传址调用 传址调用 传址调用

    使用Python调用微信本地ocr服务.zip

    使用Python调用微信本地ocr服务.zip使用Python调用微信本地ocr服务.zip使用Python调用微信本地ocr服务.zip使用Python调用微信本地ocr服务.zip使用Python调用微信本地ocr服务.zip使用Python调用微信本地ocr服务.zip...

    网页调用OCX 和 调用OCX的接口函数

    网页调用OCX(ActiveX控件)是一种在网页中集成特定功能的技术,它允许网页与本地系统进行交互,比如播放视频、打印文档或者执行一些特定的系统操作。ActiveX是微软开发的一种技术,它扩展了HTML和JavaScript的能力...

    Python 解决调用Word2007时出现“尚未调用Colnitialize”错误 Python源码

    Python 解决调用Word2007时出现“尚未调用Colnitialize”错误 Python源码Python 解决调用Word2007时出现“尚未调用Colnitialize”错误 Python源码Python 解决调用Word2007时出现“尚未调用Colnitialize”错误 Python...

    新增系统调用并统计NtCreatFile进程调用次数

    在操作系统领域,系统调用是用户程序与操作系统内核交互的主要途径。系统调用提供了诸如创建文件、读写文件、管理进程等基本功能。在这个实验中,我们将关注如何新增一个系统调用,并统计`NtCreateFile`进程调用的...

    QT调用dll和MFC调用QT的dll

    在软件开发中,有时我们需要在QT环境中调用动态链接库(DLL),或者将QT编译成DLL供MFC应用使用。这篇内容将深入探讨如何实现这些操作。 1. QT调用DLL: - 创建DLL:首先,你需要在QT环境中创建一个DLL项目,定义...

    亲测可用,java 成功调用dll函数。包含调用回调函数,springboot版本。最近由于公司业务需要,要调用dll文件,用JNA调用。

    Java调用DLL函数是跨平台编程中的一种常见需求,特别是在Java与C/C++代码交互时。JNA(Java Native Access)是Java平台上的一个库,它允许Java代码直接调用本机库(如DLL文件)的函数,而无需编写JNI(Java Native ...

    使用Python调用OpenAI接口-OpenAI接口调用python库源码.zip

    使用Python调用OpenAI接口-OpenAI接口调用python库源码.zip使用Python调用OpenAI接口-OpenAI接口调用python库源码.zip使用Python调用OpenAI接口-OpenAI接口调用python库源码.zip使用Python调用OpenAI接口-OpenAI接口...

    PB调用http、api,PB解析json.zip

    PB调用http、api,PB解析json; PB调用http、api,PB解析json; PB调用http、api,PB解析json; PB调用http、api,PB解析json; PB调用http、api,PB解析json; PB调用http、api,PB解析json; PB调用http、api,PB解析...

    C++与js相互调用

    本文将详细探讨如何实现C++与JavaScript的互相调用,以及在这个过程中涉及的关键知识点。 首先,我们要了解C++和JavaScript是两种完全不同的编程语言,它们的应用场景各有侧重。C++是一种静态类型的、编译型的语言...

    进程间函数调用

    remote-function是一个跨进程通讯库,它可以像调用本进程函数一样调用另外一个进程的函数。 remote-function支持调用普通函数,也支持调用类的成员函数。 remote-function底层使用命令管道进行通讯,内置的流程完成...

    Api接口调用封装,实现POSt,GET等数据请求

    Api接口调用封装,实现POSt,GET等数据请求,Api接口调用封装,实现POSt,GET等数据请求,Api接口调用封装,实现POSt,GET等数据请求,Api接口调用封装,实现POSt,GET等数据请求,Api接口调用封装,实现POSt,GET等数据请求,...

Global site tag (gtag.js) - Google Analytics