zookeeper配置管理實現原理----監聽事件watch
阿新 • • 發佈：2020-11-28
1. 拉取映象
docker pull registry.cn-hangzhou.aliyuncs.com/synbop/emqttd:2.3.6
- 1
2. 執行映象
- –name 名字
- -p 18083 伺服器啟動埠
- -p 1882 TCP埠
- -p 8083 WS埠
- -p 8084 WSS埠
- -p 8883 SSL埠
- -d 指定容器
docker run --name emq -p 18083:18083 -p 1883:1883 -p 8084:8084 -p 8883:8883 -p 8083:8083 -d registry.cn-hangzhou.aliyuncs.com/synbop/emqttd:2.3.6
- 1
3. 進入emq服務頁面
在瀏覽器輸入機器IP:18083就可以進入emqtt頁面
初始的賬戶 admin, 密碼 public
4. 配置emq(對於V3.1.0)
為emq的使用者配置許可權 , emq還支援多種資料庫驗證, 包括 mongo, redis, pgsql 等等, 有興趣可以自行研究
# 進入容器, 不能用 /bin/bash 進入
docker exec -it emq /bin/sh
- 1
- 2
- 1.首先先關閉匿名認證(預設是開啟的誰都能夠登入)
# 編輯配置檔案
vi /opt/emqttd/etc/emq.conf
# 更改允許匿名 True -> false
allow_anonymous = false
- 1
- 2
- 3
- 4
- 2.建立使用者和許可權的 mysql 表, 可以拉一個 mysql 容器, 也可以直接在你的 ubuntu 裡的 mysql 中建立
CREATE DATABASE emq charset utf8;
use eqm;
CREATE TABLE mqtt_user (
id int(11) unsigned NOT NULL AUTO_INCREMENT,
username varchar(100) DEFAULT NULL,
password varchar(100) DEFAULT NULL,
salt varchar(20) DEFAULT NULL,
is_superuser tinyint(1) DEFAULT 0,
created datetime DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY mqtt_username (username)
) ENGINE=MyISAM DEFAULT CHARSET=utf8;
CREATE TABLE mqtt_acl (
id int(11) unsigned NOT NULL AUTO_INCREMENT,
allow int(1) DEFAULT NULL COMMENT '0: deny, 1: allow',
ipaddr varchar(60) DEFAULT NULL COMMENT 'IpAddress',
username varchar(100) DEFAULT NULL COMMENT 'Username',
clientid varchar(100) DEFAULT NULL COMMENT 'ClientId',
access int(2) NOT NULL COMMENT '1: subscribe, 2: publish, 3: pubsub',
topic varchar(100) NOT NULL DEFAULT '' COMMENT 'Topic Filter',
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 3.插入ACL規則 -ACL規則
tips: !!! 不要直接按照下面的例子設定, 先檢視ACL規則瞭解之後在根據自己情況進行配置
INSERT INTO `mqtt_acl` (`id`, `allow`, `ipaddr`, `username`, `clientid`, `access`, `topic`) VALUES
(1,1,NULL,'$all',NULL,2,'#'),
(2,0,NULL,'$all',NULL,1,'$SYS/#'),
(3,0,NULL,'$all',NULL,1,'eq #'),
(5,1,'127.0.0.1',NULL,NULL,2,'$SYS/#'),
(6,1,'127.0.0.1',NULL,NULL,2,'#'),
(7,1,NULL,'dashboard',NULL,1,'$SYS/#');
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 4.插入使用者, 由此開始訂閱與釋出的 Client 都必須通過使用者驗證（sha256值請自行轉換）
# 可以配置超級管理員(超級管理員會無視ACL規則對所有的topic都有訂閱和推送的許可權)
insert into mqtt_user (`username`, `password`) values ('admin', '03ac674216f3e15c761ee1a5e255f067953623c8b388b4459e13f978d7c846f4');
update mqtt_user set is_superuser=1 where id= 超級管理員ID ;
ps:注意 auth.mysql.password_hash(預設為sha256) 為sha256的話，新增使用者時需要手動傳遞加密後的值，plain的話則無需加密，明碼存放
- 1
- 2
- 3
- 4
- 5
- 5.修改emq的mysql配置檔案
vi /opt/emqttd/etc/plugins/emq_auth_mysql.conf
auth.mysql.server = 你的mysql-IP:3306
auth.mysql.username = root
auth.mysql.password = xxxxxxxx
auth.mysql.database = emq
- 1
- 2
- 3
- 4
- 5
- 6.重啟emq
/opt/emqttd/bin/ emqx stop
/opt/emqttd/bin/ emqx start
/opt/emqttd/bin/emqttd_ctl plugins load emq_auth_mysql #開啟mysql認證外掛
- 1
- 2
- 3
ACL規則
規則表字段說明：
- allow：禁止（0），允許（1）
- ipaddr：設定 IP 地址
- username：連線客戶端的使用者名稱，此處的值如果設定為 $all 表示該規則適用於所有的使用者
- clientid：連線客戶端的 Client ID
- access：允許的操作：訂閱（1），釋出（2），訂閱釋出都可以（3）
- topic：控制的主題，可以使用萬用字元，並且可以在主題中加入佔位符來匹配客戶端資訊，例如
t/%c則在匹配時主題將會替換為當前客戶端的 Client ID
%u：使用者名稱
%c：Client ID
示例
-- 所有使用者不可以訂閱系統主題
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');
-- 允許客戶端訂閱包含自身 Client ID 的 /smarthome/${clientid}/temperature 主題
INSERT INTO mqtt_acl (allow, ipaddr, username, clientid, access, topic) VALUES (1, NULL, NULL, NULL, 1, '/smarthome/%c/temperature');