クラス UnicastReceivingChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.ip.AbstractInternetProtocolReceivingChannelAdapter
org.springframework.integration.ip.udp.UnicastReceivingChannelAdapter
実装されたすべてのインターフェース:
RunnableSE、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、Phased、SmartLifecycle、ComponentSourceAware、ExpressionCapable、MessageProducer、IntegrationPattern、CommonSocketOptions、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent、SchedulingAwareRunnable
既知の直属サブクラス
MulticastReceivingChannelAdapter
public class UnicastReceivingChannelAdapter extends AbstractInternetProtocolReceivingChannelAdapter
受信 UDP パケットを受信するチャネルアダプター。オプションで、すべてのデータが受信されたことを検証するために使用される 4 バイト長のフィールドをパケットの前に付けることができます。パケットには、確認応答を送信する必要があることを示す情報も含まれる場合があります。
導入:
2.0
作成者:
Gary Russell, Artem Bilan, Christian Tzolov

  • フィールドの詳細

    • lock

      protected final LockSE lock

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

    • UnicastReceivingChannelAdapter

      public UnicastReceivingChannelAdapter(int port)
      指定されたポートでリッスンする UnicastReceivingChannelAdapter を構築します。
      パラメーター:
      port - ポート。

    • UnicastReceivingChannelAdapter

      public UnicastReceivingChannelAdapter(int port, boolean lengthCheck)
      指定されたポートでパケットをリッスンする UnicastReceivingChannelAdapter を構築します。受信パケットの前に長さが期待される lengthCheck オプションの設定を有効にします。
      パラメーター:
      port - ポート。
      lengthCheck - true の場合、lengthCheck オプションが有効になります。

  • メソッドの詳細

    • setLengthCheck

      public void setLengthCheck(boolean lengthCheck)
      パラメーター:
      lengthCheck - true の場合、受信パケットには 4 バイトのバイナリ長ヘッダーが含まれることが期待されます。
      導入:
      5.0

    • setSocketCustomizer

      public void setSocketCustomizer(SocketCustomizer socketCustomizer)
      作成後にソケットをさらに構成するようにカスタマイザーを設定します。
      パラメーター:
      socketCustomizer - カスタマイザー。
      導入:
      5.3.3

    • isLongLived

      public boolean isLongLived()

    • getPort

      public int getPort()
      オーバーライド:
      クラス AbstractInternetProtocolReceivingChannelAdapter の getPort 
      戻り値:
      このレシーバーがリッスンしているポート。

    • onInit

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

    • run

      public void run()

    • sendAck

      protected void sendAck(Message<byte[]> message)

    • asyncSendMessage

      protected boolean asyncSendMessage(DatagramPacketSE packet)

    • doSend

      protected void doSend(DatagramPacketSE packet)

    • receive

      protected DatagramPacketSE receive() throws IOExceptionSE
      例外:
      IOExceptionSE

    • setSocket

      public void setSocket(DatagramSocketSE socket)
      パラメーター:
      socket - 設定するソケット

    • getTheSocket

      @Nullable protected DatagramSocketSE getTheSocket()

    • getSocket

      public DatagramSocketSE getSocket()

    • setSocketAttributes

      protected void setSocketAttributes(DatagramSocketSE socket) throws SocketExceptionSE
      タイムアウトと受信バッファサイズを設定します。ソケットカスタマイザを呼び出します。
      パラメーター:
      socket - ソケット。
      例外:
      SocketExceptionSE - ソケット例外。

    • doStop

      protected void doStop()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
      オーバーライド:
      クラス AbstractInternetProtocolReceivingChannelAdapter の doStop 

    • setSoSendBufferSize

      public void setSoSendBufferSize(int soSendBufferSize)
      パラメーター:
      soSendBufferSize - 送信バッファサイズ。
      関連事項:

    • setLookupHost

      public void setLookupHost(boolean lookupHost)

    • getComponentType

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