{"id":403,"date":"2018-03-14T15:20:01","date_gmt":"2018-03-14T07:20:01","guid":{"rendered":"http:\/\/www.max-shu.com\/blog\/?p=403"},"modified":"2018-03-14T15:20:01","modified_gmt":"2018-03-14T07:20:01","slug":"emq%ef%bc%88emqttd%ef%bc%89-2-x-%e5%ae%89%e8%a3%85%e5%92%8c%e4%bd%bf%e7%94%a8%ef%bc%88%e7%89%a9%e8%81%94%e7%bd%91%e4%bc%a0%e8%be%93%e6%8e%a7%e5%88%b6%e5%8d%8f%e8%ae%ae%e7%9a%84broker%ef%bc%89","status":"publish","type":"post","link":"http:\/\/www.max-shu.com\/blog\/?p=403","title":{"rendered":"EMQ\uff08emqttd\uff09 2.x \u5b89\u88c5\u548c\u4f7f\u7528\uff08\u7269\u8054\u7f51\u4f20\u8f93\u63a7\u5236\u534f\u8bae\u7684Broker\uff09"},"content":{"rendered":"
\u652f\u6301\u4e0b\u56fd\u4ea7\u5f00\u6e90\u3002<\/div>\n
<\/div>\n
MQTT\u7269\u8054\u7f51\u4f20\u8f93\u63a7\u5236\u534f\u8bae\uff1a\u300aMQTT-3.1.1-CN.pdf<\/a>\u300b<\/div>\n
<\/div>\n
\n
\u4e0b\u8f7d\uff1aemqttd-centos64-v2.0-rc.2-20161019.zip<\/div>\n
<\/div>\n
\u5b89\u88c5\uff1a<\/b><\/div>\n
$ unzip\u00a0emqttd-centos64-v2.0-rc.2-20161019.zip -d \/data\/<\/div>\n
$ mv \/data\/emqttd \/data\/emqttd-centos64-v2.0-rc.2-20161019<\/div>\n
$ ln -s\u00a0\/data\/emqttd-centos64-v2.0-rc.2-20161019\u00a0\/data\/emqttd<\/div>\n
<\/div>\n
\u7cfb\u7edf\u4f18\u5316\u914d\u7f6e\uff1a<\/b><\/div>\n
# ulimit -n 1048576<\/div>\n
$ sudo sysctl -w fs.file-max=2097152<\/div>\n
$ sudo sysctl -w fs.nr_open=2097152<\/div>\n
$ sudo sysctl -w net.core.somaxconn=65535<\/div>\n
$ sudo sysctl -p<\/div>\n
<\/div>\n
\u4fee\u6539\u914d\u7f6e\u6587\u4ef6\uff08node.cookie\u5fc5\u987b\u6bcf\u53f0\u90fd\u8981\u4e00\u6837\uff0cnode.name\u7684@\u540e\u9762\u5fc5\u987b\u662fip\u5730\u5740\u6216\u8005fqdn\u65b9\u5f0f\u7684\u4e3b\u673a\u540d\uff09\uff1a<\/b><\/div>\n
$ cd \/data\/emqttd<\/div>\n
$ vi etc\/emq.conf<\/div>\n
## Node name<\/div>\n
node.name = emqttd@192.168.60.58<\/b><\/div>\n
## Cookie for distributed node<\/div>\n
node.cookie =\u00a0emq_dist_cookie_533d99ckd9ji475<\/div>\n
## Erlang Process Limit<\/div>\n
node.process_limit =\u00a02000000<\/div>\n
## Sets the maximum number of simultaneously existing ports for this system<\/div>\n
node.max_ports =\u00a01000000<\/div>\n
## Size of acceptor pool<\/div>\n
mqtt.listener.tcp.acceptors =\u00a064<\/div>\n
## Maximum number of concurrent clients<\/div>\n
mqtt.listener.tcp.max_clients =\u00a01000000<\/div>\n
## Rate Limit. Format is ‘burst,rate’, Unit is KB\/Sec<\/div>\n
## mqtt.listener.tcp.rate_limit =\u00a0100,10<\/div>\n
## TCP Socket Options<\/div>\n
mqtt.listener.tcp.backlog =\u00a0262144<\/div>\n
## Distributed node port range<\/div>\n
node.dist_listen_min = 6000<\/div>\n
node.dist_listen_max = 6999<\/div>\n
## \u5982\u679c\u9700\u8981\u542f\u7528\u9632\u706b\u5899\uff0c\u5219\u4e0a\u9762\u4e24\u884c\u53bb\u6389\u6ce8\u91ca\uff0c\u6ce8\u610f\u4e0b\u9762\u7684\u9632\u706b\u5899\u7aef\u53e3\u8bbe\u7f6e\uff0c\u8981\u6253\u5f00\u8be5\u6bb5\u7aef\u53e3\u3002<\/span><\/b><\/div>\n
## Expired after 1 day:<\/div>\n
## w – week<\/div>\n
## d – day<\/div>\n
## h – hour<\/div>\n
## m – minute<\/div>\n
## s – second<\/div>\n
mqtt.session.expired_after =\u00a02w<\/div>\n
# \u4e0a\u9762\u4e3a\u6301\u4e45\u4f1a\u8bdd\u5230\u671f\u65f6\u95f4\uff0c\u4ece\u5ba2\u6237\u7aef\u65ad\u5f00\u7b97\u8d77\uff0c\u8d85\u65f6\u540e\u5ba2\u6237\u7aef\u6ca1\u6709\u6536\u5230\u7684\u6d88\u606f\u4f1a\u4e22\u5f03\uff08\u4e0d\u60f3\u4e22\u5931\u6d88\u606f\u7684\u8bdd\uff0c\u8be5\u503c\u5c31\u8981\u8bbe\u7f6e\u7684\u5f88\u5927\uff09\u3002<\/b><\/div>\n
## Console log. Enum: off, file, console, both<\/div>\n
log.console =\u00a0both<\/div>\n
## Console log level. Enum: debug, info, notice, warning, error, critical, alert, emergency<\/div>\n
log.console.level =\u00a0info<\/div>\n
## Console log file<\/div>\n
log.console.file = log\/console.log<\/div>\n
## Error log file<\/div>\n
log.error.file = log\/error.log<\/div>\n
## Enable the crash log. Enum: on, off<\/div>\n
log.crash = on<\/div>\n
log.crash.file = log\/crash.log<\/div>\n
<\/div>\n
\u4fee\u6539\u4e0b\u542f\u52a8\u811a\u672c\uff08\u5728stop\u5904\u589e\u52a0\u4e00\u884c\uff09\uff1a<\/b><\/div>\n
$ vi bin\/emqttd<\/div>\n
…<\/div>\n
\u00a0 \u00a0 stop)<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 # Wait for the node to completely stop…<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 PID=”$(relx_get_pid)”<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 if ! relx_nodetool “stop”; then<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 exit 1<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 fi<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 while $(kill -s 0 “$PID” 2>\/dev\/null);<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 do<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 sleep 1<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 done<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0\u00a0killall epmd<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 ;;<\/div>\n
<\/div>\n
\u542f\u52a8\uff1a<\/b><\/div>\n
$ cd emqttd<\/div>\n
\u76f4\u63a5\u8fdb\u5165\u63a7\u5236\u53f0\u6a21\u5f0f\uff1a<\/div>\n
$ .\/bin\/emqttd console<\/div>\n
\u540e\u53f0\u8fd0\u884c\u6a21\u5f0f\uff1a<\/div>\n
$ .\/bin\/emqttd start<\/div>\n
$ .\/bin\/emqttd_ctl status<\/div>\n
$ .\/bin\/emqttd stop<\/div>\n
<\/div>\n
\u5f00\u542f\u9632\u706b\u5899\uff1a<\/b><\/div>\n
\u7aef\u53e3\uff1a1883\uff1aMQTT\u534f\u8baetcp\u7aef\u53e3\uff0c8883\uff1aMQTT(SSL) tcp\u7aef\u53e3\uff0c8083\uff1aMTQQ(websocket)\u3001HTTP API\u7aef\u53e3\uff0c18083\uff1adashboard\u7ba1\u7406\u63a7\u5236WEB\u7aef\u53e3\uff0c4369\uff1a\u96c6\u7fa4\u5904\u7406epmd\u7aef\u53e3\uff0c6000-6999\u7531\u4e0a\u9762\u914d\u7f6e\u6587\u4ef6\u5b9a\u4e49\u7684epmd\u9700\u8981\u7684\u7aef\u53e3\u8303\u56f4\u3002<\/b><\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=1883\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=1883\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=8883\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=8883\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=8083\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=8083\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=18083\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=18083\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=4369\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=4369\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=6000-6999\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=6000-6999\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –list-all<\/div>\n
sudo firewall-cmd –permanent –zone=public –list-all<\/div>\n
<\/div>\n
\u67e5\u770b\u5404\u53f0\u7684\u542f\u52a8\u72b6\u6001\uff1a<\/b><\/div>\n
http:\/\/192.168.60.55:8083\/status<\/div>\n
http:\/\/192.168.60.55:18083\/ \u00a0 \u00a0 \u00a0\u7528\u6237\u540d\/\u5bc6\u7801\uff1a admin \/ public<\/div>\n
$ vi data\/configs\/vm.xxx.args<\/div>\n
$\u00a0vi data\/configs\/app.xxx.conf<\/div>\n
<\/div>\n
LOG\u4f4d\u7f6e\uff1a<\/b><\/div>\n
$ vi log\/<\/div>\n
<\/div>\n
\u628a\u8282\u70b9\u52a0\u5165\u96c6\u7fa4\uff1a<\/b><\/div>\n
\u5728\u5404\u4e2a\u8282\u70b9\u4e0a\u6267\u884c\uff08\u91cd\u590d\u6267\u884c\u4e5f\u6ca1\u5173\u7cfb\uff0c\u5176\u4e2d192.168.60.55\u8fd9\u53f0\u4f1a\u63d0\u793a\u9519\u8bef\uff1acannot_join_with_self\uff0c\u8fd9\u4e2a\u6ca1\u5173\u7cfb\uff0c\u81ea\u5df1\u4e0d\u7528\u52a0\u5165\u81ea\u5df1\uff09\uff1a<\/div>\n
$ .\/bin\/emqttd_ctl cluster join emqttd@192.168.60.55<\/div>\n
$ .\/bin\/emqttd_ctl cluster status<\/div>\n
Cluster status: [{running_nodes,[’emqttd@192.168.60.58′,<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0’emqttd@192.168.60.56′,<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0’emqttd@192.168.60.57′,<\/div>\n
\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0’emqttd@192.168.60.55′]}]<\/div>\n
\u628a\u8282\u70b9\u9000\u51fa\u96c6\u7fa4\uff1a<\/b><\/div>\n
\u672c\u673a\u9000\u51fa\u96c6\u7fa4\uff1a<\/div>\n
$ .\/bin\/emqttd_ctl cluster leave<\/div>\n
\u628a\u67d0\u8282\u70b9\u9000\u51fa\u96c6\u7fa4\uff1a<\/div>\n
$ .\/bin\/emqttd_ctl cluster remove emqttd@192.168.60.56<\/div>\n
<\/div>\n
<\/div>\n
\u6d4b\u8bd5\u4e00\u4e0b\uff1a<\/b><\/div>\n
\u4e0b\u8f7d\u5b89\u88c5MTQQ\u534f\u8bae\u7684\u5ba2\u6237\u7aef\uff1ahttps:\/\/mosquitto.org\/download\/<\/a><\/div>\n
$ sudo rpm -ivh libmosquitto1-1.4.10-1.1.x86_64.rpm<\/div>\n
$ sudo rpm -ivh mosquitto-clients-1.4.10-1.1.x86_64.rpm<\/div>\n
\u8ba2\u9605\uff1a<\/div>\n
$ mosquitto_sub -h 192.168.60.56 -p 1883 -t test_topic_1 -q 1 -c -i 1111<\/div>\n
\u53d1\u5e03\uff1a\u53e6\u5f00\u4e00\u4e2assh\u6216\u8005\u53e6\u5916\u673a\u5668\u4e0a\u6267\u884c\uff1a<\/div>\n
$ mosquitto_pub -h 192.168.60.57 -p 1883 -t test_topic_1 -q 1 -m “hello mqtt 7”<\/div>\n
\u53c2\u6570\uff1a<\/div>\n
-h\uff1a \u8fde\u63a5\u5230\u54ea\u53f0broker\u3002<\/div>\n
-p\uff1a \u8fde\u63a5\u7aef\u53e3\u3002<\/div>\n
-t\uff1a topic\u540d\u5b57\uff0ctopic\u7c7b\u4f3c\u6587\u4ef6\u7cfb\u7edf\u7684\u7ec4\u7ec7\u65b9\u5f0f\uff0c\u4ee5”\/”\u5206\u9694\u7b26\u6765\u5206\u5c42\uff0c\u8ba2\u9605\u8005\u8ba2\u9605\u65f6\u53ef\u4ee5\u4f7f\u7528\u901a\u914d\u7b26”+”\u548c”#”\uff0c\u53d1\u5e03\u8005\u4e0d\u80fd\u4f7f\u7528\u901a\u914d\u7b26\u3002<\/div>\n
-q\uff1a qos\u7ea7\u522b\uff0c\u9ed8\u8ba4\u4e3a0\uff0c\u5171\u4e09\u4e2a\u503c\uff1a0\uff1a\u81f3\u591a\u4e00\u6b21\uff0c\u4e0d\u4fdd\u8bc1\u5230\u8fbe\u8ba2\u9605\u8005\uff1b1\uff1a\u81f3\u5c11\u4e00\u6b21\uff0c\u4fdd\u8bc1\u5230\u8fbe\u8ba2\u9605\u8005\uff0c\u4f46\u4e0d\u4fdd\u8bc1\u4e0d\u91cd\u590d\uff1b2\uff1a\u6b63\u597d\u4e00\u6b21\uff0c\u4fdd\u8bc1\u5230\u8fbe\uff0c\u53c8\u4fdd\u8bc1\u4e0d\u91cd\u590d\uff1b\u975e\u94b1\u7c7b\u7684\u5e94\u7528\u4f7f\u7528qos1\u5c31\u53ef\u4ee5\u4e86\u3002<\/div>\n
-c\uff1a \u5982\u679c\u8ba2\u9605\u8005\u9000\u51fa\uff0c\u5728broker\u4fdd\u7559\u6240\u6709\u8ba2\u9605\u7684\u6d88\u606f\uff0c\u4e00\u65e6\u91cd\u65b0\u8fde\u63a5\u4e0a\uff0c\u5219\u628a\u6240\u6709\u6d88\u606f\u53d1\u7ed9\u8ba2\u9605\u8005\uff0c\u5c31\u662f\u6301\u4e45\u6027\u8ba2\u9605\uff08clean_sess=false\uff09\u3002<\/div>\n
-i\uff1a \u8bbe\u7f6eclient id\uff0c\u5728\u5373\u65f6\u901a\u4fe1\u65f6\u53ef\u4ee5\u8bbe\u7f6e\u4e3a\u7528\u6237id\u6216\u8005\u7528\u6237\u540d\u7b49\u5177\u6709\u552f\u4e00\u6027\u7684\u5b57\u6bb5\u3002<\/div>\n
-r\uff1a \u53d1\u5e03\u65b9\u4f7f\u7528\u7684\u53c2\u6570\uff0c\u4fdd\u7559\u6d88\u606f\uff08\u6bcf\u4e2atopic\u53ea\u4fdd\u7559\u6700\u540e\u4e00\u4e2a\u8fd9\u79cd\u6d88\u606f\uff0c\u4e4b\u524d\u7684\u4f1a\u8986\u76d6\u00a0\uff09\uff0c\u5373\u4f7f\u8be5\u6d88\u606f\u88ab\u4e00\u4e2a\u8ba2\u9605\u8005\u8bfb\u53d6\u4e86\uff0c\u8fd8\u4f1a\u4e00\u76f4\u4fdd\u7559\u5728broker\uff0c\u5982\u679c\u6709\u65b0\u7684\u8ba2\u9605\u8005\u8ba2\u9605\u8be5topic\uff0c\u5219\u9a6c\u4e0a\u4f1a\u6536\u5230\u8be5\u6d88\u606f\uff0c\u7c7b\u4f3cqq\u91cc\u9762\u7684\u516c\u544a\u6027\u6d88\u606f\uff0c\u8fd9\u7c7b\u4fe1\u606f\u7684\u5220\u9664\uff0c\u53d1\u9001\u4e00\u4e2apayload\u4e3a\u7a7a\u7684null\u6d88\u606f\u5373\u53ef\uff1a$ mosquitto_pub -h 192.168.60.56 -p 1883 -t test_topic_1 -q 1 -r -n\u00a0 -u user -P 123456\u3002<\/div>\n
-m\uff1a \u8be5topic\u7684\u4e00\u6761\u6d88\u606f\u5185\u5bb9\u3002<\/div>\n
<\/div>\n
<\/div>\n
\u52a0\u5165MariaDB\u7684\u8ba4\u8bc1\uff1a<\/b><\/div>\n
\u4fee\u6539\u914d\u7f6e\uff1a<\/b><\/div>\n
$ vi .\/etc\/emq.conf<\/div>\n
## Allow Anonymous authentication<\/div>\n
mqtt.allow_anonymous =\u00a0false<\/div>\n
## Default ACL File<\/div>\n
mqtt.acl_file = etc\/acl.conf<\/div>\n
<\/div>\n
$ vi .\/data\/loaded_plugins<\/div>\n
emq_dashboard.<\/div>\n
emq_auth_mysql.<\/div>\n
<\/div>\n
\u4fee\u6539plugins\u914d\u7f6e\uff1a<\/b><\/div>\n
$ vi etc\/plugins\/emq_auth_mysql.conf<\/div>\n
## Mysql Server<\/div>\n
auth.mysql.server =\u00a0192.168.60.60:3306<\/div>\n
## Mysql Pool Size<\/div>\n
auth.mysql.pool = 8<\/div>\n
## Mysql Username<\/div>\n
auth.mysql.username = root<\/div>\n
## Mysql Password<\/div>\n
auth.mysql.password = 123456<\/div>\n
## Mysql Database<\/div>\n
auth.mysql.database = mqtt<\/div>\n
## Variables: %u = username, %c = clientid<\/div>\n
## Authentication Query: select password only<\/div>\n
auth.mysql.auth_query = select password from mqtt_user where username = ‘%u’ limit 1<\/div>\n
## Password hash: plain, md5, sha, sha256, pbkdf2<\/div>\n
auth.mysql.password_hash =\u00a0plain<\/div>\n
## %% Superuser Query<\/div>\n
auth.mysql.super_query = select is_superuser from mqtt_user where username = ‘%u’ limit 1<\/div>\n
## ACL Query Command<\/div>\n
auth.mysql.acl_query = select allow, ipaddr, username, clientid, access, topic from mqtt_acl where ipaddr = ‘%a’ or username = ‘%u’ or username = ‘$all’ or clientid = ‘%c’<\/div>\n
## ACL nomatch<\/div>\n
auth.mysql.acl_nomatch = deny<\/div>\n
<\/div>\n
\u5f80MariaDB\u63d2\u5165\u521d\u59cb\u5316\u6570\u636e\u5e93\u548c\u8868\uff08\u5f15\u64ce\u9700\u8981\u6539\u6210InnDB\uff09\uff1a<\/b><\/div>\n
\u8ba4\u8bc1\u7684\u7528\u6237\u8868\u4e5f\u53ef\u4ee5\u5171\u7528\u5176\u4ed6\u7cfb\u7edf\u7684\u7528\u6237\u8868\uff0c\u7531\u4e0a\u9762\u7684emq_auth_mysql.conf\u6765\u914d\u7f6e\uff1aauth.mysql.auth_query\u3001auth.mysql.super_query\u3001auth.mysql.acl_query\uff1a<\/b><\/div>\n
\u5efa\u7acbmqtt\u6570\u636e\u5e93\uff1a<\/div>\n
$ mysql -uroot -p123456 -hxxxx<\/div>\n
MariaDB [test]> create database mqtt;<\/div>\n
\u7528\u6237\u8868\uff1a<\/div>\n
MariaDB [test]> CREATE TABLE `mqtt_user` (<\/div>\n
\u00a0 `id` int(11) unsigned NOT NULL AUTO_INCREMENT,<\/div>\n
\u00a0 `username` varchar(100) DEFAULT NULL,<\/div>\n
\u00a0 `password` varchar(100) DEFAULT NULL,<\/div>\n
\u00a0 `salt` varchar(20) DEFAULT NULL,<\/div>\n
\u00a0 `is_superuser` tinyint(1) DEFAULT 0,<\/div>\n
\u00a0 `created` datetime DEFAULT NULL,<\/div>\n
\u00a0 PRIMARY KEY (`id`),<\/div>\n
\u00a0 UNIQUE KEY `mqtt_username` (`username`)<\/div>\n
) DEFAULT CHARSET=utf8;<\/div>\n
\u7528\u6237\u8868\u63d2\u5165\u6d4b\u8bd5\u6570\u636e\uff1a<\/div>\n
MariaDB [mqtt]> INSERT INTO mqtt_user\u00a0(id, username, password, salt, is_superuser, created)<\/div>\n
VALUES<\/div>\n
\u00a0 \u00a0 (1,’superuser’,’123456′,’123456′,True,’2016-10-26 10:00:00′),<\/div>\n
\u00a0 \u00a0 (2,’user’,’123456′,’123456′,False,’2016-10-26 10:01:00′);<\/div>\n
acl\u8868\uff1a<\/div>\n
MariaDB [mqtt]> CREATE TABLE `mqtt_acl` (<\/div>\n
\u00a0 `id` int(11) unsigned NOT NULL AUTO_INCREMENT,<\/div>\n
\u00a0 `allow` int(1) DEFAULT NULL COMMENT ‘0: deny, 1: allow’,<\/div>\n
\u00a0 `ipaddr` varchar(60) DEFAULT NULL COMMENT ‘IpAddress’,<\/div>\n
\u00a0 `username` varchar(100) DEFAULT NULL COMMENT ‘Username’,<\/div>\n
\u00a0 `clientid` varchar(100) DEFAULT NULL COMMENT ‘ClientId’,<\/div>\n
\u00a0 `access` int(2) NOT NULL COMMENT ‘1: subscribe, 2: publish, 3: pubsub’,<\/div>\n
\u00a0 `topic` varchar(100) NOT NULL DEFAULT ” COMMENT ‘Topic Filter’,<\/div>\n
\u00a0 PRIMARY KEY (`id`)<\/div>\n
) DEFAULT CHARSET=utf8;<\/div>\n
acl\u8868\u63d2\u5165\u9ed8\u8ba4\u6570\u636e\uff08\u6ce8\u610f\u5e26$SYS\u4e3abroker\u4fdd\u7559\u7684\u7279\u6b8atopic\u7528\u6765\u7edf\u8ba1\u4f7f\u7528\uff0cusername\u4e3a$all\u8868\u793a\u6240\u6709\u5728user\u8868\u4e2d\u7684\u7528\u6237<\/b>\uff09\uff1a<\/div>\n
MariaDB [mqtt]> INSERT INTO mqtt_acl (id, allow, ipaddr, username, clientid, access, topic)<\/div>\n
VALUES<\/div>\n
\u00a0 \u00a0 (1,1,NULL,’$all’,NULL,2,’#’),<\/div>\n
\u00a0 \u00a0 (2,1,NULL,’$all’,NULL,1,’#’),<\/div>\n
\u00a0 \u00a0 (3,1,NULL,’$all’,NULL,3,’#’),<\/div>\n
\u00a0 \u00a0 (4,1,’127.0.0.1′,NULL,NULL,2,’$SYS\/#’),<\/div>\n
\u00a0 \u00a0 (5,1,’127.0.0.1′,NULL,NULL,2,’#’),<\/div>\n
\u00a0 \u00a0 (6,1,NULL,’dashboard’,NULL,1,’$SYS\/#’);<\/div>\n
<\/div>\n
\u6d4b\u8bd5\uff0c\u91cd\u542f\u6bcf\u53f0\u670d\u52a1\u5668\u540e\u6267\u884c\uff1a<\/b><\/div>\n
$ mosquitto_sub -h 192.168.60.55 -p 1883 -t test_topic_1 -q 1 -c -i 1112\u00a0 -u user -P 123456<\/div>\n
$ mosquitto_pub -h 192.168.60.55 -p 1883 -t test_topic_1 -q 1 -m “hello mqtt 1” -u user -P 123456<\/div>\n
<\/div>\n
<\/div>\n
\u91cd\u65b0\u521d\u59cb\u5316emq\uff1a<\/b><\/div>\n
$ bin\/emqttd stop<\/div>\n
$ rm -rf data\/mnesia\/*<\/div>\n
$ rm -rf data\/configs\/*<\/div>\n
$ rm -rf log\/*<\/div>\n
$ bin\/emqttd start<\/div>\n
$ bin\/emqttd_ctl cluster join emqttd@192.168.60.55<\/div>\n
<\/div>\n
<\/div>\n
\u4f7f\u7528Haproxy\u6765\u5b9e\u73b0\u8d1f\u8f7d\u5206\u62c5\uff1a<\/b><\/div>\n
\u56e0\u4e3aemq\u7684topic\u548c\u6d88\u606f\u5728\u96c6\u7fa4\u7684\u5404\u53f0\u670d\u52a1\u5668\u4e0a\u4e00\u81f4\uff0c\u6240\u4ee5\u6570\u636e\u4e0d\u80fd\u4ee5\u589e\u52a0\u673a\u5668\u7684\u65b9\u5f0f\u6269\u5bb9\uff0c\u53ea\u80fd\u589e\u52a0\u6bcf\u53f0\u7684\u5185\u5b58\uff0c\u548c\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\u5219\u53ef\u4ee5\u4ee5\u589e\u52a0\u673a\u5668\u65b9\u5f0f\u6269\u5bb9\u3002<\/b><\/div>\n
$ vi \/etc\/haproxy\/haproxy.cfg<\/div>\n
################## EMQ ######################<\/div>\n
listen emq_emqttd *:1883<\/div>\n
\u00a0 \u00a0 mode tcp<\/div>\n
\u00a0 \u00a0 balance source<\/div>\n
\u00a0 \u00a0 log global<\/div>\n
\u00a0 \u00a0 timeout connect\u00a0 \u00a0 \u00a0 \u00a0 \u00a025s<\/div>\n
\u00a0 \u00a0 timeout client\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 0<\/div>\n
\u00a0 \u00a0 timeout server\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 0<\/div>\n
\u00a0 \u00a0 option tcpka<\/div>\n
\u00a0 \u00a0 option tcplog<\/div>\n
\u00a0 \u00a0 option tcp-check<\/div>\n
\u00a0 \u00a0 server emq1 192.168.60.55:1883 check inter 25000 port 1883 rise 2 fall 2 weight 25<\/div>\n
\u00a0 \u00a0 server emq2 192.168.60.56:1883 check inter 25000 port 1883 rise 2 fall 2 weight 25<\/div>\n
\u00a0 \u00a0 server emq3 192.168.60.57:1883 check inter 25000 port 1883 rise 2 fall 2 weight 25<\/div>\n
\u00a0 \u00a0 server emq4 192.168.60.58:1883 check inter 25000 port 1883 rise 2 fall 2 weight 25<\/div>\n
<\/div>\n
\u5f00\u542fhaproxy\u4e0a\u7684\u9632\u706b\u5899\uff1a<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –add-port=1883\/tcp<\/div>\n
sudo firewall-cmd –permanent –zone=public –add-port=1883\/tcp<\/div>\n
sudo firewall-cmd\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 –zone=public –list-all<\/div>\n
sudo firewall-cmd –permanent –zone=public –list-all<\/div>\n
<\/div>\n
<\/div>\n
\u4f7f\u7528\uff1a<\/b><\/div>\n
broker\u64cd\u4f5c\uff1a<\/b><\/div>\n
\u663e\u793abroker\u72b6\u6001\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl status<\/div>\n
\u663e\u793abroker\u7248\u672c\u3001\u542f\u7528\u65f6\u95f4\u7b49\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl broker<\/div>\n
\u663e\u793abroker\u7684pubsub\u8fdb\u7a0b\u72b6\u6001\u3001\u5185\u5b58\u3001\u961f\u5217\u957f\u5ea6\u3001\u89c4\u7ea6\u6570\u7b49\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl broker\u00a0 pubsub<\/div>\n
\u663e\u793abroker\u7684\u7edf\u8ba1\u4fe1\u606f\uff1a\u5ba2\u6237\u7aef\u8fde\u63a5\u6570\u3001\u4f1a\u8bdd\u6570\u3001\u4e3b\u9898\u6570\u3001\u8ba2\u9605\u6570\u3001\u8def\u7531\u6570\u7b49\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl broker stats<\/div>\n
\u663e\u793abroker\u7684\u6d4b\u91cf\u4fe1\u606f\uff1a\u5e95\u5c42\u6d41\u91cf\u3001MQTT\u62a5\u6587\u6570\u3001\u6d88\u606f\u6570\u7b49\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl broker metrics<\/div>\n
Cluster\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl cluster<\/div>\n
cluster join <Node>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Join the cluster<\/div>\n
cluster leave\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Leave the cluster<\/div>\n
cluster remove <Node>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Remove the node from cluster<\/div>\n
cluster status\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Cluster status<\/div>\n
Client\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl clients<\/div>\n
clients list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # List all clients<\/div>\n
clients show <ClientId>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Show a client<\/div>\n
clients kick <ClientId>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Kick out a client<\/div>\n
Sessions\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl sessions<\/div>\n
sessions list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# List all sessions<\/div>\n
sessions list persistent\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # List all persistent sessions \uff0c\u6865\u63a5Bridge\u7684\u65f6\u5019\u624d\u4f1a\u7528\u5230\uff08\u5373clean_sess=false\u7684\u7c7b\u578b\uff09<\/div>\n
sessions list transient\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# List all transient sessions<\/div>\n
sessions show <ClientId>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Show a session<\/div>\n
Routes\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl routes<\/div>\n
routes list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# List all routes<\/div>\n
routes show <Topic>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Show a route<\/div>\n
Topics\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl topics<\/div>\n
topics list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# List all topics<\/div>\n
topics show <Topic>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Show a topic<\/div>\n
Subscription\u8ba2\u9605\u8005\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl subscriptions<\/div>\n
subscriptions list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # List all subscriptions<\/div>\n
subscriptions show <ClientId>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Show subscriptions of a client<\/div>\n
subscriptions add <ClientId> <Topic> <QoS>\u00a0 \u00a0 \u00a0 # Add a static subscription manually<\/div>\n
subscriptions del <ClientId>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Delete static subscriptions manually<\/div>\n
subscriptions del <ClientId> <Topic>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Delete a static subscription manually<\/div>\n
Plugins\u63d2\u4ef6\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl plugins<\/div>\n
plugins list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Show loaded plugins<\/div>\n
plugins load <Plugin>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Load plugin<\/div>\n
plugins unload <Plugin>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Unload plugin<\/div>\n
$ .\/bin\/emqttd_ctl plugins list<\/div>\n
Plugin(emq_auth_clientid, version=2.0, description=Authentication with ClientId\/Password, active=false)<\/div>\n
Plugin(emq_auth_http, version=2.0, description=Authentication\/ACL with HTTP API, active=false)<\/div>\n
Plugin(emq_auth_ldap, version=2.0, description=Authentication\/ACL with LDAP, active=false)<\/div>\n
Plugin(emq_auth_mongo, version=2.0, description=Authentication\/ACL with MongoDB, active=false)<\/div>\n
Plugin(emq_auth_mysql, version=2.0, description=Authentication\/ACL with MySQL, active=false)<\/div>\n
Plugin(emq_auth_pgsql, version=2.0, description=Authentication\/ACL with PostgreSQL, active=false)<\/div>\n
Plugin(emq_auth_redis, version=2.0, description=Authentication\/ACL with Redis, active=false)<\/div>\n
Plugin(emq_auth_username, version=2.0, description=Authentication with Username\/Password, active=false)<\/div>\n
Plugin(emq_coap, version=0.2, description=CoAP Gateway, active=false)<\/div>\n
Plugin(emq_dashboard, version=2.0, description=Dashboard, active=true)<\/div>\n
Plugin(emq_mod_rewrite, version=2.0, description=Rewrite Module, active=false)<\/div>\n
Plugin(emq_plugin_template, version=2.0, description=EMQ Plugin Template, active=false)<\/div>\n
Plugin(emq_recon, version=2.0, description=Recon Plugin, active=false)<\/div>\n
Plugin(emq_reloader, version=2.0, description=Reloader Plugin, active=false)<\/div>\n
Plugin(emq_sn, version=0.2, description=MQTT-SN Gateway, active=false)<\/div>\n
Plugin(emq_stomp, version=2.0, description=Stomp Protocol Plugin, active=false)<\/div>\n
Bridges\u6865\u63a5\u64cd\u4f5c\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl bridges<\/div>\n
bridges list\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # List bridges<\/div>\n
bridges options\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Bridge options<\/div>\n
bridges start <Node> <Topic>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Start a bridge<\/div>\n
bridges start <Node> <Topic> <Options>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 # Start a bridge with options<\/div>\n
bridges stop <Node> <Topic>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Stop a bridge<\/div>\n
vm\u865a\u673a\uff08erlang\u865a\u673a\uff09\u6027\u80fd\u67e5\u770b\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl vm all<\/div>\n
cpu\/load1\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 0.05<\/div>\n
cpu\/load5\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 0.05<\/div>\n
cpu\/load15\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 : 0.07<\/div>\n
memory\/total\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 : 166404232<\/div>\n
memory\/processes\u00a0 \u00a0 \u00a0 \u00a0 : 32564328<\/div>\n
memory\/processes_used\u00a0 \u00a0: 32563952<\/div>\n
memory\/system\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 133839904<\/div>\n
memory\/atom\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 959633<\/div>\n
memory\/atom_used\u00a0 \u00a0 \u00a0 \u00a0 : 954350<\/div>\n
memory\/binary\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 46088<\/div>\n
memory\/code\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 28250535<\/div>\n
memory\/ets\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 : 5741416<\/div>\n
process\/limit\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 2097152<\/div>\n
process\/count\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 288<\/div>\n
io\/max_fds\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 : 1000000<\/div>\n
io\/active_fds\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 1<\/div>\n
ports\/count\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 25<\/div>\n
ports\/limit\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0: 1048576<\/div>\n
\u7aef\u53e3\u4f7f\u7528\u60c5\u51b5\u67e5\u770b\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl listeners<\/div>\n
mnesia\u6570\u636e\u5e93\u4fe1\u606f\u67e5\u770b\uff1a<\/b><\/div>\n
$ bin\/emqttd_ctl mnesia<\/div>\n
\u7ba1\u7406dashboard\u7528\u6237\uff1a<\/b><\/div>\n
$ .\/bin\/emqttd_ctl admins<\/div>\n
admins add <Username> <Password> <Tags>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Add dashboard user<\/div>\n
admins passwd <Username> <Password>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Reset dashboard user password<\/div>\n
admins del <Username>\u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0# Delete dashboard user<\/div>\n
<\/div>\n
\u8ffd\u8e2a \uff0cEMQ\u6d88\u606f\u670d\u52a1\u5668\u652f\u6301\u8ffd\u8e2a\u6765\u81ea\u67d0\u4e2a\u5ba2\u6237\u7aef(Client)\u7684\u5168\u90e8\u62a5\u6587\uff0c\u6216\u8005\u53d1\u5e03\u5230\u67d0\u4e2a\u4e3b\u9898(Topic)\u7684\u5168\u90e8\u6d88\u606f\u3002<\/b><\/div>\n
\u8ffd\u8e2a\u5ba2\u6237\u7aef(Client):<\/div>\n
.\/bin\/emqttd_ctl trace client “clientid(mosqsub\/23058-vm6)” “trace_clientid.log”<\/div>\n
\u8ffd\u8e2a\u4e3b\u9898(Topic):<\/div>\n
.\/bin\/emqttd_ctl trace topic “topic1” “trace_topic.log”<\/div>\n
\u67e5\u8be2\u8ffd\u8e2a:<\/div>\n
.\/bin\/emqttd_ctl trace list<\/div>\n
\u505c\u6b62\u8ffd\u8e2a:<\/div>\n
.\/bin\/emqttd_ctl trace client “clientid(mosqsub\/23058-vm6)” off<\/div>\n
.\/bin\/emqttd_ctl trace topic “topic1” off<\/div>\n
<\/div>\n
\u94a9\u5b50(Hook)\u6269\u5c55\uff0cEMQ\u6d88\u606f\u670d\u52a1\u5668\u5728\u5ba2\u6237\u7aef\u4e0a\u4e0b\u7ebf\u3001\u4e3b\u9898\u8ba2\u9605\u3001\u6d88\u606f\u6536\u53d1\u4f4d\u7f6e\u8bbe\u8ba1\u4e86\u6269\u5c55\u94a9\u5b50(Hook):<\/b><\/div>\n
\u94a9\u5b50 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\u8bf4\u660e<\/div>\n
client.connected \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u5ba2\u6237\u7aef\u4e0a\u7ebf<\/div>\n
client.subscribe \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u5ba2\u6237\u7aef\u8ba2\u9605\u4e3b\u9898\u524d<\/div>\n
client.unsubscribe \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u5ba2\u6237\u7aef\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898<\/div>\n
session.subscribed \u00a0 \u00a0 \u00a0 \u00a0 \u00a0\u5ba2\u6237\u7aef\u8ba2\u9605\u4e3b\u9898\u540e<\/div>\n
session.unsubscribed \u00a0 \u00a0 \u00a0\u5ba2\u6237\u7aef\u53d6\u6d88\u8ba2\u9605\u4e3b\u9898\u540e<\/div>\n
message.publish \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 MQTT\u6d88\u606f\u53d1\u5e03<\/div>\n
message.delivered \u00a0 \u00a0 \u00a0 \u00a0 \u00a0MQTT\u6d88\u606f\u9001\u8fbe<\/div>\n
message.acked \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 \u00a0 MQTT\u6d88\u606f\u56de\u6267<\/div>\n
client.disconnected \u00a0 \u00a0 \u00a0 \u00a0\u5ba2\u6237\u7aef\u8fde\u63a5\u65ad\u5f00<\/div>\n
\u94a9\u5b50\u4f7f\u7528\u4f8b\u5b50\uff1a<\/div>\n
-module(emqttd_plugin_template).<\/div>\n
-export([load\/1, unload\/0]).<\/div>\n
-export([on_message_publish\/2, on_message_delivered\/4, on_message_acked\/4]).<\/div>\n
load(Env) -><\/div>\n
\u00a0 \u00a0 emqttd:hook(‘message.publish’, fun ?MODULE:on_message_publish\/2, [Env]),<\/div>\n
\u00a0 \u00a0 emqttd:hook(‘message.delivered’, fun ?MODULE:on_message_delivered\/4, [Env]),<\/div>\n
\u00a0 \u00a0 emqttd:hook(‘message.acked’, fun ?MODULE:on_message_acked\/4, [Env]).<\/div>\n
on_message_publish(Message, _Env) -><\/div>\n
\u00a0 \u00a0 io:format(“publish ~s~n”, [emqttd_message:format(Message)]),<\/div>\n
\u00a0 \u00a0 {ok, Message}.<\/div>\n
on_message_delivered(ClientId, _Username, Message, _Env) -><\/div>\n
\u00a0 \u00a0 io:format(“delivered to client ~s: ~s~n”, [ClientId, emqttd_message:format(Message)]),<\/div>\n
\u00a0 \u00a0 {ok, Message}.<\/div>\n
on_message_acked(ClientId, _Username, Message, _Env) -><\/div>\n
\u00a0 \u00a0 io:format(“client ~s acked: ~s~n”, [ClientId, emqttd_message:format(Message)]),<\/div>\n
\u00a0 \u00a0 {ok, Message}.<\/div>\n
unload() -><\/div>\n
\u00a0 \u00a0 emqttd:unhook(‘message.publish’, fun ?MODULE:on_message_publish\/2),<\/div>\n
\u00a0 \u00a0 emqttd:unhook(‘message.acked’, fun ?MODULE:on_message_acked\/4),<\/div>\n
\u00a0 \u00a0 emqttd:unhook(‘message.delivered’, fun ?MODULE:on_message_delivered\/4).<\/div>\n
<\/div>\n
<\/div>\n
MQTT\u534f\u8bae\u7684\u5ba2\u6237\u7aef\u5e93\uff1a<\/b><\/div>\n
https:\/\/github.com\/mqtt\/mqtt.github.io\/wiki\/libraries<\/a><\/div>\n
http:\/\/www.eclipse.org\/paho\/downloads.php<\/a><\/div>\n
<\/div>\n
<\/div>\n
\u505aIM\u5373\u65f6\u901a\u4fe1\u534f\u8bae\u65f6\u7684\u8003\u8651\uff1a<\/b><\/div>\n
MQTT\u4f5c\u4e3a\u53d1\u5e03\u3001\u8ba2\u9605\u7cfb\u7edf\uff0c\u4f5c\u4e3a\u6d88\u606f\u63a8\u9001\u662f\u5f88\u597d\u7684\u3002<\/div>\n
\u5982\u679c\u4f5c\u4e3aIM\u5373\u65f6\u901a\u4fe1\uff0c\u5219\u53ef\u4ee5\u8003\u8651\u628a\u6bcf\u4e2a\u7528\u6237id\u505a\u6210\u4e00\u4e2atopic\uff0c\u6bcf\u4e2a\u7528\u6237\u8ba2\u9605\u540d\u4e3a\u81ea\u5df1id\u7684topic\uff08\u6bd4\u5982”USER\/1111″\uff09\uff0c\u53d1\u9001\u65b9\u5982\u679c\u9700\u8981\u53d1\u5e03\u6d88\u606f\u7ed9\u67d0\u4e00\u4e2a\u7528\u6237\uff0c\u5219\u53d1\u5e03\u8be5\u7528\u6237id\u7684topic\u6d88\u606f\uff0c\u5bf9\u65b9\u81ea\u7136\u5c31\u4f1a\u6536\u5230\u3002\u53e6\u5916\u6bcf\u4e2a\u7528\u6237\u8fd8\u8981\u8ba2\u9605\u51e0\u4e2a\u7cfb\u7edf\u7c7b\u7684topic\uff08\u6bd4\u5982”ADMIN\/broadcast”\uff0c”ADMIN\/1111″\uff09\uff0c\u4ee5\u4fbf\u540e\u53f0\u7cfb\u7edf\u53d1\u5e03\u5404\u7c7b\u6d88\u606f\u3002\u81f3\u4e8e\u7fa4\u7ec4\u6d88\u606f\uff0c\u6bcf\u52a0\u5165\u4e00\u4e2a\u7fa4\uff0c\u5219\u589e\u52a0\u8ba2\u9605\u4e00\u4e2a\u540d\u4e3a\u7fa4id\u7684topic\uff08\u6bd4\u5982”GROUP\/1111″\uff09\u3002<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"

\u652f\u6301\u4e0b\u56fd\u4ea7\u5f00\u6e90\u3002 MQTT\u7269\u8054\u7f51\u4f20\u8f93\u63a7\u5236\u534f\u8bae\uff1a\u300aMQTT-3.1.1-CN.pdf\u300b \u4e0b\u8f7d\uff1aemqttd-ce …<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[13],"tags":[337,334,333,119,94,338],"class_list":["post-403","post","type-post","status-publish","format-standard","hentry","category-13","tag-emq","tag-emqtt","tag-mqtt","tag-119","tag-94","tag-338"],"views":1828,"_links":{"self":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts\/403","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=403"}],"version-history":[{"count":1,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts\/403\/revisions"}],"predecessor-version":[{"id":404,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts\/403\/revisions\/404"}],"wp:attachment":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=403"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=403"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=403"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}