クラス TcpConnectionSupport

java.lang.ObjectSE
org.springframework.integration.ip.tcp.connection.TcpConnectionSupport
実装されたすべてのインターフェース:
RunnableSETcpConnection
既知の直属サブクラス
TcpConnectionInterceptorSupportTcpNetConnectionTcpNioConnection

public abstract class TcpConnectionSupport extends ObjectSE implements TcpConnection
TcpConnections の基本クラス。TcpConnections は、クライアント接続ファクトリ(送信)またはサーバー接続ファクトリ(受信)によって確立されます。
導入:
2.0
作成者:
Gary Russell, Artem Bilan, Ngoc Nhan
  • フィールドの詳細

    • logger

      protected final Log logger
  • コンストラクターの詳細

    • TcpConnectionSupport

      public TcpConnectionSupport()
    • TcpConnectionSupport

      public TcpConnectionSupport(@Nullable ApplicationEventPublisher applicationEventPublisher)
    • TcpConnectionSupport

      public TcpConnectionSupport(SocketSE socket, boolean server, boolean lookupHost, @Nullable ApplicationEventPublisher applicationEventPublisher, @Nullable StringSE connectionFactoryName)
      イベント発行者が提供されている場合は、TcpConnectionSupport オブジェクトを作成し、TcpConnectionOpenEvent を発行します。
      パラメーター:
      socket - 基本となるソケット。
      server - この接続がサーバー接続の場合は true
      lookupHost - ホスト名の逆ルックアップを実行する必要がある場合は true、それ以外の場合は、識別のために IP アドレスが使用されます。
      applicationEventPublisher - オープン、クローズ、例外イベントが送信されるパブリッシャー。イベントの公開が不要な場合は null になることがあります。
      connectionFactoryName - この接続を作成する接続ファクトリの名前。イベントの発行中に使用され、null の場合があります。その場合、「不明」が使用されます。
  • メソッドの詳細

    • close

      public void close()
      この接続を閉じます。
      次で指定:
      インターフェース TcpConnectionclose 
    • closeConnection

      protected void closeConnection(boolean isException)
      インターセプトされている場合は、最も外側のインターセプターからクローズを伝搬します。それ以外の場合は、close() を呼び出します。
      パラメーター:
      isException - この呼び出しが例外の結果である場合は true。
    • getMapper

      public TcpMessageMapper getMapper()
      戻り値:
      マッパー
    • setMapper

      public void setMapper(TcpMessageMapper mapper)
      パラメーター:
      mapper - 設定するマッパー
    • getDeserializer

      public Deserializer<?> getDeserializer()
      次で指定:
      インターフェース TcpConnectiongetDeserializer 
      戻り値:
      デシリアライザー
    • setDeserializer

      public void setDeserializer(Deserializer<?> deserializer)
      パラメーター:
      deserializer - 設定するデシリアライザー
    • getSerializer

      public Serializer<?> getSerializer()
      次で指定:
      インターフェース TcpConnectiongetSerializer 
      戻り値:
      シリアライザー
    • setSerializer

      public void setSerializer(Serializer<?> serializer)
      パラメーター:
      serializer - 設定するシリアライザー
    • setNeedsTest

      public void setNeedsTest(boolean needsTest)
      最初の受信メッセージのみに一時リスナーを使用するには、true に設定します。
      パラメーター:
      needsTest - 一時リスナーの場合は true。
      導入:
      5.3
    • registerListener

      public void registerListener(@Nullable TcpListener listener)
      受信メッセージを受信するリスナーを設定します。
      パラメーター:
      listener - リスナー。
    • registerTestListener

      public void registerTestListener(TcpListener tListener)
      最初の受信メッセージのみを受信するように一時リスナーを設定します。クライアント接続ファクトリの connectionTest と組み合わせて使用します。
      パラメーター:
      tListener - テストリスナー。
      導入:
      5.3
    • enableManualListenerRegistration

      public void enableManualListenerRegistration()
      TcpListener の自動登録または手動登録を使用するかどうかを設定します。(デフォルトは自動)。手動登録が行われている場合、受信メッセージはリスナーが登録されるまで遅延されます。
      導入:
      1.4.5
    • registerSender

      public void registerSender(@Nullable TcpSender senderToRegister)
      送信者を登録します。送信者が応答を送信する接続を決定できるように、サーバー側の接続で使用されます。
      パラメーター:
      senderToRegister - 送り主。
    • registerSenders

      public void registerSenders(ListSE<TcpSender> sendersToRegister)
      送信者を登録します。送信者が応答を送信する接続を決定できるように、サーバー側の接続で使用されます。
      パラメーター:
      sendersToRegister - 送り主。
      導入:
      5.4
    • getListener

      @Nullable public TcpListener getListener()
      次で指定:
      インターフェース TcpConnectiongetListener 
      戻り値:
      リスナー
    • getSender

      @Nullable public TcpSender getSender()
      戻り値:
      存在する場合、最初の送信者。
    • getSenders

      public ListSE<TcpSender> getSenders()
      送信者のリストを返します。
      戻り値:
      送信者。
      導入:
      5.4
    • isServer

      public boolean isServer()
      次で指定:
      インターフェース TcpConnectionisServer 
      戻り値:
      接続が 1 回使用される場合は true。
    • incrementAndGetConnectionSequence

      public long incrementAndGetConnectionSequence()
      次で指定:
      インターフェース TcpConnectionincrementAndGetConnectionSequence 
      戻り値:
      このソケットで受信したメッセージの次のシーケンス番号
    • getHostAddress

      public StringSE getHostAddress()
      次で指定:
      インターフェース TcpConnectiongetHostAddress 
      戻り値:
      ホストアドレス
    • getHostName

      public StringSE getHostName()
      次で指定:
      インターフェース TcpConnectiongetHostName 
      戻り値:
      ホスト名
    • getConnectionId

      public StringSE getConnectionId()
      次で指定:
      インターフェース TcpConnectiongetConnectionId 
      戻り値:
      接続を一意に表す文字列。
    • getSocketInfo

      public SocketInfo getSocketInfo()
      インターフェースからコピーされた説明: TcpConnection
      SocketSE プロパティに getter を提供します。
      次で指定:
      インターフェース TcpConnectiongetSocketInfo 
      戻り値:
      socketInfo - たとえばインターセプターでは null になる場合があります。インターセプターはオーバーライドして実際の TcpConnection に委譲する必要があります。
      導入:
      4.2.5
    • setWrapped

      public void setWrapped(boolean wrapped)
      インターセプトされた場合は true に設定します。
      パラメーター:
      wrapped - ラップされている場合は true。
      導入:
      5.4.5
    • setWrapper

      public void setWrapper(TcpConnectionSupport wrapper)
      ラッパーを設定します。
      パラメーター:
      wrapper - ラッパー。
      導入:
      5.4.6
    • getConnectionFactoryName

      public StringSE getConnectionFactoryName()
    • isNoReadErrorOnClose

      protected boolean isNoReadErrorOnClose()
    • setNoReadErrorOnClose

      protected void setNoReadErrorOnClose(boolean noReadErrorOnClose)
    • sendExceptionToListener

      protected final void sendExceptionToListener(ExceptionSE e)
    • publishConnectionOpenEvent

      protected void publishConnectionOpenEvent()
    • publishConnectionCloseEvent

      protected void publishConnectionCloseEvent()
    • publishConnectionExceptionEvent

      protected void publishConnectionExceptionEvent(ThrowableSE t)
    • publishEvent

      public void publishEvent(TcpConnectionEvent event)
      インターセプターなどがイベント、おそらく TcpConnectionEvent のサブクラスを発行できるようにします。イベントソースはこの接続である必要があります。
      パラメーター:
      event - 公開するイベント。
    • toString

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