第 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() {
经验分享 程序员 微信小程序 职场和发展