JT/T 808 ゲートウェイ

EMQX 5.4 には、中国で広く使用されている車両端末通信プロトコルである JT/T 808 プロトコルが含まれています。これは車両と監視センター間のデータ通信に用いられます。EMQX の JT/T 808 ゲートウェイは、JT/T 808 クライアントからの接続を受け入れ、そのイベントやメッセージを MQTT パブリッシュメッセージに変換します。

現時点での実装には以下の制限があります：

• TCP 伝送に基づいています。
• JT/T 808 2011、2013、2019 のみサポートし、JT/T 808 2021 は未対応です。
• 端末の登録・登録解除メッセージを SMS 経由で送信できません。
• EMQX の組み込み認証システムは使用できず、端末登録／アクセス認証用の HTTP サービスアドレスの設定が必要です。

JT/T 808 ゲートウェイの有効化

JT/T 808 ゲートウェイは、ダッシュボード、REST API、または base.hocon 設定ファイルから有効化および設定できます。

ダッシュボードからゲートウェイを有効化する

このセクションでは、ダッシュボードから JT/T 808 ゲートウェイを有効化する方法を説明します。

EMQX ダッシュボードの左ナビゲーションバーで 管理 -> ゲートウェイ をクリックします。ゲートウェイ ページにはサポートされているすべてのゲートウェイが一覧表示されます。JT/T 808 を見つけて、操作 列の 設定 ボタンをクリックすると、JT/T 808 初期化 ページに移動します。

TIP

EMQX がクラスターで稼働している場合、ダッシュボードや REST API での設定はクラスター全体に反映されます。単一ノードのみを設定したい場合は、base.hocon でゲートウェイを設定してください。

設定を簡素化するために、EMQX は ゲートウェイ ページのすべての必須フィールドにデフォルト値を提供しています。カスタム設定が不要な場合は、以下の3ステップで JT/T 808 ゲートウェイを有効化できます：

1. 基本パラメーター ステップページで全てのデフォルト設定を受け入れ、次へ をクリックします。
2. 次に リスナー ステップページに移動し、EMQX はポート 6207 で TCP リスナーを事前設定しています。再度 次へ をクリックして設定を確認します。
3. 有効化 ボタンをクリックして JT/T 808 ゲートウェイを起動します。

ゲートウェイの有効化が完了すると、ゲートウェイ ページに戻り、JT/T 808 ゲートウェイの状態が 有効 になっていることを確認できます。

REST API または設定ファイルでゲートウェイを有効化する

JT/T 808 ゲートウェイは、REST API または設定ファイルからも有効化および設定できます：

curl -X 'PUT' 'http://127.0.0.1:18083/api/v5/gateways/jt808' \
  -u <your-application-key>:<your-security-key> \
  -H 'Content-Type: application/json' \
  -d '{
  "name": "jt808",
  "frame": {
    "max_length": 8192
  },
  "proto": {
    "auth": {
      "allow_anonymous": true
    },
    "up_topic":"jt808/${clientid}/${phone}/up",
    "dn_topic":"jt808/${clientid}/${phone}/dn"
  },
  "mountpoint": "jt808/${clientid}/",
  "retry_interval": "8s",
  "max_retry_times": 3,
  "message_queue_len": 10,
  "enable_stats": true,
  "idle_timeout": "30s",
  "listeners": [
    {
      "type":"tcp",
      "name":"default",
      "bind":"6207",
      "acceptors":16,
      "max_conn_rate":1000,
      "max_connections":1024000,
      "id":"jt808:tcp:default"
    }
  ]
  }'

gateway {
  jt808 {
    enable_stats = true
    frame {max_length = 8192}
    idle_timeout = 30s
    listeners {
      tcp {
        default {
          acceptors = 16
          bind = "6207"
          max_conn_rate = 1000
          max_connections = 1024000
        }
      }
    }
    max_retry_times = 3
    message_queue_len = 10
    mountpoint = "jt808/${clientid}/"
    proto {
      auth {allow_anonymous = true}
      dn_topic = "jt808/${clientid}/${phone}/dn"
      up_topic = "jt808/${clientid}/${phone}/up"
    }
    retry_interval = 8s
  }
}

TIP

