パッケージ org.springframework.messaging.tcp.reactor

クラス ReactorNettyTcpClient<P>

java.lang.ObjectSE
org.springframework.messaging.tcp.reactor.ReactorNettyTcpClient<P>
型パラメーター:
P - 送受信メッセージのペイロードの型
実装されたすべてのインターフェース:
TcpOperations<P>
public class ReactorNettyTcpClient<P> extends ObjectSE implements TcpOperations<P>
Reactor Netty ベースの TcpOperations の実装。
導入:
5.0
作成者:
Rossen Stoyanchev, Stephane Maldini

  • コンストラクターの詳細

    • ReactorNettyTcpClient

      public ReactorNettyTcpClient(StringSE host, int port, ReactorNettyCodec<P> codec)
      接続に使用するホストとポートを持つ単純なコンストラクター。

      このコンストラクターは、TcpClient および ConnectionProvider、LoopResources、ChannelGroup などの基盤となるリソースのライフサイクルを管理します。

      TcpClient の初期化とライフサイクルを完全に制御するには、ReactorNettyTcpClient(TcpClient, ReactorNettyCodec) を使用します。

      パラメーター:
      host - 接続するホスト
      port - 接続するポート
      codec - 入力 / 出力バイトストリームをエンコードおよびデコードするため
      関連事項:

    • ReactorNettyTcpClient

      public ReactorNettyTcpClient(FunctionSE<reactor.netty.tcp.TcpClient,reactor.netty.tcp.TcpClient> clientConfigurer, ReactorNettyCodec<P> codec)
      TcpClient と基礎となるリソースのライフサイクルを引き続き管理するが、Function<TcpClient, TcpClient> を介してクライアントの他のプロパティを直接構成できる ReactorNettyTcpClient(String, int, ReactorNettyCodec) のバリアント。
      パラメーター:
      clientConfigurer - コンフィギュレーター機能
      codec - 入力 / 出力バイトストリームをエンコードおよびデコードするため
      導入:
      5.1.3
      関連事項:

    • ReactorNettyTcpClient

      public ReactorNettyTcpClient(reactor.netty.tcp.TcpClient tcpClient, ReactorNettyCodec<P> codec)
      ライフサイクルが外部で管理されることが期待される、外部で作成された TcpClient インスタンスを持つコンストラクター。
      パラメーター:
      tcpClient - 使用する TcpClient インスタンス
      codec - 入力 / 出力バイトストリームをエンコードおよびデコードするため
      関連事項:

  • メソッドの詳細

    • setLogger

      public void setLogger(Log logger)
      クラス名に基づいたロガーよりも使用する代替ロガーを設定します。
      パラメーター:
      logger - 使用するロガー
      導入:
      5.1

    • getLogger

      public Log getLogger()
      現在設定されているロガーを返します。
      導入:
      5.1

    • connectAsync

      public CompletableFutureSE<VoidSE> connectAsync(TcpConnectionHandler<P> handler)
      インターフェースからコピーされた説明: TcpOperations
      新しい接続を開きます。
      次で指定:
      インターフェース TcpOperations<P> の connectAsync 
      パラメーター:
      handler - 接続を管理するためのハンドラー
      戻り値:
      接続が正常に確立されたかどうかを判断するために使用できる CompletableFuture

    • extendTcpClient

      protected reactor.netty.tcp.TcpClient extendTcpClient(reactor.netty.tcp.TcpClient tcpClient, TcpConnectionHandler<P> handler)
      特定の TcpConnectionHandler の TcpClient を初期化する機会を提供します。これにより、さらに情報を公開する StompTcpConnectionHandler などのサブインターフェースが実装される場合があります。
      パラメーター:
      tcpClient - 候補 TcpClient
      handler - TCP 接続のハンドラー
      戻り値:
      同じハンドラーまたは更新されたインスタンス

    • connectAsync

      public CompletableFutureSE<VoidSE> connectAsync(TcpConnectionHandler<P> handler, ReconnectStrategy strategy)
      インターフェースからコピーされた説明: TcpOperations
      新しい接続を開き、接続が失敗した場合の再接続方法を示します。
      次で指定:
      インターフェース TcpOperations<P> の connectAsync 
      パラメーター:
      handler - 接続を管理するためのハンドラー
      strategy - 再接続するための戦略
      戻り値:
      初期接続が正常に確立されたかどうかを判断するために使用できる CompletableFuture

    • shutdownAsync

      public CompletableFutureSE<VoidSE> shutdownAsync()
      インターフェースからコピーされた説明: TcpOperations
      開いている接続をシャットダウンして閉じます。
      次で指定:
      インターフェース TcpOperations<P> の shutdownAsync 
      戻り値:
      接続が正常に閉じられたかどうかを判断するために使用できる CompletableFuture

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString