数据订阅 SDK 参考¶

数据订阅Java SDK的相关函数参考文档如下：

实时数据订阅¶

订阅Client类：EosClient¶

函数	函数说明	参数说明	返回
EosClient(String host, int port, String accessKey, String secretKey)	构造函数	host: 订阅服务端地址 port: 订阅服务端口 accesskey: accessKey secretKey: 对应accesskey的secret	EosClient实例
getDataService()	获取基础告警数据订阅服务实例	无	IDataService实例
getAdvancedAlertService()	获取高级告警数据订阅服务实例	无	IAdvancedAlertService实例

实时数据订阅服务类：IDataService¶

函数

函数说明

参数说明

返回

subscribe(IDataHandler dataHandler, String subId)

获取subId订阅的实时数据，使用这个方法的订阅client属于默认的订阅分组

dataHandler: 实时订阅数据处理对象
subId: EnOS Cloud 配置的subId

无

subscribe(IDataHandler dataHandler, String subId, String consumerGroup)

获取subId订阅的实时数据，同时指定订阅分组。具体说明如下：

consumerGroup指定了当前订阅client所属的订阅分组

属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力

同一条消息只能被一个订阅分组内的某一个client消费

dataHandler: 实时订阅数据处理对象
subId：EnOS Cloud 配置的subId
consumerGroup：订阅分组名称（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）

无

订阅数据处理类：IDataHandler¶

函数	函数说明	参数说明	返回
dataRead(StreamMessage message)	读取实时订阅数据函数	message：实时订阅数据	无

告警数据订阅¶

订阅Client类：EosClient¶

函数	函数说明	参数说明	返回
EosClient(String host, int port, String accessKey, String secretKey)	获取构造函数	host: 订阅服务端地址 port: 订阅服务端口 accesskey: accessKey secretKey: 对应accesskey的secret	EosClient实例
getAlertService()	获取告警数据订阅服务实例	无	IAlertService实例

基础告警数据订阅服务类：IAlertService¶

函数

函数说明

参数说明

返回

subscribe(IAlertHandler alertHandler, String subId)

获取subId订阅的告警数据，使用这个方法的订阅client属于默认的订阅分组

alertHandler：告警订阅数据处理对象
subId: EnOS Cloud 配置的subId

无

subscribe(IAlertHandler alertHandler, String subId, String consumerGroup)

获取subId订阅的告警数据，同时指定订阅分组，具体说明如下：

consumerGroup指定了当前订阅client所属的订阅分组
属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力
同一条消息只能被一个订阅分组内的某一个client消费

alertHandler：告警订阅数据处理对象
subId：EnOS Cloud 配置的subId
consumerGroup：订阅分组名称，与kafka consumerGroup含义相同（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）

无

基础订阅数据处理类：IAlertHandler¶

函数	函数说明	参数说明	返回
alertRead(Alert alert)	读取告警订阅数据函数	alert：告警订阅数据	无

高级告警数据订阅服务类：IAdvancedAlertService¶

函数

函数说明

参数说明

返回

subscribe(IAdvancedAlertHandler alertHandler, String subId)

获取subId订阅的告警数据，使用这个方法的订阅client属于默认的订阅分组

AdvancedAlertHandler：高级告警订阅数据处理对象
subId: EnOS Cloud 配置的subId

无

subscribe(IAdvancedAlertHandler alertHandler, String subId, String consumerGroup)

获取subId订阅的告警数据，同时指定订阅分组，具体说明如下：

consumerGroup指定了当前订阅client所属的订阅分组
属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力
同一条消息只能被一个订阅分组内的某一个client消费

AdvancedAlertHandler：高级告警订阅数据处理对象
subId：EnOS Cloud 配置的subId
consumerGroup：订阅分组名称，与kafka consumerGroup含义相同（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）

无

高级订阅数据处理类：IAdvancedAlertHandler¶

函数	函数说明	参数说明	返回
AdvancedAlertRead(Alert alert)	读取高级告警订阅数据函数	alert：高级告警订阅数据	无

