java实现http协议_java用http协议本地文件
对于那些感兴趣的人,这是一个片段 . 我能够通过Flux Launcher 而不是reactor-netty UDP类来实现 .
private static final String SSDP_IP = “239.255.255.250”;
private static final int SSDP_PORT = 1900;
private static final int TIMEOUT = 5000;
String request = new String(“example”);
byte[] receiveData = new byte[1024];
DatagramPacket sendPacket = new DatagramPacket(request.getBytes(),
request.getBytes().length, InetAddress.getByName(SSDP_IP), SSDP_PORT);
DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length,
InetAddress.getLocalHost(), SSDP_PORT);
Flux response = Flux.create(emitter -> {
try (DatagramSocket socket = new DatagramSocket()) {
socket.setSoTimeout(TIMEOUT);
socket.send(sendPacket);
while (true) {
socket.receive(receivePacket);
emitter.next(receivePacket.getData());
}
} catch (SocketTimeoutException e) {
emitter.complete();
} catch (IOException e) {
emitter.error(e);
}
})
.map(mapper -> new String(receivePacket.getData(), 0, receivePacket.getLength()))
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/183164.html原文链接:https://javaforall.cn
相关文章
- java局域网发送文件_Java如何实现局域网文件传输代码案例分享
- Java 文件上传与下载
- java线程池的面试题_献给准备面试的你,Java线程and线程池面试题小结「建议收藏」
- Java删除文件(delete file in java)[通俗易懂]
- java二维数组试题_Java二维数组及习题总结
- java和c语言哪个简单_Java编程和C语言哪个好学
- java redis锁_Java中Redis锁的实现[通俗易懂]
- java static再赋值_java static变量可以赋值吗?
- java 读取字符串文件_Java读取文件为字符串
- Java Web(六)Servlet
- java 异或加密_Java异或技操作给任意的文件加密原理及使用详解
- Java学习笔记 (异常相关知识)
- Java 递归列出目录下的文件以及子目录详解编程语言
- java文件操作类(新建 复制 移动 删除文件和文件夹 获取扩展名)详解编程语言
- JAVA 文件读写大全详解编程语言
- Java遍历文件夹下所有文件并替换指定字符串详解编程语言
- java http post上传文件详解编程语言
- [二]Java虚拟机 jvm内存结构 运行时数据内存 class文件与jvm内存结构的映射 jvm数据类型 虚拟机栈 方法区 堆 含义详解编程语言
- 服务器上的文件Java获取Linux服务器文件:简单又高效的操作方法(java获取linux)
- 策略Java中使用Redis的超时策略(redisjava过期)
- 安装Oracle JDK 从Java进入下一个级别(oracle下载java)
- 缓存使用Redis让Java代码更加迅速缓存设置(redis设置java)
- 使用java实现http多线程断点下载文件(一)
- Java多线程的用法详解
- 用java生成html文件实现原理及代码
- Java使用jxl包写Excel文件适合列宽实现