Moralis 实时查询

标准连接

我们维护一个 WebSocket 连接以与 Moralis LiveQuery 服务器进行通信。 在服务器端使用时,我们使用 ws 包,在浏览器中使用 window.WebSocket。 我们认为在大多数情况下,没有必要直接处理 WebSocket 连接。 因此,我们开发了一个简单的 API,让您专注于自己的业务逻辑。

创建订阅

let query = new Moralis.Query(Game);
let subscription = await query.subscribe();

你得到的订阅实际上是一个事件发射器。 有关事件发射器的更多信息,请查看此处。 您将通过此订阅获得 LiveQuery 事件。 当您第一次调用 subscribe 时,我们将尝试为您打开与 LiveQuery 服务器的 WebSocket 连接。

事件处理

我们定义了几种类型的事件,您将通过订阅对象获得:

打开事件

subscription.on(open, () => {
 console.log(subscription opened);
});

当您调用 ​query.subscribe()​ 时,我们会向 LiveQuery 服务器发送一个订阅请求。 当我们从 LiveQuery 服务器获得确认时,将发出此事件。

当客户端无法维护 WebSocket 连接并与 LiveQuery 服务器断开连接时,我们将尝试自动重新连接 LiveQuery 服务器。 如果我们重新连接 LiveQuery 服务器并成功重新订阅 MoralisQuery,您也会收到此事件。

创建事件

subscription.on(create, (object) => {
  console.log(object created);
});

当创建一个新的 MoralisObject 并满足您订阅的 MoralisQuery 时,您将收到此事件。 该对象是创建的 MoralisObject。

注意:在新的 Nitro 服务器上,对于自动同步的表(例如同步事件),将使用更新而不是创建。

更新事件

subscription.on(update, (object) => {
  console.log(object updated);
});

当现有 MoralisObject 满足 MoralisQuery 时,您的订阅会更新(MoralisObject 在更改前后满足 MoralisQuery),您将收到此事件。 该对象是已更新的 MoralisObject。 它的内容是 MoralisObject 的最新值。

进入事件

subscription.on(enter, (object) => {
  console.log(object entered);
});

当现有 MoralisObject 的旧值不满足 MoralisQuery 但其新值满足 MoralisQuery 时,您将收到此事件。 对象是进入 MoralisQuery 的 MoralisObject。 它的内容是 MoralisObject 的最新值。

离开事件

subscription.on(leave, (object) => {
  console.log(object left);
});

当现有 MoralisObject 的旧值满足 MoralisQuery 但其新值不满足 MoralisQuery 时,您将收到此事件。 对象是离开 MoralisQuery 的 MoralisObject。 它的内容是 MoralisObject 的最新值。

删除事件

subscription.on(delete, (object) => {
  console.log(object deleted);
});

当满足 MoralisQuery 的现有 MoralisObject 被删除时,您将收到此事件。 对象是被删除的 MoralisObject。

关闭事件

subscription.on(close, () => {
  console.log(subscription closed);
});

当客户端失去与 LiveQuery 服务器的 WebSocket 连接并且我们无法获得更多事件时,您将获得此事件。

退订

subscription.unsubscribe();

如果您想停止接收来自 MoralisQuery 的事件,您只需取消订阅即可。 之后,您将不会从订阅对象中获得任何事件。

关闭

Moralis.LiveQuery.close();

使用完 LiveQuery 后,您可以调用 ​Moralis.LiveQuery.close()​。 此函数将关闭与 LiveQuery 服务器的 WebSocket 连接,取消自动重新连接,并取消订阅所有基于它的订阅。 如果在此之后调用 ​query.subscribe()​,我们将创建一个到 LiveQuery 服务器的新 WebSocket 连接。

设置服务器 URL

Moralis.liveQueryServerURL = ws://XXXX

大多数情况下,您不需要手动设置它。 如果您设置了 ​Moralis.serverURL​,我们将尝试提取主机名并使用 ws://hostname 作为默认的 liveQueryServerURL。 但是,如果您想定义自己的 liveQueryServerURL 或使用不同的协议(例如 wss),则应自行设置。

WebSocket 状态

我们公开了三个事件来帮助您监控 WebSocket 连接的状态:

打开事件

Moralis.LiveQuery.on(open, () => {
  console.log(socket connection established);
});

当我们与 LiveQuery 服务器建立 WebSocket 连接时,您将收到此事件。

关闭事件

Moralis.LiveQuery.on(close, () => {
  console.log(socket connection closed);
});

当我们失去与 LiveQuery 服务器的 WebSocket 连接时,您将收到此事件。

错误事件

Moralis.LiveQuery.on(error, (error) => {
  console.log(error);
});

当发生网络错误或 LiveQuery 服务器错误时,您将收到此事件。

重新连接

由于整个 LiveQuery 功能依赖于与 LiveQuery 服务器的 WebSocket 连接,因此我们总是尝试保持打开的 WebSocket 连接。

因此,当与 LiveQuery 服务器的连接丢失时,我们会尝试自动重新连接。 我们在引擎盖下做指数回退。

但是,如果 WebSocket 连接由于 ​Moralis.LiveQuery.close()​ 或 ​client.close()​ 而关闭,我们将取消自动重新连接。

SessionToken

当您订阅 MoralisQuery 时,我们会将 ​sessionToken ​发送到 LiveQuery 服务器。 对于标准 API,我们默认使用当前用户的 ​sessionToken​。 对于高级 API,您可以在订阅 MoralisQuery 时使用任何 ​sessionToken​。 需要注意的重要一点是,当您注销或您使用的 ​sessionToken ​无效时,您应该取消订阅并重新订阅 MoralisQuery。 否则,您可能会遇到安全问题,因为您会收到不应该发送给您的事件。

使用 Moralis.Query.or 和两个查询的示例

let query1 = new Moralis.Query(test_subscription);
let query2 = new Moralis.Query(test_subscription);
query1.equalTo(a, undefined)
query2.equalTo(a, 10)
mainQuery = Moralis.Query.or(query1, query2);
let subscription = await mainQuery.subscribe();
subscription.on(create, (object) => {
  console.log(object created, object);
});
subscription.on(update, (object) => {
  console.log(object updated, object);
});

作者:唐伯虎点蚊香,如若转载,请注明出处:https://www.web176.com/moralis/25980.html

(0)
打赏 支付宝 支付宝 微信 微信
唐伯虎点蚊香的头像唐伯虎点蚊香
上一篇 2023年10月14日
下一篇 2023年10月14日

相关推荐

发表回复

登录后才能评论