记录一下自己解决这个问题的方法!
一、技术原理
新建一个转发指定数据的资源接口,然后在规则引擎中设置过滤主题消息的规则,筛选出你所需要主题的消息,设置转发的http接口(URL),http请求选择POST或GET请求,要求是在编写servlet接口时与doPost()、doGet()方法对应。servlet接口中的逻辑就是实现对数据库的增删改查操作,当然servlet接口也是部署在云端的!
二、实现步骤
1、新建资源接口:
打开EMQX的后台,新建一个资源,资源类型选择webhook,资源ID可以自己修改也可不改,填写url,这里我是用tomcat服务器部署servlet接口,端口是8080,如果使用其他的服务器部署,请填写该服务器的端口!
2、设置主题消息过滤规则并配置转发的资源接口:
选择规则,点击新建一条规则。在这里需要编写筛选主题消息的SQL语句。
这里的payload是一个消息对象,主题收到的每一条消息都有如下这么多属性,其中我们传输的数据就在payload中,它是json格