rsocket java下載 - rsocket java原始碼下載

rsocket java

JAVA源碼

1.1.4 Release

下載

RSocket

RSocket 是一種二進位協議，用於位元組流傳輸，例如 TCP、WebSockets 和 Aeron。

它透過在單一連接上傳遞非同步訊息來啟用以下對稱互動模型：

請求/回應（1 流）
請求/流（許多的有限流）
即發即忘（無回應）
事件訂閱（無限流）

了解更多信息，請訪問 http://rsocket.io

建置和二進位文件

建置狀態

️ master分支現在致力於1.2.x系列的開發。

版本和里程碑可透過 Maven Central 取得。

例子：

repositories {
    mavenCentral()
    maven { url ' https://repo.spring.io/milestone ' }  // Reactor milestones (if needed)
}
dependencies {
    implementation ' io.rsocket:rsocket-core:1.2.0-SNAPSHOT '
    implementation ' io.rsocket:rsocket-transport-netty:1.2.0-SNAPSHOT '
}

快照可透過 oss.jfrog.org (OJO) 取得。

例子：

repositories {
    maven { url ' https://maven.pkg.github.com/rsocket/rsocket-java ' }
    maven { url ' https://repo.spring.io/snapshot ' }  // Reactor snapshots (if needed)
}
dependencies {
    implementation ' io.rsocket:rsocket-core:1.2.0-SNAPSHOT '
    implementation ' io.rsocket:rsocket-transport-netty:1.2.0-SNAPSHOT '
}

發展

從外掛程式首選項中在 Intellij 中安裝 google-java-format。在首選項 -> 其他設定 -> google-java-format 設定下啟用

自動格式化為

 $./gradlew goJF

偵錯

可以列印幀以幫助調試。將記錄器io.rsocket.FrameLogger設定為調試以列印幀。

要求

Java 8 - 嚴重依賴 Java 8 功能 API 和 java.time，也依賴 Reactor
Android O - https://github.com/rsocket/rsocket-demo-android-java8

普通客戶端

 package io . rsocket . transport . netty ;

import io . rsocket . Payload ;
import io . rsocket . RSocket ;
import io . rsocket . core . RSocketConnector ;
import io . rsocket . transport . netty . client . WebsocketClientTransport ;
import io . rsocket . util . DefaultPayload ;
import reactor . core . publisher . Flux ;

import java . net . URI ;

public class ExampleClient {
    public static void main ( String [] args ) {
        WebsocketClientTransport ws = WebsocketClientTransport . create ( URI . create ( "ws://rsocket-demo.herokuapp.com/ws" ));
        RSocket clientRSocket = RSocketConnector . connectWith ( ws ). block ();

        try {
            Flux < Payload > s = clientRSocket . requestStream ( DefaultPayload . create ( "peace" ));

            s . take ( 10 ). doOnNext ( p -> System . out . println ( p . getDataUtf8 ())). blockLast ();
        } finally {
            clientRSocket . dispose ();
        }
    }
}

零拷貝

預設情況下，為了使 RSocket 更易於使用，它會複製傳入的有效負載。複製有效負載會犧牲效能和延遲。如果您想使用零複製，則必須停用此功能。若要停用複製，您必須在RSocketFactory中包含payloadDecoder參數。這將允許您管理有效負載，而無需從底層傳輸複製資料。使用完有效負載後，必須釋放它們，否則會出現記憶體洩漏。正確使用這將減少延遲並提高效能。

伺服器設定範例

 RSocketServer . create ( new PingHandler ())
        // Enable Zero Copy
        . payloadDecoder ( PayloadDecoder . ZERO_COPY )
        . bind ( TcpServerTransport . create ( 7878 ))
        . block ()
        . onClose ()
        . block ();

客戶端設定範例

 RSocket clientRSocket =
        RSocketConnector . create ()
            // Enable Zero Copy
            . payloadDecoder ( PayloadDecoder . ZERO_COPY )
            . connect ( TcpClientTransport . create ( 7878 ))
            . block ();