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