Dockerを使用してMQTTサーバーを構築するプロセスの詳細な説明

# コンテナに入ります。/bin/bash を使用して入ることはできません。docker exec -it emq /bin/sh

# 設定ファイルを編集する vi /opt/emqttd/etc/emq.conf
# allowAnonymous を True から false に変更
allow_anonymous = 偽

データベース emq 文字セット utf8 を作成します。

eqm を使用します。

テーブル mqtt_user を作成します ( 
id int(11) 符号なし NOT NULL AUTO_INCREMENT, 
ユーザー名 varchar(100) デフォルト NULL, 
パスワードvarchar(100) デフォルトNULL、 
ソルトvarchar(20) デフォルトNULL、 
is_superuser tinyint(1) デフォルト 0, 
作成日時 DEFAULT NULL、 
主キー (id)、 
ユニークキー mqtt_username (ユーザー名) 
)ENGINE=MyISAM デフォルト文字セット=utf8;

テーブル mqtt_acl を作成します ( 
id int(11) 符号なし NOT NULL AUTO_INCREMENT, 
allow int(1) デフォルト NULL コメント '0: 拒否、1: 許可'、 
ipaddr varchar(60) デフォルト NULL コメント 'IpAddress', 
ユーザー名 varchar(100) デフォルト NULL コメント 'ユーザー名', 
clientid varchar(100) デフォルト NULL コメント 'ClientId', 
アクセス int(2) NOT NULL COMMENT '1: subscribe、2: publish、3: pubsub'、 
topic varchar(100) NOT NULL DEFAULT '' COMMENT 'トピックフィルター', 
主キー (id) 
)ENGINE=InnoDB デフォルト文字セット=utf8;

`mqtt_acl` (`id`, `allow`, `ipaddr`, `username`, `clientid`, `access`, `topic`) の値を挿入します 
(1,1,NULL,'$すべて',NULL,2,'#'),
(2,0,NULL,'$all',NULL,1,'$SYS/#'),
(3,0,NULL,'$all',NULL,1,'等しい#'),
(5,1,'127.0.0.1',NULL,NULL,2,'$SYS/#'),
(6,1,'127.0.0.1',NULL,NULL,2,'#'),
(7,1,NULL,'ダッシュボード',NULL,1,'$SYS/#');

# スーパー管理者を設定できます (スーパー管理者は ACL ルールに関係なく、すべてのトピックをサブスクライブしてプッシュする権限を持ちます)
mqtt_user (`username`, `password`) に値 ('admin', '03ac674216f3e15c761ee1a5e255f067953623c8b388b4459e13f978d7c846f4') を挿入します。
mqtt_user を更新し、is_superuser=1 を設定します。ここで、id はスーパー管理者 ID です。

ps: auth.mysql.password_hash (デフォルトは sha256) に注意してください。sha256 の場合は、新しいユーザーを追加するときに暗号化された値を手動で渡す必要があります。プレーンの場合は、暗号化する必要がなく、プレーンテキストで保存されます。

vi /opt/emqttd/etc/plugins/emq_auth_mysql.conf
auth.mysql.server = yourmysql-IP:3306 
auth.mysql.ユーザー名 = ルート 
auth.mysql.パスワード = xxxxxxxx 
auth.mysql.データベース = emq

/opt/emqttd/bin/emqx 停止
/opt/emqttd/bin/emqx スタート
/opt/emqttd/bin/emqttd_ctl plugins load emq_auth_mysql #mysql認証プラグインを開く

-- すべてのユーザーがシステムトピックをサブスクライブすることはできません INSERT INTO mqtt_acl (allow, ipaddr, username, clientid, access, topic) VALUES (0, NULL, '$all', NULL, 1, '$SYS/#');

-- 10.59.1.100 上のクライアントがシステム トピックをサブスクライブできるようにします INSERT INTO mqtt_acl (allow, ipaddr, username, clientid, access, topic) VALUES (1, '10.59.1.100', NULL, NULL, 1, '$SYS/#');

-- クライアントが /smarthome/+/temperature トピックをサブスクライブすることを禁止します INSERT INTO mqtt_acl (allow, ipaddr, username, clientid, access, topic) VALUES (0, NULL, NULL, NULL, 1, '/smarthome/+/temperature');

-- クライアントが独自のクライアント ID を含む /smarthome/${clientid}/temperature トピックをサブスクライブできるようにします INSERT INTO mqtt_acl (allow, ipaddr, username, clientid, access, topic) VALUES (1, NULL, NULL, NULL, 1, '/smarthome/%c/temperature');