物联网架构成长之路(5)-EMQ插件配置

1. 前言
  上一小结说了插件的创建,这一节主要怎么编写代码,以及具体流程之类的。
2. 增加一句Hello World
  修改 ./deps/emq_plugin_wunaozai/src/emq_plugin_wunaozai.erl 增加一行Hello World

  增加后,保存

1 make clean
2 make
3 cp -r ebin ../../_rel/emqttd/lib/emq_plugin_wunaozai-2.3.1

  这样就把最新版本复制到_rel 目录下了。

  回到eqm-relx 目录

1 ./_rel/emqttd/bin/emqttd console

3. 重新加载/卸载插件

1 ./_rel/emqttd/bin/emqttd_ctl plugins unload emq_plugin_wunaozai
2 ./_rel/emqttd/bin/emqttd_ctl plugins load emq_plugin_wunaozai

  下面是运行效果,可以看见,重新打印Hello World ,表示重新加载了

4. 开启热加载
  启动官方提供的热加载插件,可以通过上面那种./emqttd_ctl 进行加载,或者管理界面加载

  我们重新修改./emq-relx/deps/emq_plugin_wunaozai/src/emq_plugin_wunaozai.erl 把刚才的Hello World 改成 Test Reload.
  然后

1 make clean
2 make
3 cp -r ebin ../../_rel/emqttd/lib/emq_plugin_wunaozai-2.3.1

  然后看emq-relx/_rel/emqttd/log/reloader.log

  下面红框圈住的就是我执行 cp 复制是触发的重新加载。
  注意,如果此时你有看刚才 ./_rel/emqttd/bin/emqttd console 启动后的那个打印,就知道,这个热启动,是没有打印 start wunaozai Test Reload. 这一行信息的。
  通过 ./_rel/emqttd/bin/emqttd_ctl reload emq_plugin_wunaozai 这个命令,也是只打印log/reloader.log 日志,而不触发load事件。
  而通过

1 ./_rel/emqttd/bin/emqttd_ctl plugins unload emq_plugin_wunaozai
2 ./_rel/emqttd/bin/emqttd_ctl plugins load emq_plugin_wunaozai 

  或者在 web控制台,

  点击stop 然后start 就会打印 Test Reload. 触发load事件

5. 说明
  通过上述说明一个事,就是在开发过程中, 可以先用console模式开启EMQ服务,然后开启热加载模块插件,然后在emq-relx/deps 写插件代码,然后通过脚本make clean && make && cp 把插件拷贝到运行环境中。Erlang 是支持热部署的。

原文地址:https://www.cnblogs.com/wunaozai/p/8137619.html

时间: 2024-08-01 14:54:25

物联网架构成长之路(5)-EMQ插件配置的相关文章

物联网架构成长之路(4)-EMQ插件创建

1. 说明 以下用到的知识,是建立在我目前所知道的知识领域,以后如果随着知识的拓展,不一定会更新内容.由于不是EMQ公司的人,EMQ的文档又很少,很多知识点都是靠猜的.2. 一些资料 架构设计 http://emqtt.com/docs/v2/design.html 扩展插件 http://emqtt.com/docs/v2/plugins.html  一些自带的插件3. 写插件 经过上一篇博客讲解的,编译_relx后,在deps目录下就会包含了所有依赖包以及插件包,在这个目录下有个emq_pl

物联网架构成长之路(33)-EMQ数据存储到influxDB

一.前言 时隔一年半,技术变化特别快,学习也要跟上才行.以前写过EMQ数据转存问题,当时用了比较笨的方法,通过写插件的方式,把MQTT里面的数据发送到数据库进行存储.当时也是为了学习erlang和emq.现在随着对物联网的深入,也结合实际需求,不停的学习.下面将介绍我实验测试可行的物联网数据分析解决方案.采用的还是开源方案.通过订阅MQTT的根Topic,把所有物联网数据转存到InfluxDB时序数据库,然后通过Grafana进行图表显示.这应该是目前比较流行的方案.二.安装InfluxDB I

物联网架构成长之路(7)-EMQ权限验证小结

