消息队列节点

最近更新时间:2025-09-09 16:17:42

我的收藏

节点功能

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




操作说明

输入变量

输入变量仅在该节点内部生效,不能跨节点使用。点击添加,进行如下配置添加输入变量。
配置
说明
变量名称
该变量的名称,只能包含字母、数字或下划线,并且以字母或下划线开头,必填
变量描述
该变量的说明信息,非必填
数据来源
该变量的数据来源,支持“引用”“输入”两种选项。“引用”可选择前序所有节点的输出变量,“输入”可手动填入固定值,必填
类型
该变量的数据类型,不可选择,默认为引用的变量类型或输入的 string 类型。

消息队列类型

消息队列节点支持对接 Kafka(详情请参见 Kafka介绍)和 RocketMQ(详情请参见 RocketMQ介绍)这两种常见的消息队列,每种消息队列的详细配置有区别。用户可以根据业务场景需求选择合适的消息队列。

连接设置

根据用户所选择的消息队列类型配置连接方式,本节点支持了 Kafka、RocketMQ 常见的连接配置信息。

消息内容

消息内容即向消息队列中发送的信息,支持引用该节点的输入变量或手动输入消息内容。

输出变量

消息队列执行消息发送动作后的输出变量。包含消息队列的发送状态 SendStatus、错误信息 ErrorMsg、时间戳 Timestamp、消息大小 MessageSize,以及运行时报错信息 Error(数据类型为 object,正常运行时该字段为空)。




异常处理

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



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




应用示例

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




常见问题

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