实时推送
云开发数据库支持监听集合中符合查询条件的数据的更新事件。
#
建立监听使用 watch()
方法即可建立监听,并且返回 watcher
对象,用于关闭监听。
符合条件的文档有任何变化,都会触发 onChange
回调。
- Web
- 小程序
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); } });
// 1. 获取数据库引用const db = wx.cloud.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()
即可关闭监听。
- Web
- 小程序
watcher.close();
watcher.close();