跳转到主要内容
高级消息队列协议()端口允许通过对数据执行 Produce 和 Consume 操作,将 集成到数据流中。

核心功能

  • 具有生产和消费操作的双向消息队列
  • 支持多种身份验证方案(None、SASL Anonymous、SASL Plain)
  • 支持安全连接的 TLS 加密
  • 灵活的消息值类型,包括对 JSON 复合数据的支持
按照以下步骤将 连接到

建立连接

必须首先通过以下两种方法之一建立到 的连接:
  • 端口添加到工作流。然后,在设置面板中,单击连接下拉列表旁边的 创建
  • 打开 系统设置 页面,然后打开 连接 选项卡。点击 添加,选择 ,然后点击 下一步
  • 仅在第一次创建连接时才需要登录过程。
  • 的连接可以跨多个 端口重复使用。
打开连接对话框后,按照以下步骤操作:
  1. 输入连接信息:
    • 名称 — 连接的静态名称。
    • 类型 — 始终设置为
    • 远程主机地址 远程主机的主机名或 IP 地址。
    • 远程主机端口 — 远程主机连接的端口。
    • 使用 TLS — 是否使用 TLS 加密连接。根据 配置进行设置。
    • 容器 Id —(可选)要访问的 连接中容器的 ID 值。
    • 认证方式 — 用于连接的身份验证方案。选项有 NoneSASL AnonymousSASL Plain
    如果选择 SASL AnonymousSASL Plain 身份验证,请输入以下信息:
    • User — 连接到 时使用的用户名。
    • Password — 用户的密码。
  2. 点击 测试连接 以确保 可以使用提供的信息连接到 。如果发生错误,请检查所有字段并重试。
  3. 点击 添加连接 以完成连接。

端口配置

此部分包含所有可配置的端口属性。

设置选项卡

配置

AMQP 消息

JSON 复合数据值类型
值类型 选项之一是 JSON(复合数据)。复合数据 JSON 架构由 type-value 对象组成,其中包含 AMQP 类型名称和值。type-value 对象的语法为:
下表提供了有效类型名称的完整列表,并描述了相关值的表示方式:
类型名称必须是小写才能正确解析。

高级选项卡

其他设置

代理设置

消息

日志

其他

自动化选项卡

自动化设置

与端口自动处理文件相关的设置。

性能

警报选项卡

SLA 选项卡

选择操作

建立连接后,必须选择 端口将执行的操作。下表概述了每个操作及其在 工作流中的位置:

Produce

Produce 操作将输入数据发送到 连接。此数据可能来自其他端口,也可能来自你手动上传到 端口 交易 选项卡的文件。 在某些 配置中,可以将 目标 字段的值设置为应充当接收者的节点的地址。并非所有配置都需要此项。

Consume

Consume 操作检查 队列中的消息。通过 Consume 端口处理的数据会进入 交易 选项卡,并向下传递到 工作流的后续步骤。 在某些 配置中,可以将 目标 字段的值设置为端口应从中接收数据的节点的地址。并非所有配置都需要此项。

示例