本文共 640 字，大约阅读时间需要 2 分钟。

从这一节我们开始开发EMQ X插件：emqx-rabbitmq-hook。

和前面说的一样， emqx-rabbitmq-hook 插件会在一些事件发生时，比如设备连接、发布消息时，将事件的数据发送到 RabbitMQ 指定的 exchange 中。

在这一节中，我们会搭建 emqx-rabbitmq-hook 插件的代码框架，并实现第一个功能，在设备连接时将连接事件的信息发送到相应的 RabbitMQ exchange 中去。

代码结构

在开发的时候我们可以直接在 emqx-rel/deps 创建一个目录 emqx_rabbitmq_hook 来存放 emqx-rabbitmq-hook 插件的代码：

初始代码结构基本和 emqx-plugin-template 一致，然后再在这个基础上叠加代码。

最后在emqx-rel/Makefile里添加依赖：

DEPS += emqx_rabbitmq_hook

这样在 make 的时候就会编译 emqx-rabbitmq-hook 插件了。

建立 RabbitMQ 连接和连接池

我们需要在插件启动的时候建立和 RabbitMQ 的连接，同时我们希望用一个连接池对插件的 RabbitMQ 进行管理，第一步是在插件的 Makefile 添加相应的依赖：

## emqx_rabbitmq_hook/MakefileDEPS = lager amqp_client ecpool...dep_lager = git-emqx

转载地址：http://riiti.baihongyu.com/