MQ发送
用于向消息队列中发送消息
属性 | 描述 | 是否必填 |
---|---|---|
MQ类型 | 下拉 选项:ActiveMQ,RabbitMQ,RocketMQ,Kafka | 是 |
MQ服务器地址 | 外部服务的完整绝对路径 | 是 |
消息发送方式 | 下拉选项:队列,广播 | 是 |
主题名称 | - | 是 |
发送数据 | 可以是字符串常量,也可以是通过表达式返回的对象,最终发送的数据会转为字符串发送到MQ服务器,如果传入参数是基本类型则直接换为字符类型,如果是对象则转为JSON字符串 | 是 |
出参变量名 | 将该操作的结果通过该变量名设置到服务的上下文中,如可通过ctx.mqOutput来访问 | 是 |
注意事项
1、ActiveMQ,url通过设置为: tcp://ip:port, 如:tpc://192.168.1.1:61616
2、RabbitMQ,url通常设置为: ip:port, 如:192.168.1.1:5672
3、RocketMQ,url通常设置为: ip:port, 如:192.168.1.1:9876
4、Kafka,url通常设置为: ip:port, 如:192.168.1.1:9092