サブスクライバのスケーリング

異なるノードで実行されるサブスクライバを追加または削除するには、次の追加ビルダーAPIを使用してNoSQLSubscriptionConfigを作成する必要があります。

/* step 3: create a subscription configuration */
  final NoSQLSubscriptionConfig subscriptionConfig =
    // Scalable subscriber should set Subscriber Id
    // with 2 as total number of subscribers and
    // 0 as its own SubscriberId within the group of 2 subscribers

    new NoSQLSubscriptionConfig.Builder(CKPT_TABLE_NAME)
    .setSubscribedTables("usertable")
    .setSubscriberId(new NoSQLSubscriberId(2,0))
    .setStreamMode(streamMode)
    .build();

APIのsetSubscriberId()では、1つの引数NoSQLSubscriberIDを使用します。NoSQLSubscriberIdは、サブスクライバの合計数とサブスクライバ索引の両方を含むオブジェクトです。したがって、NoSQLubscriberIdオブジェクトを構築するには、次の2つの引数が必要です。

• サブスクライバの数

  異なるノードで実行されるサブスクライバの合計数。たとえば、前述のコード例では、NoSQLSubscriberIdが作成した.setSubscriberId(new NoSQLSubscriberId(2,0))には、合計で2つのサブスクライバがあります。

• サブスクライバ索引

  サブスクライバの合計数の中における現在のサブスクライバの数値索引。数値索引は0から始まります。たとえば、2つのサブスクライバ・クライアントは0および1として識別できます。