クラス PartitionedChannel

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.AbstractSubscribableChannel
org.springframework.integration.channel.AbstractExecutorChannel
org.springframework.integration.channel.PartitionedChannel
実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ExecutorChannelInterceptorAware, ComponentSourceAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, SubscribableChannelManagement, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel
public class PartitionedChannel extends AbstractExecutorChannel
パーティション化されたメッセージディスパッチのための AbstractExecutorChannel 実装。複数のパーティションが必要で、各パーティションは専用のスレッドによってサポートされます。partitionKeyFunction は、メッセージをどのパーティションにディスパッチするかを決定するために使用されます。デフォルトでは、IntegrationMessageHeaderAccessor.CORRELATION_ID メッセージヘッダーがパーティションキーとして使用されます。

実際のディスパッチおよびスレッド化ロジックは PartitionedDispatcher に実装されています。

デフォルトの ThreadFactorySE は、このチャネルの Bean 名に -partition-thread- を加えたものに基づいています。すべてのスレッド名は、それが属するパーティションを反映します。

ロジックの残りの部分は ExecutorChannel と似ており、次のものが含まれます。- サブスクライバのロードバランシング。- フェイルオーバーとエラー処理。- チャネル操作のインターセプト。

導入:
6.1
作成者:
Artem Bilan
関連事項:

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

    • PartitionedChannel

      public PartitionedChannel(int partitionCount)
      指定されたパーティション数に基づいてインスタンスを作成し、IntegrationMessageHeaderAccessor.CORRELATION_ID メッセージヘッダーからパーティションキーを解決します。
      パラメーター:
      partitionCount - このチャネルのパーティションの数。

    • PartitionedChannel

      public PartitionedChannel(int partitionCount, FunctionSE<Message<?>, ObjectSE> partitionKeyFunction)
      指定されたパーティション数と、メッセージに対するパーティションキーの機能に基づいてインスタンスを作成します。
      パラメーター:
      partitionCount - このチャネルのパーティションの数。
      partitionKeyFunction - このチャネルに送信されたメッセージに対してパーティションキーを解決する関数。

  • 方法の詳細

    • setThreadFactory

      public void setThreadFactory(ThreadFactorySE threadFactory)
      パーティションごとにエグゼキュータの ThreadFactorySE を設定します。PartitionedDispatcher まで伝播します。デフォルトは、このチャネルの Bean 名に -partition-thread- を加えた CustomizableThreadFactory になります。
      パラメーター:
      threadFactory - 使用する ThreadFactorySE。

    • setFailover

      public void setFailover(boolean failover)
      チャネルのディスパッチャーでフェイルオーバーを有効にするかどうかを指定します。デフォルトではそうなります。無効にするには、この値を "false" に設定します。
      パラメーター:
      failover - フェールオーバーブール値。

    • setFailoverStrategy

      public void setFailoverStrategy(PredicateSE<ExceptionSE> failoverStrategy)
      スローされた例外に対してチャネルのディスパッチャーがフェイルオーバーを有効にするかどうかの戦略を構成します。setFailover(boolean) オプションをオーバーライドします。つまり、このオプションまたはそのオプションを設定する必要があります。
      パラメーター:
      failoverStrategy - フェイルオーバー戦略述語。
      導入:
      6.3

    • setLoadBalancingStrategy

      public void setLoadBalancingStrategy(@Nullable LoadBalancingStrategy loadBalancingStrategy)
      PartitionedDispatcher には LoadBalancingStrategy を指定します。
      パラメーター:
      loadBalancingStrategy - 負荷分散戦略の実装。

    • setWorkerQueueSize

      public void setWorkerQueueSize(int workerQueueSize)
      パーティションエグゼキュータのワーカーにキューのサイズを指定します。デフォルトは 0 です。
      パラメーター:
      workerQueueSize - パーティションエグゼキュータの ワーカーキューのサイズ。
      導入:
      6.4.10

    • getDispatcher

      protected PartitionedDispatcher getDispatcher()
      次で指定:
      クラス AbstractSubscribableChannel の getDispatcher 

    • onInit

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

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean 内の destroy 
      次で指定:
      インターフェース IntegrationManagement 内の destroy 
      オーバーライド:
      クラス AbstractMessageChannel の destroy