1. 前言 经过前面几小节,讲了一下插件开发,这一小节主要对一些代码和目录结构进行讲解,这些都是测试过程中一些个人经验,不一定是官方做法.而且也有可能会因为版本不一致导致差异. 2. 目录结构 这个目录结构整体就是从 emq-plugin-template 复制一份过来的,然后修改. .erlang.mk 这个是编译过程的临时文件,不用管 .git 这个是源代码版本管理,不用管 data 一些系统数据文件,不用管 deps 这个是在make编译的时候,自动下载一些依赖包,不用管 ebin 这个是

物联网架构成长之路(50)-EMQ配置SSL证书,实现MQTTs协议

0. 前言 EMQ是带有SSL功能的,需要进行简单的配置,才能使用.下面就简单说一下如何实现自签证书. 1. 利用OpenSSL签发证书 1 ? cat createCA.sh 2 #/bin/sh 3 # 生成自签名的CA key和证书 4 openssl genrsa -out ca.key 2048 5 openssl req -x509 -new -nodes -key ca.key -sha256 -days 3650 -subj "/CN=www.wunaozai.com"

物联网架构成长之路(0)-目录

一.基础 [http://www.cnblogs.com/wunaozai/p/8067621.html] 物联网架构成长之路(1)-前言 [http://www.cnblogs.com/wunaozai/p/8075640.html] 物联网架构成长之路(2)-脚手架工具准备 [http://www.cnblogs.com/wunaozai/p/8082332.html] 物联网架构成长之路(3)-EMQ消息服务器了解

物联网架构成长之路(56)-SpringCloudGateway+JWT实现网关鉴权

0. 前言 结合前面两篇博客,前面博客实现了Gateway网关的路由功能.此时,如果每个微服务都需要一套帐号认证体系就没有必要了.可以在网关处进行权限认证.然后转发请求到后端服务.这样后面的微服务就可以直接调用,而不需要每个都单独一套鉴权体系.参考了Oauth2和JWT,发现基于微服务,使用JWT会更方便一些,所以准备集成JWT作为微服务架构的认证方式. [https://www.cnblogs.com/wunaozai/p/12512753.html] 物联网架构成长之路(54)-基于Naco

物联网架构成长之路(32)-SpringBoot集成MQTT客户端

一.前言 这里虽然是说MQTT客户端.其实对于服务器来说,这里的一个具有超级权限的MQTT客户端,就可以做很多事情.比如手机APP或者网页或者第三方服务需要发送数据到设备,但是这些又不是设备,又不能让他们连到MQTT.那么就可以通过HTTP请求业务服务器.然后由业务服务器利用这个MQTT客户端进行发送数据. 还有,之前好多人问我,怎么保存这些物联网数据,真的要像前面的博客那样,要自己写插件吗?特别麻烦的啊.这里给出的结论是不需要.保存数据,除了写EMQ插件,还可以在EMQ的规则引擎上进行配置We

物联网架构成长之路(2)-脚手架工具准备

0. 说明 开始搞服务器了,总要准备几个专业一点的Linux工具,不然给人看起来不是很专业的样子.这一小节,只是简单的举例几个小工具,主要是保存一些配置文件,方便以后查看.后期心情好的话,就在以后遇到好的工具,在这里进行更新. 1. Oh-my-zsh 一般搞服务器都是在Linux上的,默认的shell不是很好用,自己一点一点的配置又有点麻烦,那就直接用这个现成的,安装后就可以使用了,这段时间用起来还算比较方便的. https://github.com/robbyrussell/oh-my-zs

物联网架构成长之路(35)-利用Netty解析物联网自定义协议

一.前言 前面博客大部分介绍了基于EMQ中间件,通信协议使用的是MQTT,而传输的数据为纯文本数据,采用JSON格式.这种方式,大部分一看就知道是熟悉Web开发.软件开发的人喜欢用的方式.由于我也是做web软件开发的,也是比较喜欢这种方式.阿里的物联网平台,也是推荐这种方式.但是,但是做惯硬件开发,嵌入式开发就比较喜欢用裸TCP-Socket连接.采用的是二进制协议.基于此大部分应用场合为了兼容旧设备,就需要单独开发一个TCP服务器的网关.这里使用以前学过的,也是比较流行的Netty框架. 话不