实时推送

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

建立监听

使用 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();