クラス TcpNetConnection

java.lang.ObjectSE
org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
org.springframework.integration.ip.tcp.connection.TcpNetConnection
実装されているすべてのインターフェース:
RunnableSE、TcpConnection、SchedulingAwareRunnable
public class TcpNetConnection extends TcpConnectionSupport implements SchedulingAwareRunnable
SocketSE を使用および基礎とする TcpConnection。
導入:
2.0
作成者:
Gary Russell, Artem Bilan, Christian Tzolov, Ngoc Nhan

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

    • TcpNetConnection

      public TcpNetConnection(SocketSE socket, boolean server, boolean lookupHost, @Nullable ApplicationEventPublisher applicationEventPublisher, StringSE connectionFactoryName)
      ソケット用の TcpNetConnection を作成します。
      パラメーター:
      socket - ソケット
      server - true の場合、この接続は受信リクエストの結果として作成されました。
      lookupHost - ホスト名のルックアップを実行する必要がある場合は true、それ以外の場合は IP アドレスを使用して接続を識別します。
      applicationEventPublisher - OPEN、CLOSE、EXCEPTION イベントが送信される発行元。イベントの公開が不要な場合は null になることがあります。
      connectionFactoryName - この接続を作成する接続ファクトリの名前。イベントの発行中に使用され、null の場合があります。その場合、「不明」が使用されます。

  • メソッドの詳細

    • isLongLived

      public boolean isLongLived()
      次で指定:
      インターフェース SchedulingAwareRunnable の isLongLived 

    • close

      public void close()
      この接続を閉じます。
      次で指定:
      インターフェース TcpConnection の close 
      オーバーライド:
      クラス TcpConnectionSupport の close 

    • isOpen

      public boolean isOpen()
      次で指定:
      インターフェース TcpConnection の isOpen 
      戻り値:
      接続が開いている場合は true。

    • send

      public void send(Message<?> message)
      インターフェースからコピーされた説明: TcpConnection
      メッセージを変換して送信します。
      次で指定:
      インターフェース TcpConnection の send 
      パラメーター:
      message - メッセージ

    • getPayload

      public ObjectSE getPayload()
      インターフェースからコピーされた説明: TcpConnection
      デシリアライザーを使用して、接続の入力ストリームからメッセージペイロードを取得します。
      次で指定:
      インターフェース TcpConnection の getPayload 
      戻り値:
      ペイロード。

    • getPort

      public int getPort()
      次で指定:
      インターフェース TcpConnection の getPort 
      戻り値:
      港

    • getDeserializerStateKey

      @Nullable public ObjectSE getDeserializerStateKey()
      次で指定:
      インターフェース TcpConnection の getDeserializerStateKey 
      戻り値:
      この接続の状態を維持する Deserializer の状態を参照するために使用できるキー。現在、これは接続に関連付けられている InputStream ですが、オブジェクトは不透明として扱われ、キーとしてのみ使用される必要があります。

    • getSslSession

      @Nullable public SSLSessionSE getSslSession()
      次で指定:
      インターフェース TcpConnection の getSslSession 
      戻り値:
      SSL が使用されている場合、この接続に関連付けられている SSLSessionSE。そうでない場合は null

    • inputStream

      protected InputStreamSE inputStream() throws IOExceptionSE
      たとえば、入力ストリームをラップするために、サブクラスでこれをオーバーライドできます。
      戻り値:
      入力ストリーム。
      例外:
      IOExceptionSE - 例外が発生した場合。
      導入:
      5.0

    • run

      public void run()
      リスナーがない場合、このメソッドは終了します。リスナーが存在する場合、メソッドは接続のストリームから入力を読み取るループで実行され、データは Deserializer を使用してオブジェクトに変換され、リスナーの TcpListener.onMessage(Message) メソッドが呼び出されます。
      次で指定:
      インターフェース RunnableSE の run 

    • handleReadException

      protected boolean handleReadException(ExceptionSE exception)

    • shutdownInput

      public void shutdownInput() throws IOExceptionSE
      ソケットの入力ストリームをストリームの終わりに設定します。
      次で指定:
      インターフェース TcpConnection の shutdownInput 
      例外:
      IOExceptionSE - IO 例外。
      導入:
      5.2
      関連事項:

    • shutdownOutput

      public void shutdownOutput() throws IOExceptionSE
      ソケットの出力ストリームを無効にします。
      次で指定:
      インターフェース TcpConnection の shutdownOutput 
      例外:
      IOExceptionSE - IO 例外
      導入:
      5.2
      関連事項: