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 下發布的開源軟體