第 4 章 连接到 AMQP

在集成中，您可以获取信息或从高级消息队列协议(AMQP)代理发布信息。AMQP 定义客户端和消息代理之间的通信。要与以下代理类型通信，请使用 AMQP 连接器创建与感兴趣的代理的连接：

  • 支持 AMQP 的 Apache ActiveMQ 代理
  • Apache ActiveMQ Artemis
  • AMQ 7 代理
  • EnMasse，它是一个开源的管理平台

要与以下代理类型之一通信，请使用 Red Hat AMQ 连接器 创建与感兴趣的代理的连接：

  • 不支持 AMQP 的 Apache ActiveMQ 代理
  • AMQ 6 代理
注意

可使用 AMQP 连接器创建与不支持 AMQP 或 AMQ 6 代理的 Apache ActiveMQ 代理的连接。这样做需要代理中的传输配置。有关配置代理的详情，请参考 Red Hat JBoss A-MQ 管理和监控 Broker，添加客户端连接点。有关要指定配置值的详情，请参考 Red Hat JBoss A-MQ Connection Reference, Advanced Message Queuing Protocol (AMQP)。

要使用 AMQP 连接器，请参阅：

4.1. 创建 AMQP 连接

集成中，若要从 AMQP 代理获取消息或发布消息，可创建 AMQP 连接，您可以将其添加到集成。

先决条件

对于您要连接的 AMQP 代理，您有以下内容：

  • 其 URI
  • 用户帐户凭证
  • 其 PEM 证书文本

流程

  1. 在 Fuse Online 中，在左侧面板中，单击 Connections 以显示任何可用连接。
  2. 点 Create Connection 以显示连接器。
  3. 点 AMQP Message Broker 连接器。

  4. 配置连接：

    1. 在 Connection URI 字段中，输入您要向或获取数据的位置。
    2. 在 User name 字段中，输入您要用来访问此代理的帐户的用户名。
    3. 在 Password 字段中，输入您要用来访问此代理的帐户的密码。
    4. 在 Client ID 字段中，输入允许关闭并重新打开的 ID，而不缺少信息。目的地类型必须是主题。
    5. 如果在开发环境中使用此连接，您可以通过禁用 检查证书 来保存一些时间。禁用检查证书对于开发环境来说比较方便。对于安全生产环境，请始终启用 检查证书。
    6. 在 Broker 证书 字段中，粘贴代理的 PEM 证书文本。除非禁用证书检查，还需要此项。
    7. 在 Client certificate 字段中，粘贴客户端的 PEM 证书文本。此字段中的内容始终是可选的。
  5. 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息，指示验证是否成功。如果验证失败，请根据需要重新传输配置详情，然后重试。
  6. 如果验证成功，请单击 Next。
  7. 在 Name 字段中输入您选择的名称，可帮助您将这个连接与任何其他连接区分开来。例如，您可以输入 AMQP 1。
  8. 在 Description 字段中，输入有助于了解此连接的任何信息。例如，输入 Sample AMQP 连接
  9. 点 Save 查看您创建的连接现在可用。如果您输入了示例名称，您会看到 AMQP 1 显示为可添加到集成的连接。