跳到主要内容

实时推送

云开发数据库支持监听集合中符合查询条件的数据的更新事件。

建立监听#

使用 watch() 方法即可建立监听,并且返回 watcher 对象,用于关闭监听。

符合条件的文档有任何变化,都会触发 onChange 回调。

const cloudbase = require("@cloudbase/js-sdk");
const app = cloudbase.init({  env: "xxxx"});// 1. 获取数据库引用var db = app.database();
const watcher = db  .collection("todos")  .where({    // query...  })  .watch({    onChange: function (snapshot) {      console.log("snapshot", snapshot);    },    onError: function (err) {      console.error("the watch closed because of error", err);    }  });

关闭监听#

调用 watcher.close() 即可关闭监听。

watcher.close();