数据订阅 SDK 参考¶
数据订阅Java SDK的相关函数参考文档如下:
实时数据订阅¶
订阅Client类:EosClient¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
EosClient(String host, int port, String accessKey, String secretKey) | 构造函数 |
|
EosClient实例 |
getDataService() | 获取基础告警数据订阅服务实例 | 无 | IDataService实例 |
getAdvancedAlertService() | 获取高级告警数据订阅服务实例 | 无 | IAdvancedAlertService实例 |
实时数据订阅服务类:IDataService¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
subscribe(IDataHandler dataHandler, String subId) | 获取subId订阅的实时数据,使用这个方法的订阅client属于默认的订阅分组 |
|
无 |
subscribe(IDataHandler dataHandler, String subId, String consumerGroup) | 获取subId订阅的实时数据,同时指定订阅分组。具体说明如下:
|
|
无 |
订阅数据处理类:IDataHandler¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
dataRead(StreamMessage message) | 读取实时订阅数据函数 | message:实时订阅数据 | 无 |
告警数据订阅¶
订阅Client类:EosClient¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
EosClient(String host, int port, String accessKey, String secretKey) | 获取构造函数 |
|
EosClient实例 |
getAlertService() | 获取告警数据订阅服务实例 | 无 | IAlertService实例 |
基础告警数据订阅服务类:IAlertService¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
subscribe(IAlertHandler alertHandler, String subId) | 获取subId订阅的告警数据,使用这个方法的订阅client属于默认的订阅分组 |
|
无 |
subscribe(IAlertHandler alertHandler, String subId, String consumerGroup) | 获取subId订阅的告警数据,同时指定订阅分组,具体说明如下:
|
|
无 |
基础订阅数据处理类:IAlertHandler¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
alertRead(Alert alert) | 读取告警订阅数据函数 | alert:告警订阅数据 | 无 |
高级告警数据订阅服务类:IAdvancedAlertService¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
subscribe(IAdvancedAlertHandler alertHandler, String subId) | 获取subId订阅的告警数据,使用这个方法的订阅client属于默认的订阅分组 |
|
无 |
subscribe(IAdvancedAlertHandler alertHandler, String subId, String consumerGroup) | 获取subId订阅的告警数据,同时指定订阅分组,具体说明如下:
|
|
无 |
高级订阅数据处理类:IAdvancedAlertHandler¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
AdvancedAlertRead(Alert alert) | 读取高级告警订阅数据函数 | alert:高级告警订阅数据 | 无 |
离线数据订阅(EnOS Cloud 特有)¶
订阅Client类:EosClient¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
EosClient(String host, int port, String accessKey, String secretKey) | 构造函数 |
|
EosClient实例 |
getOfflineDataService() | 获取离线数据订阅服务实例 | 无 | IDataService实例 |
离线数据订阅服务类:IDataService¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
subscribe(IDataHandler dataHandler, String subId) | 获取subId订阅的离线数据,使用这个方法的订阅client属于默认的订阅分组 |
|
无 |
subscribe(IDataHandler dataHandler, String subId, String consumerGroup) | 获取subId订阅的离线数据,同时指定订阅分组。具体说明如下:
|
|
无 |
订阅数据处理类:IDataHandler¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
dataRead(StreamMessage message) | 读取离线订阅数据函数 | message:离线订阅数据 | 无 |
事件数据订阅¶
订阅Client类:EosClient¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
EosClient(String host, int port, String accessKey, String secretKey) | 构造函数 |
|
EosClient实例 |
getEventService() | 获取事件数据订阅服务实例 | 无 | IEventService实例 |
事件数据订阅服务类:IEventService¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
subscribe(IEventHandler eventHandler, String subId) | 获取subId订阅的事件数据,使用这个方法的订阅client属于默认的订阅分组 |
|
无 |
subscribe(IEventHandler eventHandler, String subId, String consumerGroup) | 获取subId订阅的事件数据,同时指定订阅分组,具体说明如下:
|
|
无 |
订阅数据处理类:IEventHandler¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
eventRead(Event event) | 读取事件订阅数据函数 | event:事件订阅数据 | 无 |
设备事件上报订阅(EnOS Cloud 特有)¶
订阅Client类:EosClient¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
EosClient(String host, int port, String accessKey, String secretKey) | 构造函数 |
|
EosClient实例 |
getReportService() | 获取设备事件上报服务实例 | 无 | IReportService实例 |
设备事件上报服务类:IReportService¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
subscribe(IReportHandler reportHandler, String subId) | 获取subId订阅的设备事件上报,使用这个方法的订阅client属于默认的订阅分组 |
|
无 |
subscribe(IReportHandler reportHandler, String subId, String consumerGroup) | 获取subId订阅的设备事件上报,同时指定订阅分组。具体说明如下:
|
|
无 |
订阅数据处理类:IReportHandler¶
函数 | 函数说明 | 参数说明 | 返回 |
---|---|---|---|
eventRead(Report message) | 读取设备事件上报函数 | message:展示设备事件上报信息 | 无 |