kettle插件-rabbitmq插件

场景：kettle本身可以直接链接rabbitmq，但是需要配置rabbitmq开启mqtt协议，本次讲解下自定义开发组件RabbitMQ consumer，无需开启mqtt协议即可使用。

1、docker 安装rabbitmq

1）下载镜像 docker pull rabbitmq

2）启动服务

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin rabbitmq

3）开启rabbitmq web管理服务，此插件不开启，无法通过web页面访问rabbitmq

docker exec -it rabbitmq rabbitmq-plugins enable rabbitmq_management

4）访问rabbitmq web服务

 5）创建队列xiaojingang

2、将插件kettle-rabbitmq-plugins放到目录plugins目录下，重启spoon客户端。

3、在Streaming目录下找到我们的插件，拖拽到画布，设计简单的trans，如下图所示：

4、RabbitMQ consumer配置

1）链接配置，输入rabbitmq的地址、端口、用户名、密码，如下图所示：

 2）模式配置

输入rabbitmq中的队列为xiaojingang

 5、保存&运行，此插件属于流插件，所以启动之后会一直处于运行状态，如下图所示：

 6、rabbitmq web管理页面手动发送消息，如下图所示：

 7、RabbitMQ consumer插件正常接收到消息，如下图所示：

 Done ！！！