节点功能
消息队列节点支持连接用户自己的消息队列,实现向消息队列中发送消息的功能,消息队列节点属于基础节点。
说明:
消息队列节点仅实现消息的发送,订阅消息队列并消费消息仍需要用户自行开发服务实现。


操作说明
输入变量
输入变量仅在该节点内部生效,不能跨节点使用。点击添加,进行如下配置添加输入变量。
配置 | 说明 |
变量名称 | 该变量的名称,只能包含字母、数字或下划线,并且以字母或下划线开头,必填 |
变量描述 | 该变量的说明信息,非必填 |
数据来源 | 该变量的数据来源,支持“引用”“输入”两种选项。“引用”可选择前序所有节点的输出变量,“输入”可手动填入固定值,必填 |
类型 | 该变量的数据类型,不可选择,默认为引用的变量类型或输入的 string 类型。 |
消息队列类型
消息队列节点支持对接 Kafka(详情请参见 Kafka介绍)和 RocketMQ(详情请参见 RocketMQ介绍)这两种常见的消息队列,每种消息队列的详细配置有区别。用户可以根据业务场景需求选择合适的消息队列。
连接设置
根据用户所选择的消息队列类型配置连接方式,本节点支持了 Kafka、RocketMQ 常见的连接配置信息。
消息内容
消息内容即向消息队列中发送的信息,支持引用该节点的输入变量或手动输入消息内容。
输出变量
消息队列执行消息发送动作后的输出变量。包含消息队列的发送状态 SendStatus、错误信息 ErrorMsg、时间戳 Timestamp、消息大小 MessageSize,以及运行时报错信息 Error(数据类型为 object,正常运行时该字段为空)。


异常处理
可手动开启异常处理,支持异常重试和异常情况的输出内容配置。配置内容如下:
配置 | 说明 |
最大重试次数 | 节点运行异常时重新运行的最大次数。重试超过设定次数,认为该节点调用失败,返回“异常情况的输出变量”内容,默认为3次 |
重试时间间隔 | 每次重新运行的时间间隔,默认为1秒 |
异常处理方式 | 支持“输出特定内容”和“执行异常流程”两种 |
异常情况的输出变量 | 选择异常处理方式为“输出特定内容”时,超过最大重试次数后节点返回的输出变量 |


选择异常处理方式为“执行异常流程”时,则节点异常重试后执行用户自定义的异常处理流程。


应用示例
批量分析社媒文章,针对文章打出相应标签。然后通过消息队列节点将社媒文章分析结果发送到消息队列,其他服务可以通过订阅该消息队列并消费其中的文章分析结果。示例工作流如下:


常见问题
1、消息处理顺序重要吗?如何在工作流中控制?
对于审批、订单处理等有状态依赖的场景,消息顺序非常重要。在工作流中通过编排消息队列节点的前后顺序,以实现控制消息发送顺序。
2、消息格式或内容是否有要求?
工作流消息队列节点提供了消息配置文本框,支持用户任意输出消息内容,对于消息格式没有强制要求。