排他サブスクリプション

排他サブスクリプションは、EMQXがサポートする拡張されたMQTT機能です。これはトピックに対して相互排他的なサブスクリプションを可能にします。つまり、同時に1つのサブスクライバーのみがトピックをサブスクライブでき、現在のサブスクライバーがサブスクリプションを解除するまで、他のサブスクライバーは該当トピックをサブスクライブできません。

サブスクリプションを排他にするには、トピック名の先頭にプレフィックスを追加する必要があります。以下の表は例を示しています。

例	プレフィックス	実際のトピック名
$exclusive/t/1	$exclusive/	t/1

クライアントAが$exclusive/t/1をサブスクライブすると、Aが$exclusive/t/1のサブスクリプションをキャンセルするまで、他のクライアントは$exclusive/t/1をサブスクライブできません。

TIP

排他サブスクリプションは必ず$exclusive/で始まる必要があります。上記の例では、他のクライアントはt/1を通じて通常通りサブスクライブ可能です。

設定ファイルで排他サブスクリプションを有効化する

排他サブスクリプションはデフォルトで無効です。設定ファイルで以下のように有効化できます。

mqtt.exclusive_subscription.enable = true

MQTTX Desktopで排他サブスクリプションを試す

前提条件

• MQTTX Desktopを使った基本的なパブリッシュおよびサブスクライブ操作ができること
• 排他サブスクリプションが有効化されていること

1. EMQXとMQTTX Desktopを起動します。New Connectionをクリックして、パブリッシャーとしてクライアント接続を作成します。

   • Name欄にDemoと入力します。
   • Host欄にローカルホストの127.0.0.1を入力します（このデモの例として使用）。
   • その他の設定はデフォルトのままにしてConnectをクリックします。

   TIP

   MQTT接続の作成方法については、MQTTX Desktopで詳しく説明しています。

   

2. さらに2つのMQTT接続を作成し、それぞれSubscriber1とSubscriber2と名付けます。

3. ConnectionsペインでSubscriber1を選択し、New Subscriptionボタンをクリックしてサブスクリプションを作成します。Topicテキストボックスに$exclusive/t/1と入力し、このトピックをサブスクライブします。Confirmをクリックします。

   

4. ConnectionsペインでSubscriber2を選択し、同様にNew Subscriptionボタンをクリックしてサブスクリプションを作成します。Topicテキストボックスに$exclusive/t/1と入力し、サブスクライブを試みます。Confirmをクリックします。

   • エラーメッセージが表示されます。
   

MQTTX CLIで排他サブスクリプションを試す

前提条件

• MQTTX CLIを使った基本的なパブリッシュおよびサブスクライブ操作ができること
• 排他サブスクリプションが有効化されていること

1. 以下のコマンドで排他サブスクリプションを行います。

   mqttx sub -t "$exclusive/t/1"

2. ステップ1のコマンドを再度実行して、トピック$exclusive/t/1への別のサブスクリプションを試みます。以下のように返されます。

   subscription negated to t/2 with code 135

   排他サブスクリプションのエラーコード一覧：

   コード	理由
   0x8F	排他サブスクリプションが有効でない状態で$exclusive/を使用した。
   0x97	すでに別のクライアントがこのトピックをサブスクライブしている。