EMQX がクラスターで稼働している場合、ダッシュボードや REST API での設定はクラスター全体に反映されます。単一ノードのみを設定したい場合は、base.hocon でゲートウェイを設定してください。

JT/T 808 ゲートウェイは TCP タイプのリスナーのみをサポートしています。設定可能なパラメーターの完全な一覧については、ゲートウェイ設定 - リスナー を参照してください。

JT/T 808 ゲートウェイのカスタマイズ

デフォルト設定に加え、EMQX はさまざまな設定オプションを提供し、特定のビジネス要件に合わせて調整できます。このセクションでは、ゲートウェイ ページで利用可能な設定オプションを詳しく説明します。

基本設定

ゲートウェイページで JT/T 808 を見つけ、操作 列の 設定 をクリックします。設定 ペインで JT/T 808 ゲートウェイをカスタマイズできます。

• MountPoint: パブリッシュやサブスクライブ時にすべてのトピックの前に付加される文字列を設定します。これにより異なるプロトコル間でのメッセージルーティングの分離を実現します。例：jt808/${clientid}/。このトピックプレフィックスはゲートウェイが管理し、クライアントはパブリッシュやサブスクライブ時に明示的に追加する必要はありません。
• Max Length of Frame: ゲートウェイが処理可能なフレームの最大サイズです。デフォルトは 8192 で、多様なデータパケットサイズに対応可能です。
• Parse Unknown Message IDs: 標準プロトコルに定義されていないメッセージIDを解析するかどうか。
  • true に設定すると、未知のメッセージIDを持つメッセージを処理し、ペイロードを Base64 エンコードして転送します。デフォルトは true。
  • false に設定すると、メッセージを無視するか、Ignore Unsupported Frames の設定に応じてクライアントを切断します。
• String Encoding: デバイスから報告される文字列の解析や、デバイスへの文字列のパッケージングおよび送信時に使用する文字エンコーディングを指定します。
  • utf8 に設定すると、UTF-8 エンコーディングで文字列を解析します。デフォルトは UTF-8。
  • gbk に設定すると、GBK エンコーディングで文字列を解析し、EMQX にパブリッシュする前に UTF-8 に変換します。
• Retry Interval: メッセージ配信失敗時の再試行間隔。デフォルトは 8s。
• Max Retry Times: メッセージ配信の最大再試行回数。超過すると配信できないメッセージは破棄されます。デフォルトは 3。
• Max message queue length: ダウンロードストリームメッセージ配信の最大メッセージキュー長。デフォルトは 100。
• Idle Timeout: クライアントの非アクティブ時間（秒）を設定し、その時間を超えると切断とみなします。デフォルトは 30 秒。
• Enable Statistics: ゲートウェイによる統計収集と報告を許可するかどうか。デフォルトは true。選択肢は true または false。
• Registry: JT/T 808 端末のレジストリセンター。allow_anonymous が false の場合に必須です。ゲートウェイが JT/T 808 登録メッセージを受信すると、このアドレスに HTTP リクエストとして登録情報を送信します。詳細は クライアント認証／認可の設定 を参照してください。
• Authentication URL: クライアント認証用の外部サービスの URL を指定します。
• Up Topic: ゲートウェイから EMQX へメッセージをパブリッシュする際の MQTT トピックパターンです。JT/T 808 クライアントからのメッセージがどのように MQTT トピックにマッピングされるかを定義します。デフォルトは jt808/${clientid}/${phone}/up。
• Down Topic: ブローカーからゲートウェイ経由で JT/T 808 クライアントに送信されるメッセージの MQTT トピックパターンです。MQTT ブローカーから JT/T 808 クライアントへのメッセージルーティングを定義します。デフォルトは jt808/${clientid}/${phone}/dn。
• Ignore Unsupported Frames: 標準プロトコルに準拠しない JT/T 808 フレームの処理方法を決定します。
  • true に設定すると、非対応フレームはログに記録されますが、他の有効なメッセージの処理は継続され、カスタムまたは非標準メッセージによる切断を防ぎます。デフォルトは true。
  • false に設定すると、非対応フレーム受信時にクライアントを切断します。
• Allow Anonymous: クライアントが認証なしで接続できるかどうかを決定します。true に設定すると、認証情報なしで接続可能です。

リスナーの追加

