针对Emq X Broker实现简单的Webhook接口

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

Dashboard

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、最后进行调试操作

手动发送订阅 捕捉订阅消息