reactor netty

反应堆网络

Reactor Netty提供基于Netty框架的非阻塞和背压就绪的TCP / HTTP / UDP / QUIC客户端和服务器。

得到它

Reactor Netty需要 Java 8 或 + 才能运行。

使用 repo.spring.io 或Maven Central存储库中的Gradle （仅限稳定版本）：

    repositories {
      // maven { url 'https://repo.spring.io/snapshot' }
      maven { url ' https://repo.spring.io/milestone ' }
      mavenCentral()
    }

    dependencies {
      // compile "io.projectreactor.netty:reactor-netty-core:1.2.2-SNAPSHOT"
      compile " io.projectreactor.netty:reactor-netty-core:1.2.1 "
      // compile "io.projectreactor.netty:reactor-netty-http:1.2.2-SNAPSHOT"
      compile " io.projectreactor.netty:reactor-netty-http:1.2.1 "
    }

有关获取它的更多信息，请参阅参考文档（例如，使用Maven或如何获取里程碑和快照）。

入门

Reactor Netty新手？查看 Reactor Netty Workshop 和参考文档

这是一个非常简单的HTTP服务器和相应的HTTP客户端示例

 HttpServer . create ()   // Prepares an HTTP server ready for configuration
          . port ( 0 )    // Configures the port number as zero, this will let the system pick up
                      // an ephemeral port when binding the server
          . route ( routes ->
                      // The server will respond only on POST requests
                      // where the path starts with /test and then there is path parameter
                  routes . post ( "/test/{param}" , ( request , response ) ->
                          response . sendString ( request . receive ()
                                                     . asString ()
                                                     . map ( s -> s + ' ' + request . param ( "param" ) + '!' )
                                                     . log ( "http-server" ))))
          . bindNow (); // Starts the server in a blocking fashion, and waits for it to finish its initialization 

 HttpClient . create ()             // Prepares an HTTP client ready for configuration
          . port ( server . port ())  // Obtains the server's port and provides it as a port to which this
                                // client should connect
          . post ()               // Specifies that POST method will be used
          . uri ( "/test/World" )   // Specifies the path
          . send ( ByteBufFlux . fromString ( Flux . just ( "Hello" )))  // Sends the request body
          . responseContent ()    // Receives the response body
          . aggregate ()
          . asString ()
          . log ( "http-client" )
          . block ();

寻求帮助

使用Reactor Netty时遇到问题？我们很乐意提供帮助！

• 如果您要升级，请阅读发行说明以获取升级说明以及值得注意的新功能。
• 提出问题 - 我们监控 stackoverflow.com 上是否有带有reactor-netty标签的问题。您还可以在 Gitter 上与社区聊天。
• 在 github.com/reactor/reactor-netty/issues 报告Reactor Netty的错误。
• 有关支持和弃用政策的更多信息

报告问题

Reactor Netty使用GitHub's集成问题跟踪系统来记录错误和功能请求。如果您想提出问题，请遵循以下建议：

• 在记录错误之前，请搜索问题跟踪器以查看是否有人已经报告了该问题。
• 如果该问题尚不存在，请创建一个新问题。
• 请在问题报告中提供尽可能多的信息，我们想知道您正在使用的Reactor Netty版本，以及您的Operating System和JVM版本。
• 如果您想提出安全漏洞，请查看我们的安全政策以了解更多详细信息。

贡献

有关为Reactor Netty做出贡献的信息，请参阅我们的贡献指南。

从源头构建

您不需要从源代码构建来使用Reactor Netty （repo.spring.io 中的二进制文件），但如果您想尝试最新和最好的，可以使用 gradle 包装器轻松构建Reactor Netty 。您还需要 JDK 1.8。

$ git clone https://github.com/reactor/reactor-netty.git
$ cd reactor-netty
$ ./gradlew build

如果要将工件发布到本地Maven存储库，请使用：

$ ./gradlew publishToMavenLocal

Java文档

https://projectreactor.io/docs/netty/release/api/

指南

• https://projectreactor.io/docs/netty/release/reference/index.html
• https://violetagg.github.io/reactor-netty-workshop/

执照

Reactor Netty是在 Apache License 2.0 下发布的开源软件