# STOMP ゲートウェイ EMQX STOMP ゲートウェイは、[STOMP](https://stomp.github.io/stomp-specification-1.2.html) と MQTT プロトコル間の橋渡しを行うメッセージングプロトコルトランスレーターであり、これらのプロトコルを使用するクライアント同士の通信を可能にします。 この STOMP ゲートウェイは、クライアントとサーバーに対して軽量かつシンプルなメッセージングソリューションを提供し、多様なメッセージング環境でのメッセージ交換を実現します。TCP および SSL タイプのリスナーをサポートしており、柔軟で多用途なメッセージングシステム構築ツールです。 ::: tip STOMP ゲートウェイは [Stomp v1.2](https://stomp.github.io/stomp-specification-1.2.html) をベースにしており、STOMP v1.0 および v1.1 の仕様とも互換性があります。 ::: ## STOMP ゲートウェイの有効化 EMQX 5 では、STOMP ゲートウェイはダッシュボード、REST API、および設定ファイル `base.hocon` を通じて設定および有効化が可能です。本節ではダッシュボードを用いた設定手順を例に説明します。 EMQX ダッシュボードの左ナビゲーションメニューから **Management** -> **Gateways** をクリックします。**Gateways** ページにはサポートされているすべてのゲートウェイが一覧表示されます。**STOMP** を探し、**Actions** 列の **Setup** をクリックすると、**Initialize STOMP** ページに遷移します。 ::: tip EMQX をクラスターで運用している場合、ダッシュボードや REST API で行った設定はクラスター全体に影響します。特定のノードのみ設定を変更したい場合は、[`base.hocon`](../configuration/configuration.md) にて設定してください。 ::: 設定を簡略化するために、EMQX は **Gateways** ページのすべての必須フィールドにデフォルト値を用意しています。大幅なカスタマイズが不要な場合、STOMP ゲートウェイは以下の3ステップで有効化できます。 1. **Basic Configuration** タブで **Next** をクリックし、すべてのデフォルト設定を受け入れます。 2. 続いて表示される **Listeners** タブでは、EMQX がポート `61613` で UDP リスナーを事前設定しています。ここでも **Next** をクリックして設定を確定します。 3. 最後に **Enable** ボタンをクリックして STOMP ゲートウェイを有効化します。 ゲートウェイの有効化が完了すると、**Gateways** ページに戻り、STOMP ゲートウェイのステータスが **Enabled** と表示されていることを確認できます。 STOMP ゲートウェイが有効化された状態 EMQX 5.0 では、ダッシュボードを通じて Stomp ゲートウェイの設定および有効化が可能です。 上記の設定は REST API でも行えます。 **サンプルコード:** ```bash curl -X 'PUT' 'http://127.0.0.1:18083/api/v5/gateways/stomp' \ -u : \ -H 'Content-Type: application/json' \ -d '{ "name": "stomp", "enable": true, "mountpoint": "stomp/", "listeners": [ { "type": "tcp", "name": "default", "bind": "61613", "max_conn_rate": 1000, "max_connections": 1024000 } ] }' ``` ## STOMP クライアントとの連携 ### クライアントライブラリ STOMP ゲートウェイを構築した後は、STOMP クライアントツールを使って接続テストを行い、正常に動作しているか確認できます。例として [stomp.py](https://github.com/jasonrbriggs/stomp.py) があります。 ### パブリッシュ／サブスクライブ STOMP プロトコルは PUB/SUB メッセージングモデルと完全に互換性があり、STOMP ゲートウェイは以下のように動作します。 - STOMP プロトコルの `SEND` メッセージをメッセージのパブリッシュに使用します。`SEND` メッセージの `destination` フィールドがトピックを指定し、メッセージ内容は `SEND` メッセージのボディに含まれます。QoS（サービス品質）は固定で 0 です。 - STOMP プロトコルの `SUBSCRIBE` メッセージをサブスクライブ要求に使用します。`SUBSCRIBE` メッセージの `destination` フィールドがトピックを指定します。QoS は固定で 0 であり、MQTT プロトコルで定義されているワイルドカードもサポートします。 - STOMP プロトコルの `UNSUBSCRIBE` メッセージをサブスクライブ解除要求に使用します。`UNSUBSCRIBE` メッセージの `destination` フィールドがトピックを指定します。 ## STOMP ゲートウェイのカスタマイズ デフォルト設定に加え、EMQX はさまざまな設定オプションを提供し、特定のビジネス要件により適した構成を可能にしています。本節では **Gateways** ページで利用可能な各種フィールドについて詳しく解説します。 ### 基本設定 **Basic Configuration** タブでは、許容される最大ヘッダー数、ヘッダー長の最大値、統計情報の有効化設定、ゲートウェイの MountPoint 文字列設定が可能です。以下に各フィールドの詳細を示します。 1. **Max Header**: 許容される最大の STOMP ヘッダー数を設定します。デフォルトは `10` です。 2. **Max Each Header Length**: ヘッダー値の最大文字列長を設定します。デフォルトは `1024` です。 3. **Max Body Length**: STOMP パケットの最大バイト数を設定します。デフォルトは `65536` です。 4. **Idle Timeout**: 非アクティブ状態が続いた際に、STOMP フレームを待機する最大秒数を設定し、その時間を超えると接続を切断します。 5. **Enable Statistics**: ゲートウェイが統計情報を収集・報告するかどうかを設定します。デフォルトは `true` で、選択肢は `true` または `false` です。 6. **MountPoint**: パブリッシュおよびサブスクライブ時にすべてのトピックの前に付加される文字列を設定します。これにより異なるプロトコル間でのメッセージルーティングの分離を実現できます。例として *stomp/* などがあります。 **注意**: このトピックプレフィックスはゲートウェイが管理しており、クライアントはパブリッシュやサブスクライブ時に明示的にこのプレフィックスを付加する必要はありません。 ### リスナーの追加 ポート `61613` で名前が **default** の TCP リスナーが既に設定されており、最大 16 個のアクセプターをプールで管理し、最大 1,024,000 の同時接続をサポートしています。より詳細な設定を行う場合は **Settings** をクリックし、リスナーの削除は **Delete**、新規リスナーの追加は **+ Add Listener** をクリックしてください。 ::: tip STOMP ゲートウェイは TCP および SSL タイプのリスナーのみをサポートしています。 ::: **Add Listener** をクリックすると **Add Listener** ページが開き、以下の設定が可能です。 **基本設定** - **Name**: リスナーの一意識別子を設定します。 - **Type**: プロトコルタイプを選択します。STOMP では **tcp** または **ssl** が選択可能です。 - **Bind**: リスナーが接続を受け付けるポート番号を設定します。 - **MountPoint**（任意）: パブリッシュおよびサブスクライブ時にすべてのトピックの前に付加される文字列を設定し、異なるプロトコル間のメッセージルーティング分離を実現します。 **リスナー設定** - **Acceptor**: アクセプタープールのサイズを設定します。デフォルトは **16** です。 - **Max Connections**: リスナーが処理可能な最大同時接続数を設定します。デフォルトは **1024000** です。 - **Max Connection Rate**: リスナーが1秒あたりに受け入れ可能な新規接続の最大レートを設定します。デフォルトは **1000** です。 - **Proxy Protocol**: EMQX が [ロードバランサー](../deploy/cluster/lb.md) の背後に配置されている場合に、プロトコル V1/V2 を有効化します。 - **Proxy Protocol Timeout**: プロキシプロトコルパッケージを待機する最大秒数を設定し、その時間を超えると接続を切断します。デフォルトは **3s** です。 **TCP 設定** - **ActiveN**: ソケットの `{active, N}` オプションを設定します。これはソケットが能動的に処理可能な受信パケット数を意味します。詳細は [Erlang Documentation - setopts/2](https://erlang.org/doc/man/inet.html#setopts-2) を参照してください。 - **Buffer**: 受信および送信パケットを格納するバッファサイズを KB 単位で設定します。 - **TCP_NODELAY**: 接続に対して `TCP_NODELAY` フラグを有効化するかどうかを設定します。これはクライアントが前回のデータのアックを待たずに追加データを送信できるかを制御します。デフォルトは **false**、選択肢は **true** または **false** です。 - **SO_REUSEADDR**: ポート番号のローカル再利用を許可するかどうかを設定します。 - **Send Timeout**: 送信タイムアウト時に接続を切断するかどうかを設定します。デフォルトは **15s** です。 **SSL 設定**（SSL リスナーのみ） TLS 検証の有効化はトグルスイッチで設定可能ですが、その前に関連する **TLS Cert**、**TLS Key**、および **CA Cert** の情報をファイル内容を入力するか、**Select File** ボタンでアップロードして設定する必要があります。詳細は [SSL/TLS 接続の有効化](../network/emqx-mqtt-tls.md) を参照してください。 続いて以下の設定が可能です。 - **SSL Versions**: サポートする SSL バージョンを設定します。デフォルトは **tlsv1.3**、**tlsv1.2**、**tlsv1.1**、**tlsv1** です。 - **Fail If No Peer Cert**: クライアントが空の証明書を送信した場合に接続を拒否するかどうかを設定します。デフォルトは **false**、選択肢は **true** または **false** です。 - **Intermediate Certificate Depth**: ピア証明書に続く有効な認証パスに含まれる自己発行でない中間証明書の最大数を設定します。デフォルトは **10** です。 - **Key Password**: プライベートキーがパスワード保護されている場合に使用するユーザーパスワードを設定します。 ## 認証の設定 STOMP プロトコルの接続メッセージにはユーザー名とパスワードの概念が既に定義されているため、STOMP は以下のような多様な認証方式をサポートしています。 - [組み込みデータベース認証](../access-control/authn/mnesia.md) - [MySQL 認証](../access-control/authn/mysql.md) - [MongoDB 認証](../access-control/authn/mongodb.md) - [PostgreSQL 認証](../access-control/authn/postgresql.md) - [Redis 認証](../access-control/authn/redis.md) - [HTTP サーバー認証](../access-control/authn/http.md) - [JWT 認証](../access-control/authn/jwt.md) - [LDAP 認証](../access-control/authn/ldap.md) STOMP ゲートウェイは STOMP プロトコルの `CONNECT` または `STOMP` メッセージ内の情報を用いてクライアントの認証フィールドを生成します。 - クライアント ID: ランダムに生成される文字列 - ユーザー名: `CONNECT` または `STOMP` メッセージヘッダーの `login` フィールドの値 - パスワード: `CONNECT` または `STOMP` メッセージヘッダーの `passcode` フィールドの値 REST API を使って Stomp ゲートウェイ用の組み込みデータベース認証を作成することも可能です。 **サンプルコード:** ```bash curl -X 'POST' \ 'http://127.0.0.1:18083/api/v5/gateway/stomp/authentication' \ -u : \ -H 'accept: application/json' \ -H 'Content-Type: application/json' \ -d '{ "backend": "built_in_database", "mechanism": "password_based", "password_hash_algorithm": { "name": "sha256", "salt_position": "suffix" }, "user_id_type": "username" }' ``` ::: tip MQTT プロトコルとは異なり、**ゲートウェイは認証器のリスト（または認証チェーン）ではなく、単一の認証器の作成のみをサポートしています**。 認証器が有効化されていない場合、すべての STOMP クライアントはログインが許可されます。 :::