Reactor Netty HTTP 服务器端-响应式编程-014

2024-05-10 09:04

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

 🤗 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提供了易于使用和配置的 HttpServer 。它隐藏了创建HTTP服务器所需的大部分Netty的功能,并增加了Reactive Streams背压。

Reactor Netty HTTP 服务器端测试代码open in new window

#启动和停止

要想启动一个HTTP服务器,您必须创建并且配置一个 HttpServer 实例。

默认情况下,host被配置为任何的本地地址,当执行bind操作的时候系统会选择一个临时端口。下面是创建并且配置一个HttpServer实例的例子:

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

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

负责实例的创建是 HttpServerBind, 配置信息在 HttpServerConfig#HttpServerChannelInitializer:

@Override
protected ChannelPipelineConfigurer defaultOnChannelInit() {return super.defaultOnChannelInit().then(new HttpServerChannelInitializer(this));}

对于 HTTP 协议这里有自己的 initializer 也就是 pipeline:

configureHttp11Pipeline(channel.pipeline(),accessLogEnabled,accessLog,compressPredicate(compressPredicate, minCompressionSize),cookieDecoder,cookieEncoder,decoder,formDecoderProvider,forwardedHeaderHandler,idleTimeout,observer,mapHandle,maxKeepAliveRequests,metricsRecorder,minCompressionSize,uriTagValue);

熟悉 Netty 框架的同学对这一块并不默认, 一个最乞丐版的 Netty 服务器可能只包含 request/respone decoder/encoder。

#预热

默认情况下,HttpServer初始化资源的操作在需要使用的时候才进行。这意味着初始化加载的时候bind operation会占用额外的时间:

  1. 事件循环组
  2. native传输库(当使用了native传输的时候)
  3. 用于安全性的native库(使用了OpenSsl的时候)

当您需要预加载这些资源的时候,您可以按照以下方式来配置HttpServer:

public static void main(String[] args) {HttpServer httpServer =HttpServer.create().handle((request, response) -> request.receive().then());httpServer.warmup() // <1>.block();DisposableServer server = httpServer.bindNow();server.onDispose().block();
}

<1> 初始化和加载事件循环组,native传输库和用于安全性的native库

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



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

相关文章

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引言

详解Java如何向http/https接口发出请求

《详解Java如何向http/https接口发出请求》这篇文章主要为大家详细介绍了Java如何实现向http/https接口发出请求,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 用Java发送web请求所用到的包都在java.net下,在具体使用时可以用如下代码,你可以把它封装成一

Spring MVC如何设置响应

《SpringMVC如何设置响应》本文介绍了如何在Spring框架中设置响应,并通过不同的注解返回静态页面、HTML片段和JSON数据,此外,还讲解了如何设置响应的状态码和Header... 目录1. 返回静态页面1.1 Spring 默认扫描路径1.2 @RestController2. 返回 html2

使用Python实现批量访问URL并解析XML响应功能

《使用Python实现批量访问URL并解析XML响应功能》在现代Web开发和数据抓取中,批量访问URL并解析响应内容是一个常见的需求,本文将详细介绍如何使用Python实现批量访问URL并解析XML响... 目录引言1. 背景与需求2. 工具方法实现2.1 单URL访问与解析代码实现代码说明2.2 示例调用

Node.js 中 http 模块的深度剖析与实战应用小结

《Node.js中http模块的深度剖析与实战应用小结》本文详细介绍了Node.js中的http模块,从创建HTTP服务器、处理请求与响应,到获取请求参数,每个环节都通过代码示例进行解析,旨在帮... 目录Node.js 中 http 模块的深度剖析与实战应用一、引言二、创建 HTTP 服务器:基石搭建(一

Python如何实现 HTTP echo 服务器

《Python如何实现HTTPecho服务器》本文介绍了如何使用Python实现一个简单的HTTPecho服务器,该服务器支持GET和POST请求,并返回JSON格式的响应,GET请求返回请求路... 一个用来做测试的简单的 HTTP echo 服务器。from http.server import HT

C#反射编程之GetConstructor()方法解读

《C#反射编程之GetConstructor()方法解读》C#中Type类的GetConstructor()方法用于获取指定类型的构造函数,该方法有多个重载版本,可以根据不同的参数获取不同特性的构造函... 目录C# GetConstructor()方法有4个重载以GetConstructor(Type[]

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码: 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口,https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor