• 文档
• 数据订阅 SDK 参考

数据订阅 SDK 参考

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

实时数据订阅

订阅Client类：EosClient

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

实时数据订阅服务类：IDataService

函数	函数说明	参数说明	返回
subscribe(IDataHandler dataHandler, String subId)	获取subId订阅的实时数据，使用这个方法的订阅client属于默认的订阅分组	dataHandler: 实时订阅数据处理对象 subId: 云端配置的subId	无
subscribe(IDataHandler dataHandler, String subId, String consumerGroup)	获取subId订阅的实时数据，同时指定订阅分组。具体说明如下： consumerGroup指定了当前订阅client所属的订阅分组 属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力 同一条消息只能被一个订阅分组内的某一个client消费	dataHandler: 实时订阅数据处理对象 subId：云端配置的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: 云端配置的subId	无
subscribe(IAlertHandler alertHandler, String subId, String consumerGroup)	获取subId订阅的告警数据，同时指定订阅分组，具体说明如下： consumerGroup指定了当前订阅client所属的订阅分组 属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力 同一条消息只能被一个订阅分组内的某一个client消费	alertHandler：告警订阅数据处理对象 subId：云端配置的subId consumerGroup：订阅分组名称，与kafka consumerGroup含义相同（如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）	无

订阅数据处理类：IAlertHandler

函数	函数说明	参数说明	返回
alertRead(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: 云端配置的subId	无
subscribe(IDataHandler dataHandler, String subId, String consumerGroup)	获取subId订阅的离线数据，同时指定订阅分组。具体说明如下： consumerGroup指定了当前订阅client所属的订阅分组 属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力 同一条消息只能被一个订阅分组内的某一个client消费	dataHandler: 离线订阅数据处理对象 subId：云端配置的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: 云端配置的subId	无
subscribe(IEventHandler eventHandler, String subId, String consumerGroup)	获取subId订阅的事件数据，同时指定订阅分组，具体说明如下： consumerGroup指定了当前订阅client所属的订阅分组 属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力 同一条消息只能被一个订阅分组内的某一个client消费	eventHandler：事件订阅数据处理对象 subId：云端配置的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: 云端配置的subId	无
subscribe(IReportHandler reportHandler, String subId, String consumerGroup)	获取subId订阅的设备事件上报，同时指定订阅分组。具体说明如下： consumerGroup指定了当前订阅client所属的订阅分组 属于同一个订阅分组的client可共同处理订阅内容，在单个订阅client处理能力有限的情况下，可以通过增加属于同一个订阅分组的client来提升整体订阅数据处理能力 同一条消息只能被一个订阅分组内的某一个client消费	reportHandler: 设备事件上报处理对象 subId：云端配置的subId consumerGroup：订阅分组名称 （如果consumerGroup传null，系统默认使用“DefaultConsumerGroup”作为consumerGroup的值。自行定义时，需避免使用“DefaultConsumerGroup”作为consumerGroup的值）	无

订阅数据处理类：IReportHandler

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