GraphQL 是一种新型的数据查询语言，它可以帮助开发者更加灵活地对数据进行查询和操作，同时也可以在前端应用中实现实时数据更新。在本文中，我们将会探讨如何使用 GraphQL 来实现实时数据更新，并通过示例代码进行详细解析。
GraphQL 简介
GraphQL 是一种由 Facebook 开发的 API 查询语言，它的主要特点是可以通过一个请求来一次性获取所需的所有数据，而无需像传统的 RESTful API 那样需要多个请求。此外，GraphQL 还支持按需查询和动态查询参数，这些特点使得它在前端开发中越来越受欢迎。
实时数据更新
在前端开发中，实时数据更新是一项非常重要的功能，它可以让应用程序在数据变化时及时更新显示内容，从而提升用户体验。而 GraphQL 利用了它的特性可以轻松地实现实时数据更新。
GraphQL 支持使用 WebSocket 与服务器建立长连接，从而在应用程序中实现事件驱动的数据更新。当数据发生变化时，服务器会主动推送更新通知，而客户端只需要响应相关操作即可。
实现步骤
下面我们来详细讲解如何使用 GraphQL 实现实时数据更新。
第一步：安装依赖
首先我们需要安装所需的依赖：
npm install graphql-subscriptions apollo-server-express subscriptions-transport-ws
其中，graphql-subscriptions 是实现 GraphQL 订阅功能的库，apollo-server-express 是一个基于 Express 的 GraphQL 服务器库，subscriptions-transport-ws 是用于在 WebSocket 中传输消息的库。
第二步：创建 GraphQL Server
接下来我们需要创建一个 GraphQL 服务器，实现订阅和发布功能。在这里我们使用 apollo-server-express 库提供的 ApolloServer 对象来完成。
-- -------------------- ---- -------
----- - ------------ - - ---------------------------------
----- - ------------ - - ----------------
----- - -------- --------- - - -------------------
----- - ------------------ - - --------------------------------------
----- ------- - -------------------
----- - ------ - - --------------------
----- --- - ----------
----- ------ - --- --------------
-------
-------------- -
---------- -- -- ------------------- ------------
------------- -- -- ------------------- ---------------
--
---
------------------------ --- ---
----- ---------- - ------------------
----------------------- -- -- -
------------------- ----- -- ---------------------------------------------
-------------------------- ----- -- -------------------------------------------------
---
----- ------------------ - --------------------------
-
-------
--------
----------
---------- -- -- ------------------- --------- -- ------------
------------- -- -- ------------------- ------------ ---- ------------
--
-
------- -----------
----- -------------------------
-
--在上述代码中，我们先创建了一个 Express 应用程序，并通过 ApolloServer 对象来初始化 GraphQL 服务器，设置了 GraphQL schema 和订阅事件的处理函数。subscriptions 选项用于设置客户端连接和断开事件的处理函数。
接下来我们创建了一个 HTTP 服务器并将 Express 中间件应用到其中。最后，我们使用 SubscriptionServer 对象创建了一个 WebSocket 服务器，并将其连接到 HTTP 服务器上。
第三步：实现订阅操作
下面我们需要在 schema 中定义订阅操作，从而支持客户端的订阅功能。在这里我们以一个简单的示例来说明。
-- -------------------- ---- -------
----- - --- - - ---------------------------------
----- -------- - ----
---- ------------ -
------------- -------
-
--
----- --------- - -
------------- -
------------- -
---------- --- --- - ------ -- -- --------------------------------------
--
--
--
-------------- - - --------- --------- --在上述代码中，我们在 typeDefs 中定义了 messageAdded 订阅操作，它会订阅服务器中的 MESSAGE_ADDED 事件。在 resolvers 中，我们实现了 Subscription 里的 messageAdded 的逻辑，返回了一个 asyncIterator 对象，用于处理订阅更新。
第四步：使用 pubsub 发布更新
最后，我们需要在服务端使用 pubsub 来发布 数据更新 事件。在 Express 应用程序中添加以下代码：
const { PubSub } = require('graphql-subscriptions');
const pubsub = new PubSub();
setInterval(() => {
pubsub.publish('MESSAGE_ADDED', { messageAdded: new Date().toISOString() });
}, 1000);在上述代码中，我们创建了一个 PubSub 对象，并在定时器中每隔 1 秒发布一次 MESSAGE_ADDED 事件，其中事件携带当前的时间戳。
完整示例
下面是一个完整的 GraphQL 实现实时数据更新的示例：
-- -------------------- ---- -------
----- - ------------ - - ---------------------------------
----- - ------------ - - ----------------
----- - -------- --------- - - -------------------
----- - ------------------ - - --------------------------------------
----- - --- - - ---------------------------------
----- - ------ - - ---------------------------------
----- ------- - -------------------
----- -------- - ----
---- ----- -
----- -------
-
---- ------------ -
------------- -------
-
--
----- --------- - -
------ -
----- -- -- -------
--
------------- -
------------- -
---------- --- --- - ------ -- -- -
------ ----------------------------------------
--
--
--
--
----- ------ - --- ---------
-------------- -- -
------------------------------- - ------------- --- -------------------- ---
-- ------
----- --- - ----------
----- ------ - --- --------------
---------
----------
-------------- -
---------- -- -- -
------------------- --------- -- ------------
--
------------- -- -- -
------------------- ------------ ---- ------------
--
--
---
------------------------ --- ---
----- ---------- - ------------------
----------------------- -- -- -
------------------- ----- -- ---------------------------------------------
-------------------------- ----- -- -------------------------------------------------
---
----- ------------------ - --------------------------
-
------- --------------
--------
----------
---------- ---------------- -- -
------ - ------ --
--
------------- -- -- -
------------------- ------------ ---- --------- ---------
--
--
-
------- -----------
----- -------------------------
-
--在以上代码中，我们定义了一个 ping 查询操作和一个 messageAdded 订阅操作，并在服务器中每秒钟发生一次更新。在客户端连接到服务器的时候，可以订阅 messageAdded 事件来监听服务器的实时更新。我们还使用了 Promise 对象来控制订阅中止的时间。
结论
本文介绍了 GraphQL 如何实现实时数据更新的相关知识。在实现过程中，我们首先安装相关依赖，然后创建了 GraphQL 服务器，接着实现订阅操作并使用 pubsub 对象发布更新事件。最后，通过一个完整的示例代码演示了如何在服务端和客户端实现 GraphQL 实时数据更新功能。
GraphQL 的高度灵活性和可扩展性，使得它在前端应用程序的开发中越来越受到开发者的青睐。通过本文的学习，相信读者能够更加深入地了解 GraphQL 的实时数据更新功能，并在实际项目中应用。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6713b49aad1e889fe20f8302