Reactor Netty UDP 客户器端-响应式编程-017

2024-05-11 09:12

本文主要是介绍Reactor Netty UDP 客户器端-响应式编程-017,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

 🤗 ApiHug × {Postman|Swagger|Api...} = 快↑ 准√ 省↓

  1. GitHub - apihug/apihug.com: All abou the Apihug   
  2. apihug.com: 有爱,有温度,有质量,有信任
  3. ApiHug - API design Copilot - IntelliJ IDEs Plugin | Marketplace

   The Next Generation API Development Platform - ApiHug

api-hug-contact

UDP协议 UDP(User Datagram Protocol) , 文中代码都在: UDP 客户端例子open in new window。

#链接

要将UDP客户端连接到给定的端点,您必须创建并且配置一个UdpClient 实例。默认情况下,host为localhost,post为12012。下面是创建和连接一个UDP客户端的例子:

public static void main(String[] args) {Connection connection =UdpClient.create() // <1>.connectNow(Duration.ofSeconds(30)); // <2>connection.onDispose().block();
}
  1. <1> 创建一个UdpClient 实例用来进行的配置操作。
  2. <2> 用阻塞的方式进行连接操作,并且等待它初始化完成。

#预热

public static void main(String[] args) {UdpClient udpClient =UdpClient.create().host("example.com").port(80).handle((udpInbound, udpOutbound) -> udpOutbound.sendString(Mono.just("hello")));udpClient.warmup() // <1>.block();Connection connection = udpClient.connectNow(Duration.ofSeconds(30)); // <2>connection.onDispose().block();
}
  1. <1> 初始化和加载事件循环组,主机名解析器和native传输库
  2. <2> 在连接远程节点的时候会进行主机名解析

#写数据

public static void main(String[] args) {Connection connection =UdpClient.create().host("example.com").port(80).handle((udpInbound, udpOutbound) -> udpOutbound.sendString(Mono.just("hello"))) // <1>.connectNow(Duration.ofSeconds(30));connection.onDispose().block();
}

如果要发送数据到一个已有的端点,您必须添加一个I/O处理器。这个I/O处理器可以通过UdpOutbound 来写出数据。

#读数据

public static void main(String[] args) {Connection connection =UdpClient.create().host("example.com").port(80).handle((udpInbound, udpOutbound) -> udpInbound.receive().then()) // <1>.connectNow(Duration.ofSeconds(30));connection.onDispose().block();
}

如果要接收从已有端点发过来的数据,您必须添加一个I/O处理器。这个I/O处理器可以通过UdpInbound 来读取数据

其他也基本以此类推。

#参考

  1. Reactor Netty 官方文档open in new window
  2. reactor-netty-demo 学习

 

这篇关于Reactor Netty UDP 客户器端-响应式编程-017的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/979107

相关文章

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器:探测开放端口2.简易 HTTP 服务器:10 秒搭个网页3.局域网游戏:多人联机对战4.

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

一文详解SpringBoot响应压缩功能的配置与优化

《一文详解SpringBoot响应压缩功能的配置与优化》SpringBoot的响应压缩功能基于智能协商机制,需同时满足很多条件,本文主要为大家详细介绍了SpringBoot响应压缩功能的配置与优化,需... 目录一、核心工作机制1.1 自动协商触发条件1.2 压缩处理流程二、配置方案详解2.1 基础YAML

Java的IO模型、Netty原理解析

《Java的IO模型、Netty原理解析》Java的I/O是以流的方式进行数据输入输出的,Java的类库涉及很多领域的IO内容:标准的输入输出,文件的操作、网络上的数据传输流、字符串流、对象流等,这篇... 目录1.什么是IO2.同步与异步、阻塞与非阻塞3.三种IO模型BIO(blocking I/O)NI

如何解决Spring MVC中响应乱码问题

《如何解决SpringMVC中响应乱码问题》:本文主要介绍如何解决SpringMVC中响应乱码问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Spring MVC最新响应中乱码解决方式以前的解决办法这是比较通用的一种方法总结Spring MVC最新响应中乱码解

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法:给并发装上"节流阀"三、进阶控制

springMVC返回Http响应的实现

《springMVC返回Http响应的实现》本文主要介绍了在SpringBoot中使用@Controller、@ResponseBody和@RestController注解进行HTTP响应返回的方法,... 目录一、返回页面二、@Controller和@ResponseBody与RestController

SpringBoot定制JSON响应数据的实现

《SpringBoot定制JSON响应数据的实现》本文主要介绍了SpringBoot定制JSON响应数据的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们... 目录前言一、如何使用@jsonView这个注解?二、应用场景三、实战案例注解方式编程方式总结 前言

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁(Deadlock)是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁?死锁的典型条件:2. 导致死锁的常见原因2.1 锁的顺序问题错误示例:不同

PyCharm接入DeepSeek实现AI编程的操作流程

《PyCharm接入DeepSeek实现AI编程的操作流程》DeepSeek是一家专注于人工智能技术研发的公司,致力于开发高性能、低成本的AI模型,接下来,我们把DeepSeek接入到PyCharm中... 目录引言效果演示创建API key在PyCharm中下载Continue插件配置Continue引言