关闭匿名认证
etc/emq.conf 配置启用匿名认证:
##Allow Anonymous authentication mqtt.allow_anonymous = false
用户名密码认证
etc/plugins/emq_auth_username.conf auth.user.1.username = admin auth.user.1.password = public
启用账号密码验证插件
/bin/emqttd_ctl plugins load emq_auth_username
使用命令添加用户
bin/emqttd_ctl users add 修改完配置文件之后需重启mqtt
关闭账号密码验证插件
bin/emqttd_ctl plugins unload emq_auth_username
订阅多个主题
///Qos和topic1一致
int[] Qos = {1, 1};//0:最多一次,消息会丢失和重复;1:至少一次,但消息会重复;2:只有一次,确保消息达到一次
String[] topic = {TOPIC, TOPIC1};
client.subscribe(topic, Qos);