Deno KV 观察

警告：这是一个不稳定的 API，随时可能更改或删除。
Deno KV 观察允许您检测 KV 数据库的更改，从而更轻松地构建实时应用程序、新闻源、聊天等。

打开默认数据库

const kv = await Deno.openKv();

将“counter”值设置为 0，然后每秒递增。

await kv.set(["counter"], new Deno.KvU64(0n));
setInterval(() => {
  kv.atomic().sum(["counter"], 1n).commit();
}, 1000);

监听“counter”的更改并记录值。

for await (const [entry] of kv.watch([["counter"]])) {
  console.log(`Counter: ${entry.value}`);
}

您还可以从 kv.watch 创建一个流读取器，它返回一个 ReadableStream。

const stream = kv.watch([["counter"]]).getReader();
while (true) {
  const counter = await stream.read();
  if (counter.done) {
    break;
  }
  console.log(`Counter: ${counter.value[0].value}`);
}

要使用服务器发送事件，让我们创建一个使用流响应的服务器。每次检测到“counter”的更改时，将更新后的值发送给客户端。

Deno.serve((_req) => {
  const stream = kv.watch([["counter"]]).getReader();
  const body = new ReadableStream({
    async start(controller) {
      while (true) {
        if ((await stream.read()).done) {
          return;
        }
        const data = await kv.get(["counter"]);
        controller.enqueue(
          new TextEncoder().encode(`Counter: ${data.value}\n`),
        );
      }
    },
    cancel() {
      stream.cancel();
    },
  });
  return new Response(body, {
    headers: {
      "Content-Type": "text/event-stream",
    },
  });
});

使用 Deno CLI 在本地运行此示例

deno run --unstable-kv https://docs.deno.org.cn/examples/scripts/kv_watch.ts

Deno KV 观察

其他资源

您找到所需内容了吗？