规定通过mqtt_user表格验证过的用户才能连接EMQ服务器，我们需要开启mysql插件认证。EMQ2.0自带mysql插件，下面开始配置。
新建mqtt_user表格
要想控制用户登录EMQ，肯定是首先创建一个可管理的用户表格，规定只有在这个表格中的用户才能被允许连接EMQ。 按照EMQ官方文档在你mysql服务器中新建一个mqtt_user的表格(/docs/v2/guide.html#mysql)
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;
关闭匿名登录
修改emq.conf(文件在你安装EMQ目录的./etc中)
$ vim /emqttd/etc/emq.conf // 编辑emq.conf
mqtt.allow_anonymous = false // 修改为false
配置、加载mysql插件
可以通过两种方式配置、加载mysql插件
命令行方式
修改emq_auth_mysql.conf(文件在你安装EMQ目录的./etc/plugins中)
$ vim /emqttd/etc/plugins/emq_auth_mysql.conf
修改如下配置
auth.mysql.server = MYSQL_SERVER_IP:PORT // mysql服务器地址，例如：127.0.0.1:3306
auth.mysql.username = USERNAME // mysql登录用户名
auth.mysql.password = PWD // mysql登录密码
auth.mysql.database = DATABASE_NAME // 默认使用库
加载mysql插件
$ /emqttd/bin/emqttd_ctl plugins load emq_auth_mysql
Web方式
EMQ默认开启一个web服务器用于可视化管理EMQ服务器(URL:18083)，登录用户：admin、密码：public 找到 emq_auth_mysql 插件点击 配置
填写用户名、密码、ip、端口号、数据库名称
然后点击 确定 -> 启动
如果开启mysql插件报错，请自行查看EMQ日志，或者开启mysql服务器日志，大概率是mysql服务禁止访问。如果你是阿里云ECS，请设置ECS的安全组开启端口号3306出入网设置，或者检查服务器防火墙设置。如果依然报错，请设置mysql配置文件允许账户远程登录(这个可以上网搜下)，如果都没问题，emq_auth_mysql插件启动成功，下面我们可以使用EMQ自带的Dashboard的web页面(也就是前面提到的URL:18083)，找到 Websocket 填写任意账号测试能否连接EMQ服务器。
测试发现任意填写的用户、密码还是能连接上啊，我们mqtt_user中并没有任何用户记录，为什么还是能连接上，如果你EMQ服务器是先启动后配置mysql插件的话确实会出现这种情况，即使你使用重启命令重启EMQ服务器还是不行。
$ /emqttd/bin/emqttd restart
你必须先关闭EMQ，再启动EMQ，mysql插件才会生效(这个官方文档并没有说明，大坑啊)。
$ /emqttd/bin/emqttd stop
$ /emqttd/bin/emqttd start
测试
然后我们往mqtt_user中新增一条用户 username: 'admin' (用户名) password: '03ac674216f3e15c761ee1a5e255f067953623c8b388b4459e13f978d7c846f4' (密码'1234'的sha256加密字符)
因为mysql插件中读取出的密码会和明文传递的密码的sha256加密字符比较，这个可以通过配置emq_auth_mysql.conf修改。
insert into mqtt_user (`username`, `password`) values ('admin', '03ac674216f3e15c761ee1a5e255f067953623c8b388b4459e13f978d7c846f4');
然后测试 OK
