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

​
核心功能

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

​
建立连接

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

​
端口配置

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

​
设置选项卡

​
配置

​
AMQP 消息

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

​
高级选项卡

​
其他设置

​
代理设置

这是一组用于识别连接所经代理并对其进行身份验证的设置。默认情况下，本节使用 安全设置 页面的 代理设置 部分中的全局设置。清除此复选框可为您的端口提供特定的设置。

设置描述
代理类型基于代理的防火墙使用的协议。
代理主机基于代理的防火墙的名称或 IP 地址。
代理端口基于代理的防火墙的 TCP 端口。
代理用户用于通过基于代理的防火墙进行身份验证的用户名。
代理密码用于对基于代理的防火墙进行身份验证的密码。
身份验证方案保留默认值 None 或选择以下身份验证方案之一：Basic、Digest、Proprietary 或 NTLM。

​
消息

消息设置确定端口如何搜索消息并在处理后管理它们。

设置描述
保存到已发送文件夹选中此项可将端口处理的文件复制到该端口的“已发送”文件夹中。
已发送文件夹方案端口根据选定的时间间隔对 已发送 文件夹中的文件进行分组。例如，Weekly 选项指示端口每周创建一个新的子文件夹，并将本周发送的所有文件存储在该文件夹中。空白设置告诉端口将所有文件直接保存在 已发送 文件夹中。对于处理许多事务的端口，使用子文件夹可以帮助保持文件有序并提高性能。

​
日志

用于管理日志创建和存储的设置。

设置描述
日志级别指定要记录在端口日志目录中的信息类型：
  • None - 不创建任何日志。
  • Error - 仅当端口遇到错误时才创建日志。
  • Warning - 仅当端口发出警告时才创建日志。
  • Info - 记录工作流的一般信息，包括任何错误和警告（如果适用）。
  • Debug - 记录成功和失败工作流的详细调试信息。
  • Trace - 记录成功和失败工作流的详细跟踪信息。
请注意：Debug 和 Trace 级别的日志可能会记录敏感信息，包括消息内容和 SSL 证书。尽管连接属性（例如密码）被屏蔽了，但在与您的组织外部共享它们之前，请查看此级别的日志以避免泄漏敏感信息。
日志文件夹结构指示端口根据选定的时间间隔将日志文件夹中的文件分组。例如，Weekly 选项指示端口每周创建一个新的子文件夹，并将该周的所有日志存储在该文件夹中。空白设置告诉端口将所有日志直接保存在日志文件夹中。对于处理许多事务的端口，使用子文件夹有助于保持日志的有序性并提高性能。
保留消息副本指示端口在日志目录中保存最新消息副本的切换。请注意，端口每个子文件夹只保留一个消息，并且端口在再次运行时会覆盖以前保存的消息。

​
其他

特殊设置适用于特定用例。

设置描述
其他设置允许在以分号分隔的列表中配置隐藏的端口设置，例如 setting1=value1;setting2=value2。正常的端口用例和功能不需要使用这些设置。

​
自动化选项卡

​
自动化设置

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

​
性能

与端口资源分配相关的设置。

设置描述
最大工作线程数此端口上处理文件时从线程池中消耗的最大工作线程数。如果设置，则会覆盖 高级设置 页面的 性能设置 部分的默认设置。
最大文件数分配给端口的每个线程发送的最大文件数。如果设置，则会覆盖 高级设置 页面的 性能设置 部分的默认设置。

​
警报选项卡

​
SLA 选项卡

​
选择操作

与 AMQP 建立连接后，必须选择 AMQP 端口将执行的操作。下表概述了每个操作及其在 知行之桥 工作流中的位置：

​
Produce

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

​
Consume

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

​
宏

​
示例