1. 概述
1.1 版本
| FineDataLink版本 | 功能变动 |
|---|---|
| 5.0.4.4 | 实时任务支持读取 RabbitMQ 数据源 |
1.2 功能简介
FineDataLink 支持连接 RabbitMQ，实时任务可使用「RabbitMQ输入」算子，读取该数据源。
2. 准备工作
2.1 前提条件
详情请参见：前提条件
2.2 版本和JAR文件
1）若放置 JAR 文件：「RabbitMQ输入」算子中，会自动获取 RabbitMQ 中的队列。
下载驱动文件后：
若 FineDataLink 为独立部署的工程，将驱动文件放置到 %FDL_home%\webapps\webroot\WEB-INF\lib 下；放置后，需要重启 FDL 工程。
若 FineDataLink 为 OPS 部署的工程，将驱动文件上传至 FineDataLink 工程外挂目录的 customlib 文件夹下
如忘记工程外挂目录位置，请参考文档查询：导出项目部署信息；放置后，需要重启 FDL 工程。
| 支持的数据源版本 | 需要的 JAR 文件 |
|---|---|
RabbitMQ 3.8.X及以上 | http-client-3.12.0.jar spring-beans-5.0.13.RELEASE.jar spring-core-5.0.13.RELEASE.jar |
2）若未放置 JAR 文件：「RabbitMQ输入」算子中，不会自动获取 RabbitMQ 中的队列，需要手动输入。
2.3 具体连接步骤
创建数据连接步骤请参见：创建并管理数据源
部分设置项说明：
各设置项说明如下表所示：
| 设置项 | 说明 |
|---|---|
| RabbitMQ服务地址 | 通过文本框输入broker服务地址，比如amqp://host:5672 如果有SSL/TLS认证，服务地址应该为amqps://host:5671 |
| 认证方式 | 1）支持两种认证方式：无认证、用户名密码 2）选择「用户名密码」时，需要填写用户名、密码；该用户需要具备 AMQP 消息访问权限，还需要创建 HTTP API 的管理权限。若该账号也具备调用 HTTP API 的管理权限，则可填写「API端口」 |
| API端口 | RabbitMQ 管理接口的 HTTP API 端口，用于获取队列元数据等信息 非必填 |
| 虚拟主机 | RabbitMQ 的 Virtual Host（虚拟主机），可用于实现消息隔离，默认为连接 /
单租户虚拟主机默认配置/；多租户/多环境架构需要配置虚拟主机，否则可能导致连接失败、无权限或查不到目标队列。在获取队列、交换机等元数据时，HTTP API 也依赖「虚拟主机」来定位资源。配置「虚拟主机」可以确保连接的目标业务环境正确，避免串环境或读错数据 非必填 |
| 编码 |
|
上一篇：配置IBM MQ数据源
