Appearance

RocketMQ ​

往RocketMQ队列发送消息

业务属性 ​

属性含义说明输入限定示例值
enable是否启用该控件，未启用时不编译是否编译选择值启用
name控件返回值命名控件输出值变量名常量rocketMQ
text与控件关联的文本设计页控件显示常量sendRocketMQMessage
rocketMQ消息队列可选已在资源配置中配置的RocketMQ队列资源选择值myRocketMQ
topictopic名称指定发送消息的topic常量/流程变量topic1
message消息内容发送的消息内容常量，Json数据节点可用流程变量/流程变量{"key":"#{value}"}
tag发送消息的tag设置发送消息的tag，便于消费者对消息进行过滤常量/流程变量tag1
key发送消息的key决定消息发送的队列，保证消息的顺序性常量/流程变量#{key}
delay延迟发送等级常量/流程变量1
throwable发生异常时中断请求启用：控件执行异常时立即中断请求，并返回错误
禁用：控件执行异常时将被忽略，并继续执行其后的流程		选择值启用

输出值 ​

  • 消息发送成功时输出值

控件返回以属性name为名称的实体，该实体包含属性result，并且result为boolean类型的true。

  • throwable为“禁用”，消息发送失败时输出值

控件返回以属性name为名称的实体，该实体包含表示异常信息的属性err（此时属性result为nil）。

使用示例 ​

假设已创建RocketMQ资源，资源名称为：myRocketMQ，需要向主题名称为ExampleTopic发送消息。

发送常量消息 ​

  • RocketMQ控件设置

添加RocketMQ控件并命名为sendResult，属性设置为：

rocketMQ：myRocketMQ； topic：ExampleTopic

message：this is a example message

img_rocketmq_1.png
  • 输出发送结果

添加输出控件Return，data设置为：

json
{
  "sendResult": "#{sendResult}"
}
{
  "sendResult": "#{sendResult}"
}
img_rocketmq_2.png
  • 接口调用

使用curl请求接口：

$ curl http://localhost:6636/api/rocketMQ
$ curl http://localhost:6636/api/rocketMQ

接口返回：

json
{
    "sendResult": {
        "result": true
    }
}
{
    "sendResult": {
        "result": true
    }
}

使用流程变量发送消息 ​

  • RocketMQ控件设置

在前面示例的基础上，修改message属性设置为：

json
{
  "message": "#{body.message}"
}
{
  "message": "#{body.message}"
}
img_rocketmq_3.png
  • 接口调用

使用curl请求接口：

$ curl http://localhost:6636/api/rocketMQ -d "{\"message\":\"This is an example message sent to RocketMQ\"}"
$ curl http://localhost:6636/api/rocketMQ -d "{\"message\":\"This is an example message sent to RocketMQ\"}"

接口返回：

json
{
    "sendResult": {
        "result": true
    }
}
{
    "sendResult": {
        "result": true
    }
}