Appearance
Queue流程
流程是所有控件的基类容器，其余控件不允许单独拖拽至空白画布中，需要先将Queue流程拖拽至画布中，然后再将组件拖拽至Queue流程中。
一个Queue流程即为一个队列消费者程序。
队列消费者主要负责读取并处理队列消息。
业务属性
| 属性 | 含义 | 说明 | 输入限定 | 示例 |
|---|---|---|---|---|
| text | 与控件关联的文本 | 设计页控件显示 | 常量 | QueueFlow |
| queueType | 队列类型 | 目前仅支持RocketMQ | 选择值 | RocketMQ |
| rocketMQ | 消息队列 | 可选已在资源配置中配置的消息队列资源 | 选择值 | my_rocketmq |
| consumerGroup | 消费者分组 | 指定消费者分组 | 常量 | group1 |
| topic | topic名称 | 指定消费消息的topic | 常量 | topic1 |
| reconsume_times | 最大重试次数 | 默认3 | 常量 | 3 |
输入参数
消费消息会自动赋值到变量message，可在流程中直接引用。
使用示例
假设需要创建一个队列消费者，获取队列消息，并插入到数据库中
已配置的队列资源名为myRocketMQ，消费分组和消费主题为group1和topic1
- Queue流程设置
选择消费队列类型为RocketMQ，消费队列资源选择myRocketMQ
输入消费组和主题为group1和topic1
- 插入消息到数据库
假设已存在表，表字段只有
message_time和message，代表消息时间和消息内容
添加数据库操作控件，使用消息变量message插入表
ExecuteSQL控件的使用方法请参照ExecuteSQL控件说明文档
- 创建发送RocketMQ消息的http服务
创建一个新的http接口，添加RocketMQ控件，发送消息This is a example message
RocketMQ控件的使用方法请参照RocketMQ控件说明文档
- 调用RocketMQ发送消息的http服务
将上述两个流程打包并部署到引擎端后，对RocketMQ发送消息的http接口进行调用。
使用curl请求接口：
$ curl http://localhost:6636/api/rocketMQ$ curl http://localhost:6636/api/rocketMQ请求接口前表数据为空，请求接口后查询表数据：
