rsocket javaダウンロード - rsocket javaソースコードのダウンロード

rsocket java

JAVAソースコード

1.1.4 Release

ダウンロード

Rソケット

RSocket は、TCP、WebSocket、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 ();