订阅功能入门

这是 GraphQL 库版本 7 的文档。对于长期支持 (LTS) 版本 5，请参考GraphQL 库版本 5 LTS。

本指南介绍了如何在 GraphQL 服务器上开始使用订阅功能。

如果您使用 Apollo Studio，请务必在连接设置中选择 graphql-ws 实现。

订阅可以侦听数据库的更改，包括与 GraphQL 库无关的更改。

启用订阅功能

Neo4j GraphQL 订阅依赖于 Neo4j 数据变更捕获。请务必按照 CDC 文档中描述的步骤操作，以便为您的 Neo4j 实例启用 FULL 模式。

在 GraphQL 服务器上使用订阅之前，您必须通过将 subscriptions 功能传递给 Neo4jGraphQL 来启用它们

new Neo4jGraphQL({
    typeDefs,
    driver,
    features: {
        subscriptions: true
    },
});

设置 @apollo/server 服务器

接下来，下一步是安装以下依赖项

npm i --save ws graphql-ws neo4j-driver @neo4j/graphql express @apollo/server body-parser cors

将以下代码添加到您的 index.js 文件中，以实现一个带订阅功能的简单 @apollo/server 服务器（更多选项请参阅 Apollo 文档）

import { ApolloServer } from "@apollo/server";
import { expressMiddleware } from "@apollo/server/express4";
import { ApolloServerPluginDrainHttpServer } from "@apollo/server/plugin/drainHttpServer";
import bodyParser from 'body-parser';
import cors from "cors";
import { createServer } from "http";
import neo4j from 'neo4j-driver';
import { Neo4jGraphQL } from '@neo4j/graphql';
import { WebSocketServer } from "ws";
import { useServer } from "graphql-ws/lib/use/ws";
import express from 'express';

const typeDefs = `
    type Movie @node {
        title: String
    }

    type Actor @node {
        name: String
    }
    extend schema @subscription
`;

const driver = neo4j.driver("bolt://localhost:7687", neo4j.auth.basic("username", "password"));

const neoSchema = new Neo4jGraphQL({
    typeDefs,
    driver,
    features: {
        subscriptions: true
    },
});

async function main() {
    // Apollo server setup with WebSockets
    const app = express();
    const httpServer = createServer(app);
    const wsServer = new WebSocketServer({
        server: httpServer,
        path: "/graphql",
    });

    // Neo4j schema
    const schema = await neoSchema.getSchema();

    const serverCleanup = useServer(
        {
            schema,
            context: (ctx) => {
                return ctx;
            },
        },
        wsServer
    );

    const server = new ApolloServer({
        schema,
        plugins: [
            ApolloServerPluginDrainHttpServer({
                httpServer
            }),
            {
                async serverWillStart() {
                    return Promise.resolve({
                        async drainServer() {
                            await serverCleanup.dispose();
                        },
                    });
                },
            },
        ],
    });
    await server.start();

    app.use(
        "/graphql",
        cors(),
        bodyParser.json(),
        expressMiddleware(server, {
            context: async ({ req }) => ({ req }),
        })
    );

    const PORT = 4000;
    httpServer.listen(PORT, () => {
        console.log(`Server is now running on http://localhost:${PORT}/graphql`);
    });
}

main();

GraphQL 订阅

在前面的服务器运行后，Movie 和 Actor 可用的订阅已设置。您可以使用以下语句订阅新创建的电影

subscription {
    movieCreated(where: { title: { eq: "The Matrix" } }) {
        createdMovie {
            title
        }
    }
}

这样，任何以匹配标题创建的新电影都将触发订阅。您可以使用以下查询进行尝试

mutation {
    createMovies(input: [{ title: { eq: "The Matrix" } }]) {
        movies {
            title
        }
    }
}
© . All rights reserved.