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

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

型パラメーター:
P - 送信 Messages のペイロードの型
すべてのスーパーインターフェース:
AutoCloseableSE, CloseableSE
すべての既知の実装クラス:
ReactorNetty2TcpConnection, ReactorNettyTcpConnection
public interface TcpConnection<P> extends CloseableSE
メッセージの送信と TCP 接続の管理に関する契約。
導入:
4.0
作成者:
Rossen Stoyanchev

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    close()
    接続を閉じる。
    void
    onReadInactivity(RunnableSE runnable, long duration)
    一定の読み取り非アクティブ期間の後に呼び出すタスクを登録します。
    void
    onWriteInactivity(RunnableSE runnable, long duration)
    一定期間の書き込み非アクティブ後に呼び出されるタスクを登録します。
    default ListenableFuture<VoidSE>
    send(Message<P> message)
    使用すべきではありません。
    6.0 現在、sendAsync(Message) を推奨
    CompletableFutureSE<VoidSE>
    sendAsync(Message<P> message)
    指定されたメッセージを送信します。

  • メソッドの詳細

    • send

      @DeprecatedSE(since="6.0") default ListenableFuture<VoidSE> send(Message<P> message)
      使用すべきではありません。
      6.0 現在、sendAsync(Message) を推奨
      指定されたメッセージを送信します。
      パラメーター:
      message - メッセージ
      戻り値:
      メッセージがいつ正常に送信されたかを判断するために使用できる ListenableFuture

    • sendAsync

      CompletableFutureSE<VoidSE> sendAsync(Message<P> message)
      指定されたメッセージを送信します。
      パラメーター:
      message - メッセージ
      戻り値:
      メッセージがいつ正常に送信されたかを判断するために使用できる CompletableFuture
      導入:
      6.0

    • onReadInactivity

      void onReadInactivity(RunnableSE runnable, long duration)
      一定の読み取り非アクティブ期間の後に呼び出すタスクを登録します。
      パラメーター:
      runnable - 呼び出すタスク
      duration - ミリ秒単位の非アクティブ時間

    • onWriteInactivity

      void onWriteInactivity(RunnableSE runnable, long duration)
      一定期間の書き込み非アクティブ後に呼び出されるタスクを登録します。
      パラメーター:
      runnable - 呼び出すタスク
      duration - ミリ秒単位の非アクティブ時間

    • close

      void close()
      接続を閉じる。
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close