Reactor Netty TCP 服务器端-响应式编程-011

ops/2024/11/13 9:41:27/

 🤗 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

Reactor Netty提供了易于使用和配置的TcpServer 。它隐藏了创建TCP服务器所需的大部分Netty的功能,并增加了Reactive Streams背压。

一下例子镜像自 reactor netty 官方demo 在 gitee 镜像: TCP Server 例子open in new window

TCP(Transmission Control Protocol 传输控制协议)

特点:

  1. TCP是面向连接的服务,可靠的进程到进程通信的协议(重传机制)
  2. TCP报文段封装在IP数据包中
  3. IP首部 + TCP报文段(包含TCP包头,应用层数据)

#创建

public class Application {public static void main(String[] args) {DisposableServer server =TcpServer.create() // <1>.bindNow(); // <2>server.onDispose().block();}
}
  1. 创建一个TcpServer 实例用来做配置操作。
  2. 使用阻塞等待的方式启动服务器,直到初始化完成。

返回的 DisposableServer 提供了简单的服务器API,包括disposeNow() ,这个方法可以以阻塞等待的方式来关闭服务器。

#Host & Port

想要设置特定host和port,您可以用下面的方式来配置TCP服务器:

public class Application {public static void main(String[] args) {DisposableServer server =TcpServer.create().host("localhost") // <1>.port(8080) // <2>.bindNow();server.onDispose().block();}
}
  1. 配置TCP服务器的host
  2. 配置TCP服务器的port

还可多端口服务:

public class MultiAddressApplication {public static void main(String[] args) {TcpServer tcpServer = TcpServer.create();DisposableServer server1 =tcpServer.host("localhost") // <1>.port(8080) // <2>.bindNow();DisposableServer server2 =tcpServer.host("0.0.0.0") // <3>.port(8081) // <4>.bindNow();Mono.when(server1.onDispose(), server2.onDispose()).block();}
}


http://www.ppmy.cn/ops/40761.html

相关文章

大模型微调方法汇总

微调方法 Freeze方法P-tuning方法 prefix-tuningPrompt TuningP-tuning v1P-tuning v2Lora方法 重要相关参数LoRA 的优势Qlora方法 相关参数微调经验 模型选择模型大小选择数据处理微调方案英文模型需要做词表扩充吗&#xff1f;如何避免灾难遗忘大模型的幻觉问题微调后的输出…

一起了解开源自定义表单的优势表现

随着社会的进步和科技的发展&#xff0c;越来越多的中小企业希望采用更为先进的软件平台&#xff0c;助力企业实现高效率的流程化管理。低代码技术平台、开源自定义表单已经慢慢走入大众视野&#xff0c;成为一款灵活、高效的数字化转型工具。流辰信息专注于低代码技术平台的研…

【论文阅读】<YOLOP: You Only Look Once for PanopticDriving Perception>

Abstract 全视驾驶感知系统是自动驾驶的重要组成部分。一个高精度的实时感知系统可以帮助车辆在驾驶时做出合理的决策。我们提出了一个全视驾驶感知网络&#xff08;您只需寻找一次全视驾驶感知网络&#xff08;YOLOP&#xff09;&#xff09;&#xff0c;以同时执行交通目标检…

【退役之重学Java】关于 Redis

一、Redis 都有哪些数据类型 String 最基本的类型&#xff0c;普通的set和get&#xff0c;做简单的kv缓存hash 这是一个类似map 的一种结构&#xff0c;这个一般可以将结构化的数据&#xff0c;比如一个对象&#xff08;前提是这个对象没有嵌套其他的对象&#xff09;给缓存在…

es6语法总结

【1】语法 &#xff08;1&#xff09;声明变量(let-var-const) 变量提升&#xff1a; 是JavaScript引擎在代码执行前将变量的声明部分提升到作用域顶部的行为。尽管变量的声明被提升了&#xff0c;变量的赋值&#xff08;即初始化&#xff09;仍然保留在原来的位置。因此&…

1-3 如何学习,才能让这门课真正发挥价值

如何学习&#xff0c;才能让这门课真正发挥价值 在正式踏上产品经理学习之路前。我希望以一名课程产品经理的身份&#xff0c;来向你解释下这门课的设计理念和学习方法&#xff0c;以便让它真正对你有所帮助。 为什么这么说呢&#xff1f;是因为我发现&#xff0c;大都具备非常…

13.跳跃游戏

文章目录 题目简介题目解答解法一&#xff1a;贪心算法&#xff0b;动态规划代码&#xff1a;复杂度分析&#xff1a; 题目链接 大家好&#xff0c;我是晓星航。今天为大家带来的是 跳跃游戏面试题 相关的讲解&#xff01;&#x1f600; 题目简介 题目解答 思路&#xff1a;这…

BUG:PyAutoGUI pyautogui.ImageNotFoundException

BUG:PyAutoGUI pyautogui.ImageNotFoundException 环境 python 3.10 PyAutoGUI0.9.54 PyScreeze0.1.30BUG详情 在确定屏幕存在指定图片的情况下&#xff0c;使用PyAutoGUI中的locateCenterOnScreen()函数识别图片失败弹出这个bug。 注意&#xff1a; 1 如果屏幕不存在指定图…