GraphQL 是一种用于 API 的查询语言，它提供了一种更高效、更强大的方式来描述数据的形状。在 GraphQL 中，我们可以定义一个数据模型并编写查询语句来获取我们需要的数据。而且，GraphQL 还支持实时查询和订阅功能，这使得我们可以实时地获取数据更新并作出相应的响应。在本文中，我们将介绍如何在 GraphQL 中实现实时查询和订阅功能。
实时查询
在 GraphQL 中，我们可以使用订阅器（Subscription）来实现实时查询。订阅器是一种特殊类型的 GraphQL 操作，它允许客户端订阅服务器上的事件，并在事件发生时接收通知。订阅器可以订阅任何类型的事件，例如新消息、新订单、新评论等。
定义订阅器
要定义一个订阅器，我们需要使用 Subscription 类型，并在其中定义订阅操作。下面是一个简单的例子：
type Subscription {
newPost: Post!
}在上面的例子中，我们定义了一个名为 newPost 的订阅操作，它将在新帖子创建时触发，并返回一个 Post 类型的对象。
实现订阅器
要实现订阅器，我们需要使用一个实现了 AsyncIterator 接口的对象。这个接口定义了一个 next 方法，该方法返回一个 Promise，该 Promise 在订阅器有新事件时解析为 { value: T, done?: boolean }，其中 T 是事件的类型。
我们可以使用 PubSub 类来实现订阅器。PubSub 是一个事件发布/订阅的库，它可以让我们在服务器上创建发布者和订阅者。下面是一个简单的例子：
-- -------------------- ---- -------
----- - ------ - - ---------------------------------
----- ------ - --- ---------
----- -------- - -----------
----- --------- - -
------------- -
-------- -
---------- -- -- -------------------------------
--
--
--------- -
----------- ----- --- - ----- -- -- -
----- ---- - ----- ---------------------
------------------------ - -------- ---- ---
------ -----
--
--
--在上面的例子中，我们创建了一个 PubSub 实例，并定义了一个名为 NEW_POST 的常量，该常量用于标识新帖子事件。然后，我们在 Subscription 类型的 newPost 操作中使用 asyncIterator 方法创建了一个订阅器。最后，在 Mutation 类型的 createPost 操作中，我们创建了一个新的帖子并使用 pubsub.publish 方法发布了一个新帖子事件。
使用订阅器
要使用订阅器，我们需要在客户端中使用 subscribe 方法订阅事件。下面是一个使用 Apollo Client 订阅器的例子：
-- -------------------- ---- -------
----- ------------ - ----
------------ -
------- -
--
-----
-------
-
-
--
------------------------ ------ ------------ --------------
----- -- ---- -- -- -
---------------- ------- --------------
--
---在上面的例子中，我们使用 gql 函数定义了一个订阅器，该订阅器订阅了 newPost 事件，并返回了 id、title 和 content 字段。然后，我们使用 Apollo Client 的 subscribe 方法订阅事件，并在收到新事件时打印出新帖子的信息。
实时订阅
除了实时查询，GraphQL 还支持实时订阅。实时订阅是一种允许客户端订阅特定数据的更改的功能。当数据更改时，服务器将向客户端发送通知，并将新数据推送到客户端。
定义实时订阅
要定义一个实时订阅，我们需要使用 Subscription 类型，并在其中定义订阅操作。下面是一个简单的例子：
type Subscription {
postUpdated(id: ID!): Post!
}在上面的例子中，我们定义了一个名为 postUpdated 的订阅操作，它将在帖子更新时触发，并返回一个 Post 类型的对象。
实现实时订阅
要实现实时订阅，我们需要使用 withFilter 方法。withFilter 方法可以用于过滤订阅事件并仅将事件发送给订阅者。下面是一个简单的例子：
-- -------------------- ---- -------
----- - ---------- - - ---------------------------------
----- --------- - -
------------- -
------------ -
---------- -----------
-- -- -----------------------------------
--------- ---------- -- ---------------------- --- -------------
--
--
--
--------- -
----------- ----- --- - --- ----- -- -- -
----- ---- - ----- ---------------------- -------
---------------------------- - ------------ ---- ---
------ -----
--
--
--在上面的例子中，我们在 Subscription 类型的 postUpdated 操作中使用 withFilter 方法创建了一个实时订阅。该订阅订阅了 POST_UPDATED 事件，并在事件满足过滤条件时将事件发送给订阅者。在 Mutation 类型的 updatePost 操作中，我们更新了一个帖子并发布了一个 POST_UPDATED 事件。
使用实时订阅
要使用实时订阅，我们需要在客户端中使用 subscribe 方法订阅事件，并提供订阅所需的变量。下面是一个使用 Apollo Client 实时订阅的例子：
-- -------------------- ---- -------
----- ------------ - ----
------------ ---------------- ---- -
--------------- ---- -
--
-----
-------
-
-
--
------------------------
------ -------------
---------- - --- ----- --
--------------
----- -- ---- -- -- -
----------------- ---------- ------------------
--
---在上面的例子中，我们使用 gql 函数定义了一个实时订阅，该订阅订阅了 postUpdated 事件，并返回了 id、title 和 content 字段。然后，我们使用 Apollo Client 的 subscribe 方法订阅事件，并在收到更新时打印出新的帖子信息。
结论
在本文中，我们介绍了如何在 GraphQL 中实现实时查询和订阅功能。我们首先介绍了如何定义订阅器和实现订阅器，然后介绍了如何使用客户端订阅器订阅事件。接下来，我们介绍了如何定义实时订阅和实现实时订阅，然后介绍了如何使用客户端实时订阅订阅事件。实时查询和实时订阅是 GraphQL 的强大功能，它们可以使我们更轻松地构建实时应用程序。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/675517f81b963fe9cc51eb97