1、安装Docker
为了避免重复安装,这里使用Docker来安装Emq X Broker,Docker直接去官网下载安装包安装即可。官方网址:https://www.docker.com/
2、安装Emqx
官网https://www.emqx.io/也给出了安装方式,这里采用的是Docker环境下安装。
打开Windows命令行
docker pull emqx/emqx:4.2.2
docker run -d --name emqx -p 1883:1883 -p 8083:8083 -p 8883:8883 -p 8084:8084 -p 18083:18083 emqx/emqx:4.2.2
然后启动服务,访问http://localhost:18083即可访问,用户名:admin,密码:public

3、实现WebHook
由于免费版本不支持桥接到Kafka等第三方系统上,所以这里来实现一个Webhook来对采集的数据进行进一步处理。
以下是用Node.js实现的简单代码,只有通过Debug可以获取信息
var http = require('http');
var server = http.createServer(function (req, res) {
// 接收 POST 数据。如果请求方法不是 POST ,那么这个变量最终是空字符串
var POST = '';
req.on('data', function (chunk) { POST += chunk;});
req.on('end', function () {
// 执行后端逻辑代码
var i = 0;
});
});
server.listen(9091);
console.log("Server runing at port: 9091.");
4、通过Emq后台来设置规则



5、最后进行调试操作


网友评论