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

インターフェース TcpOperations<P>

型パラメーター:
P - 受信および送信メッセージのペイロードの型
すべての既知の実装クラス:
ReactorNetty2TcpClient, ReactorNettyTcpClient
public interface TcpOperations<P>
TCP 接続を確立するための契約。
導入:
4.0
作成者:
Rossen Stoyanchev

  • メソッドの詳細

    • connect

      @DeprecatedSE(since="6.0") default ListenableFuture<VoidSE> connect(TcpConnectionHandler<P> connectionHandler)
      使用すべきではありません。
      6.0 現在、connectAsync(TcpConnectionHandler) を推奨
      新しい接続を開きます。
      パラメーター:
      connectionHandler - 接続を管理するためのハンドラー
      戻り値:
      接続が正常に確立されたかどうかを判断するために使用できる ListenableFuture

    • connectAsync

      CompletableFutureSE<VoidSE> connectAsync(TcpConnectionHandler<P> connectionHandler)
      新しい接続を開きます。
      パラメーター:
      connectionHandler - 接続を管理するためのハンドラー
      戻り値:
      接続が正常に確立されたかどうかを判断するために使用できる CompletableFuture
      導入:
      6.0

    • connect

      @DeprecatedSE(since="6.0") default ListenableFuture<VoidSE> connect(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy)
      使用すべきではありません。
      6.0 現在、connectAsync(TcpConnectionHandler, ReconnectStrategy) を推奨
      新しい接続を開き、接続が失敗した場合の再接続方法を示します。
      パラメーター:
      connectionHandler - 接続を管理するためのハンドラー
      reconnectStrategy - 再接続するための戦略
      戻り値:
      初期接続が正常に確立されたかどうかを判断するために使用できる ListenableFuture

    • connectAsync

      CompletableFutureSE<VoidSE> connectAsync(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy)
      新しい接続を開き、接続が失敗した場合の再接続方法を示します。
      パラメーター:
      connectionHandler - 接続を管理するためのハンドラー
      reconnectStrategy - 再接続するための戦略
      戻り値:
      初期接続が正常に確立されたかどうかを判断するために使用できる CompletableFuture
      導入:
      6.0

    • shutdown

      @DeprecatedSE(since="6.0") default ListenableFuture<VoidSE> shutdown()
      使用すべきではありません。
      6.0 現在、shutdownAsync() を推奨
      開いている接続をシャットダウンして閉じます。
      戻り値:
      接続が正常に閉じられたかどうかを判断するために使用できる ListenableFuture

    • shutdownAsync

      CompletableFutureSE<VoidSE> shutdownAsync()
      開いている接続をシャットダウンして閉じます。
      戻り値:
      接続が正常に閉じられたかどうかを判断するために使用できる CompletableFuture
      導入:
      6.0