离线数据订阅（EnOS Cloud 特有）¶

订阅Client类：EosClient¶

函数	函数说明	参数说明	返回
EosClient(String host, int port, String accessKey, String secretKey)	构造函数	host: 订阅服务端地址 port: 订阅服务端口 accesskey: accessKey secretKey: 对应accesskey的secret	EosClient实例
getOfflineDataService()	获取离线数据订阅服务实例	无	IDataService实例

离线数据订阅服务类：IDataService¶

函数

函数说明

参数说明

返回

subscribe(IDataHandler dataHandler, String subId)

获取subId订阅的离线数据，使用这个方法的订阅client属于默认的订阅分组

dataHandler: 离线订阅数据处理对象
subId: EnOS Cloud 配置的subId

无

subscribe(IDataHandler dataHandler, String subId, String consumerGroup)

获取subId订阅的离线数据，同时指定订阅分组。具体说明如下：

consumerGroup指定了当前订阅client所属的订阅分组

属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力

同一条消息只能被一个订阅分组内的某一个client消费

dataHandler: 离线订阅数据处理对象
subId：EnOS Cloud 配置的subId
consumerGroup：订阅分组名称（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）

无

订阅数据处理类：IDataHandler¶

函数	函数说明	参数说明	返回
dataRead(StreamMessage message)	读取离线订阅数据函数	message：离线订阅数据	无

事件数据订阅¶

订阅Client类：EosClient¶

函数	函数说明	参数说明	返回
EosClient(String host, int port, String accessKey, String secretKey)	构造函数	host: 订阅服务端地址 port: 订阅服务端口 accesskey: accessKey secretKey: 对应accesskey的secret	EosClient实例
getEventService()	获取事件数据订阅服务实例	无	IEventService实例

事件数据订阅服务类：IEventService¶

函数

函数说明

参数说明

返回

subscribe(IEventHandler eventHandler, String subId)

获取subId订阅的事件数据，使用这个方法的订阅client属于默认的订阅分组

eventHandler：事件订阅数据处理对象
subId: EnOS Cloud 配置的subId

无

subscribe(IEventHandler eventHandler, String subId, String consumerGroup)

获取subId订阅的事件数据，同时指定订阅分组，具体说明如下：

consumerGroup指定了当前订阅client所属的订阅分组
属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力
同一条消息只能被一个订阅分组内的某一个client消费

eventHandler：事件订阅数据处理对象
subId：EnOS Cloud 配置的subId
consumerGroup：订阅分组名称，与kafka consumerGroup含义相同（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）

无

订阅数据处理类：IEventHandler¶

函数	函数说明	参数说明	返回
eventRead(Event event)	读取事件订阅数据函数	event：事件订阅数据	无

设备事件上报订阅（EnOS Cloud 特有）¶

订阅Client类：EosClient¶

函数	函数说明	参数说明	返回
EosClient(String host, int port, String accessKey, String secretKey)	构造函数	host: 订阅服务端地址 port: 订阅服务端口 accesskey: accessKey secretKey: 对应accesskey的secret	EosClient实例
getReportService()	获取设备事件上报服务实例	无	IReportService实例

设备事件上报服务类：IReportService¶

函数

函数说明

参数说明

返回

subscribe(IReportHandler reportHandler, String subId)

获取subId订阅的设备事件上报，使用这个方法的订阅client属于默认的订阅分组

dataHandler: 设备事件上报处理对象
subId: EnOS Cloud 配置的subId

无

subscribe(IReportHandler reportHandler, String subId, String consumerGroup)

获取subId订阅的设备事件上报，同时指定订阅分组。具体说明如下：

consumerGroup指定了当前订阅client所属的订阅分组

属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力

同一条消息只能被一个订阅分组内的某一个client消费

reportHandler: 设备事件上报处理对象
subId：EnOS Cloud 配置的subId
consumerGroup：订阅分组名称（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）

无

订阅数据处理类：IReportHandler¶

函数	函数说明	参数说明	返回
eventRead(Report message)	读取设备事件上报函数	message：展示设备事件上报信息	无