第 4-7 课:设备分组——设备端实现
在这一节我们来实现设备分组的设备端实现,设备在连接到 IotHub 时,需要主动请求标签数据,在收到来自服务端的标签数据时,需要对比本地存储的标签数据,然后 subscribe 或者 unsubscribe 对应的主题。最后我们会把代码连在一起进行测试。
设备端的持久性存储
由于需要和服务端的标签进行对比,设备需要在本地使用持久性的存储来保存已订阅的标签。一般来说,DeviceSDK 需要根据自身平台的特点来提供存储的接口,这里为了演示起见,我们使用存储 in-flight 消息的 Message Store 所使用的 levelDB 作为 DeviceSDK 的本地存储。这里我们把标签数据的存取进行封装:
//IotHub_Device/sdk/persistent_store.js var level = require(level) class PersistentStore { constructor(dbPath) { this.db = level(`${dbPath}/device_db/`) } getTags(callback) { this.db.get("tags", function (error, value) { if (error != null) { callback({tags: [], tags_version: 0}) } else { callback(JSON.parse(value)) } }) } saveTags(tags) { this.db.put("tags", Buffer.from(JSON.stringify(tags))) } close() {