最近公司在做物联网项目,买了个大喇叭,mqtt客户端是用lua语言编写的,mqtt服务器部署在腾讯云上。
最开始准备用docker安装EMQ X,但发现客户端连不上。以为是版本问题,就使用最开始的mqtt v3.1版本的EMQ
X,还是不行。
接连换了ActiveMQ5和Apollo1.7.1,都不行。
然后我就怀疑是客户端的原因了。
今天找了两个开源的客户端,安装、测试了一把,一个连不上,另一个可以连上。这里记录一下安装过程。
首先尝试安装mqtt_lua(失败)
安装前准备:
(1)安装Python3.5及以上;
(2)安装OpenSSL,安装方法可参考:https://blog.csdn.net/weixin_38090488/article/details/83721660,如果后面报错“找不到openssl/ssl.h文件”,可以参考https://blog.csdn.net/guozhiyingguo/article/details/52791284?utm_medium=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.nonecase&depth_1-utm_source=distribute.pc_relevant_t0.none-task-blog-BlogCommendFromMachineLearnPai2-1.nonecase
1 安装EMQ X
云服务器端只需要执行这一步,其他步骤是在作为客户端的本地机器上进行。
1.1 拉取镜像
docker pull emqx/emqx:v4.1.0-alpine-amd64
1.2 启动容器
docker run -d --name emqx31 -p 1883:1883 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083 emqx/emqx:v4.1.0-alpine-amd64
1.3 设置用户名/密码:
默认连接EMQ X服务器的时候不需要密码,这在在生产环境下肯定不行。
docker exec -it 容器ID /bin/sh
vi etc/plugins/emqx_auth_username.conf
在## Example下面可以看到所有用户名和密码都是被注释了的,配置用户名和密码只需增加这两行:
auth.user.1.username = 用户名
auth.user.1.password = 密码
1.4 关闭匿名登录
vi etc/emqx/emqx.conf
找到allow_anonymous = false这一行,将其修改为true。
修改完成后,在容器内执行emqx restart,或者退出容器,执行"docker restart 容器ID"即可生效。
1.5 验证
打开浏览器,输入IP:18083,即可看到EMQ X提供的dashboard,登录用户名是admin,密码是public。注意,这里的用户名和密码与服务器连接时的用户名和密码不同。如果服务器部署在云端,那么需要在安全设置里配置规则,放行18083端口(最好是EMQ X相关端口都放行)。
进入Dashboard后,找到“工具”-“WebSocket”,在“连接”模块下填入主机地址和端口(默认8083),如果不填入用户名和密码就点击“连接”的话,是会提示Connection refused: Not authorized。此时填入上面配置的用户名和密码,再点击“连接”就可以连上了。
EMQ X配置告一段落。
2 安装Lua编程语言
2.1 下载lua-5.4.0.tar.gz
进入下载页面https://www.lua.org/download.html,右键点击lua-5.4.0.tar.gz,选择“复制链接地址”,然后执行下面的命令下载:
wget https://www.lua.org/ftp/lua-5.4.0.tar.gz
2.2 安装
tar -zxvf lua-5.4.0.tar.gz
cd lua-5.4.0
make linux test(如果这一步有问题,解决办法参见https://www.jianshu.com/p/0ba41cf0403c)
sudo make install
2.3 验证
命令“lua -v”可以查看版本的话,说明安装成功。
3 安装luarocks
有两张安装方式,一是编译安装,一是package安装。这里直说编译安装,因为这样可以安装最新版。package安装的命令是:sudo apt-get install luarocks。二者选其一即可。
3.1 下载
进入下载页面https://github.com/luarocks/luarocks/wiki/Download
在Downloading中找到Tarball for Unix,右键复制链接地址,然后用wget工具下载。)
3.2 安装
点击Installing下面的”Installation instructions for Unix (Linux, BSDs, etc.)“,进入安装页面后按照命令安装(这里其实也有安装lua的方法),或者参考下面的命令:
sudo apt install build-essential libreadline-dev
wget https://luarocks.org/releases/luarocks-3.3.1.tar.gz
tar zxpf luarocks-3.3.1.tar.gz
cd luarocks-3.3.1
./configure --with-lua-include=/usr/local/include
make
sudo make install
3.3 验证
命令”luarocks --version“可以查看版本的话,说明安装成功。
4 安装LuaSocket
4.1 下载
进入下载页面,http://files.luaforge.net/releases/luasocket/luasocket,下载luasocket-2.0.2,下载方法与上面一样。
4.2 安装
根据https://blog.csdn.net/caoshunxin01/article/details/79355659的说法,lua5.2+的版本都不支持luasocket,但我没有验证。为了保险起见,可以参照这篇文章或下面的命令安装luasocket:
sudo apt-get install lua5.1
luarocks install luasocket
5 安装Penlight
Penlight的GitHub地址:https://github.com/Tieske/Penlight
执行下面的命令即可安装:
luarocks install penlight
至此,客户端运行环境安装完成,但是mqtt_lua测试失败,具体问题看该开源软件的issues。
下面安装第二种客户端工具:luamqttc,这一个工具测试成功,工具地址:https://github.com/Yongke/luamqttc
6 编译客户端
git clone https://github.com/Yongke/luamqttc.git
打开deps/lua-compat-5.2.h,找到”void lua_setuservalue (lua_State *L, int i);”这一行将其注释掉,否则执行下一步会报错。然后打开src/client.lua源文件,找到“_M.new = function(client_id, opts)”这个方法,该方法用于创建客户端对象。在该方法中的“m.opts.client_id = client_id”这一行下面,增加下面两行来指定EMQ X服务器连接时的用户名和密码(见1.3):
m.opts.username = 用户名
m.opts.password = 密码
保存后,执行下面的命令编译:
luarocks make
7 运行服务端
这个是在本地测试时运行fake一个服务器:
git clone https://github.com/eclipse/paho.mqtt.testing.git
cd paho.mqtt.testing/interoperability && python3 startbroker.py
8 测试
重新打开一个终端,进入客户端luamqttc根目录,在tests目录下有个文件client_test.lua。该文件中保存主机地址的是host字段,默认localhost,如果测试的是云端的mqtt服务器,那么将该字段更改为云端IP地址即可。
打开MQTTBox或MQTTfx(建议前者,更好用),配置好Host,Username,Password后点击保存,然后添加以下五个订阅主题(这五个主题是tests/client_test.lua中指定的测试主题,当然你也可以自己指定):
"TopicA", "TopicA/B", "Topic/C", "TopicA/C", "/TopicA"
最后,执行下面的命令测试连接、发布/订阅消息。
lua tests/client_test.lua
结果入下:
至此,测试完成!