本插件可以使用蓝图连接 RabbitMQ服务器,并推送或者监听消息。
下载地址在文章最后。
1. 节点说明
Create RabbitMQ Client - 创建RabbitMQ客户端对象
创建一个RabbitMQ客户端对象,返回的对象需要提升为变量,以后就是用这个对象去操作。
Connect - 链接服务器
链接到RabbitMQ服务器
Host :服务器IP地址。
Port :服务器端口。
User Name :服务器账号。
Password :服务器密码。
Virtual Host :连接到的虚拟主机,默认值为“/”。
Heartbeat :心跳包间隔(单位秒),默认不需要修改。如果需要时时监控网络状态,可以稍微改小一点。
Channel :连接通道ID,默认1就可以了。
Publish - 发送给服务器队列
Channel :连接通道ID,默认1就可以了。
Exchange :推送的交换器名称。
Routing:路由密匙。
Body :发送的字符串消息,可以发送Json字符串。
Bind Message Delegate - 绑定消息回调
Channel :连接通道ID,默认1就可以了。
Queue Name :需要坚挺的的队列名称。
Auto Acknowledges :是否自动确定消息,如果为 false,处理完消息以后需要手动确定消息。
On Rabbit MQ Message:回调函数绑定。
Acknowledges - 消息确认
Channel :连接通道ID,默认1就可以了。
Delivery Tag :需要确认的消息标识,由获取消息回调的时候获得。
Multiple :如果为 true,则确认此传递标记之前的所有消息,如果为 false,则仅确认此传递标记
Disconnect - 断开服务器链接
断开与RabbitMQ服务器的链接,并清空所有消息监听。
Bind Connection Close Delegate - 绑定链接失败回调
在与服务器链接失败或者异常断开的时候,系统会自动回调此事件。
2. 使用案例
3. 下载地址
https://dt.cq.cn/archives/769