1. 概述
1.1 版本
| FineDataLink 版本 | 功能变动 |
|---|---|
| 5.0.0.1 | - |
| 5.0.11.2 | 新增「重试时会话处理方式」 |
1.2 功能简介
数据开发-实时任务支持读取 MQTT 数据源。
2. 准备工作
2.1 前提条件
详情请参见：前提条件
2.2 版本和驱动
下载驱动：
若 FineDataLink 为独立部署的工程，将驱动文件放置到FDL工程安装地址\webapps\webroot\WEB-INF\lib下；放置后，需要重启 FDL 工程。
若 FineDataLink 为 OPS 部署的工程，将驱动文件上传至 FineDataLink 工程外挂目录的 customlib 文件夹下，如忘记工程外挂目录位置，请参考文档查询：导出项目部署信息；放置后，需要重启 FDL 工程。
| 支持的数据库版本 | 驱动 |
|---|---|
| 2.0.18 | org.eclipse.paho.client.mqttv3-1.2.5.jar |
2.3 收集连接信息
在连接该数据源之前，请收集以下信息：
MQTT broker 服务地址。
认证方式（若认证方式为「用户名密码」，需要收集用户名和密码）。
2.4 具体连接步骤
创建数据连接步骤请参见：创建并管理数据源
部分设置项说明：
各设置项说明如下表所示：
| 设置项 | 说明 | ||||
|---|---|---|---|---|---|
| MQTT broker服务地址 | 输入 broker服务地址，比如tcp://localhost:1883 如果有ssl认证，服务地址应该为ssl://localhost:1883 对于没有负载均衡的 MQTT 集群，可以在文本框中输入多个地址，以逗号分隔。例如：比如tcp://hostA:1883,tcp://hostB:1883,tcp://hostC:1883 | ||||
| 认证方式 | 支持两种认证方式：无认证、用户名密码 选择「用户名密码」时，需要填写用户名、密码 | ||||
| 编码 | 支持选择：
| ||||
| 重试时会话处理方式 | 沿用原会话重连： 适用场景：
创建新会话重连：
|
上一篇：配置 Pulsar 数据源
