クラス TcpInboundGateway

実装されたすべてのインターフェース:
AwareBeanFactoryAwareBeanNameAwareDisposableBeanInitializingBeanApplicationContextAwareLifecyclePhasedSmartLifecycleComponentSourceAwareExpressionCapableOrderlyShutdownCapableIntegrationPatternClientModeCapableTcpListenerTcpSenderNamedComponentIntegrationInboundManagementIntegrationManagementManageableLifecycleManageableSmartLifecycleTrackableComponent

public class TcpInboundGateway extends MessagingGatewaySupport implements TcpListener, TcpSender, ClientModeCapable, OrderlyShutdownCapable
サーバー接続ファクトリを使用する受信ゲートウェイ - スレッドはファクトリによって制御されます。java.net 接続の場合、各ソケットは一度に 1 つのメッセージしか処理できません。java.nio 接続の場合、メッセージは多重化される可能性がありますが、クライアントは相関ロジックを提供する必要があります。クライアントが TcpOutboundGateway の場合、多重化は使用されませんが、接続ファクトリがシングルユース接続を使用する場合は、複数の同時接続を使用できます。真の非同期双方向通信には、受信 / 送信チャネルアダプターのペアを使用する必要があります。
導入:
2.0
作成者:
Gary Russell, Artem Bilan
  • フィールドの詳細

    • DEFAULT_RETRY_INTERVAL

      public static final long DEFAULT_RETRY_INTERVAL
      ミリ秒単位のデフォルトの再試行間隔 -60000L。
      関連事項:
  • コンストラクターの詳細

    • TcpInboundGateway

      public TcpInboundGateway()
  • メソッドの詳細

    • onMessage

      public boolean onMessage(Message<?> message)
      インターフェースからコピーされた説明: TcpListener
      新しいメッセージが到着したときに TCPConnection によって呼び出されます。
      次で指定:
      インターフェース TcpListeneronMessage 
      パラメーター:
      message - メッセージ。
      戻り値:
      メッセージがインターセプトされた場合は true
    • isListening

      public boolean isListening()
      戻り値:
      関連する接続ファクトリがリッスンしている場合は true。
    • setConnectionFactory

      public void setConnectionFactory(AbstractConnectionFactory connectionFactory)
      AbstractClientConnectionFactory または AbstractServerConnectionFactory である必要があります。
      パラメーター:
      connectionFactory - 接続ファクトリ
    • addNewConnection

      public void addNewConnection(TcpConnection connection)
      インターフェースからコピーされた説明: TcpSender
      TcpListener が所有するソケットを使用している場合、このメソッドは新しい接続が確立されるたびに呼び出されます。
      次で指定:
      インターフェース TcpSenderaddNewConnection 
      パラメーター:
      connection - 接続。
    • removeDeadConnection

      public void removeDeadConnection(TcpConnection connection)
      インターフェースからコピーされた説明: TcpSender
      TcpListener が所有するソケットを使用している場合、このメソッドは接続が閉じられるたびに呼び出されます。
      次で指定:
      インターフェース TcpSenderremoveDeadConnection 
      パラメーター:
      connection - 接続。
    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponentgetComponentType 
      オーバーライド:
      クラス MessagingGatewaySupportgetComponentType 
    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス MessagingGatewaySupportonInit 
    • doStart

      protected void doStart()
      クラスからコピーされた説明: AbstractEndpoint
      サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
      オーバーライド:
      クラス MessagingGatewaySupportdoStart 
    • doStop

      protected void doStop()
      クラスからコピーされた説明: AbstractEndpoint
      サブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
      オーバーライド:
      クラス MessagingGatewaySupportdoStop 
    • isClientMode

      public boolean isClientMode()
      次で指定:
      インターフェース ClientModeCapableisClientMode 
      戻り値:
      isClientMode
    • setClientMode

      public void setClientMode(boolean isClientMode)
      パラメーター:
      isClientMode - 設定する isClientMode
    • getRetryInterval

      public long getRetryInterval()
      戻り値:
      retryInterval
    • setRetryInterval

      public void setRetryInterval(long retryInterval)
      再試行間隔を構成します。デフォルトは DEFAULT_RETRY_INTERVAL です。
      パラメーター:
      retryInterval - 設定する retryInterval
    • isClientModeConnected

      public boolean isClientModeConnected()
      次で指定:
      インターフェース ClientModeCapableisClientModeConnected 
      戻り値:
      エンドポイントがクライアントモードで実行されている場合は true。
    • retryConnection

      public void retryConnection()
      インターフェースからコピーされた説明: ClientModeCapable
      すぐに接続の確立を試みてください。
      次で指定:
      インターフェース ClientModeCapableretryConnection 
    • beforeShutdown

      public int beforeShutdown()
      インターフェースからコピーされた説明: OrderlyShutdownCapable
      シャットダウンが始まる前に呼び出されます。実装は、新しいメッセージの受け入れを停止する必要があります。オプションで、処理中のアクティブなメッセージの数を返すことができます。
      次で指定:
      インターフェース OrderlyShutdownCapablebeforeShutdown 
      戻り値:
      使用可能な場合、アクティブなメッセージの数。
    • afterShutdown

      public int afterShutdown()
      インターフェースからコピーされた説明: OrderlyShutdownCapable
      スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。
      次で指定:
      インターフェース OrderlyShutdownCapableafterShutdown 
      戻り値:
      使用可能な場合、アクティブなメッセージの数。