デフォルトで、ポート 6207 に名前が default の TCP リスナーがすでに設定されており、1秒あたり最大1,000接続、最大1,024,000の同時接続をサポートしています。より詳細な設定を行うには、リスナー タブをクリックし、編集、削除、または新規リスナーの追加が可能です。

+ リスナー追加 をクリックすると リスナー追加 ページが開き、以下の設定項目を入力できます：

基本設定

• 名前: リスナーの一意識別子を設定します。
• タイプ: プロトコルタイプを選択します。MQTT-SN の場合は udp または dtls が選択可能です。
• バインド: リスナーが接続を受け入れるポート番号を設定します。
• MountPoint（任意）: パブリッシュやサブスクライブ時にすべてのトピックの前に付加される文字列を設定し、異なるプロトコル間でのメッセージルーティング分離を実現します。

リスナー設定

• アセプター数: アセプタープールのサイズを設定します。デフォルトは 16。
• 最大接続数: リスナーが処理可能な同時接続数の最大値を設定します。デフォルトは 1024000。
• 最大接続レート: リスナーが1秒あたり受け入れ可能な新規接続の最大レートを設定します。デフォルトは 1000。
• プロキシプロトコル: EMQX クラスターが HAProxy や NGINX の背後にある場合に Proxy Protocol V1/V2 を有効化します。デフォルトは false。
• プロキシプロトコルタイムアウト: プロキシプロトコルのタイムアウト時間。タイムアウト内にプロキシプロトコルパケットが受信されない場合、EMQX は TCP 接続を切断します。デフォルトは 3 秒。

TCP 設定

• ActiveN: ソケットの {active, N} オプションを設定します。これはソケットが能動的に処理可能な受信パケット数です。詳細は Erlang ドキュメント - setopts/2 を参照してください。
• バッファ: 受信および送信パケットを格納するバッファサイズを KB 単位で設定します。
• TCP_NODELAY: 接続に対して TCP_NODELAY フラグを設定します。デフォルトは false。
• SO_REUSEADDR: ポート番号のローカル再利用を許可するかどうかを設定します。デフォルトは true。
• 送信タイムアウト: 接続の TCP 送信タイムアウト時間を設定します。デフォルトは 15 秒。
• 送信タイムアウト時切断: 送信タイムアウト時に接続を切断するかどうか。デフォルトは true。

クライアント認証／認可の設定

JT/T 808 プロトコル仕様における独自の登録／認証ロジックのため、JT/T 808 ゲートウェイは特定の登録サービス HTTP サービスに対して登録／認証を要求する方式のみをサポートしています。

TIP

ここでの「認証」は、JT/T 808 プロトコルで定義される認証を指し、MQTT の Pub/Sub アクセス制御とは異なります。

gateway.jt808.proto.auth.allow_anonymous = true を設定すると匿名認証が有効になり、クライアントの登録／認証ロジックをスキップできます。

登録／認証リクエストの詳細フォーマットは以下の通りです：

登録リクエスト

URL: http://127.0.0.1:8991/jt808/registry
Method: POST
Body:
   { "province": 58,
     "city": 59,
     "manufacturer": "Infinity",
     "model": "Q2",
     "license_number": "ZA334455",
     "dev_id": "xx11344",
     "color": 3,
     "phone", "00123456789"
   }

登録レスポンス：

{
  "code": 0,
  "authcode": "132456789"
}

{
  "code": 1
}

返却コードの意味：

0: 成功
1: 車両はすでに登録済み
2: データベースに該当車両なし
3: 端末はすでに登録済み
4: データベースに該当端末なし

認証リクエスト

URL: http://127.0.0.1:8991/jt808/auth
Method: POST
Body:
   { "code": "authcode",
     "phone", "00123456789"
   }

認証レスポンス：

HTTP ステータスコード 200: 認証成功
その他: 認証失敗

注：認証リクエストは、システムが認証コードを保存していない場合（端末が直接認証メッセージを送信してシステムにログインする場合）にのみ呼び出されます。

データ交換フォーマット

詳細は JT/T 808 ゲートウェイ データ交換フォーマット を参照してください。

ユーザーレイヤーインターフェース

• 詳細な設定手順は、ゲートウェイ設定 - JT/T 808 ゲートウェイ を参照してください。
• 詳細な REST API インターフェースは、REST API - ゲートウェイ を参照してください。