如何使用 Graphql SPQR 实现订阅？

Question

如何使用 Graphql SPQR 库实现 GraphQL 的订阅功能？

Answer 1

一般来说，您只需使用@GraphQLSubscription注释一个方法，并确保该方法返回org.reactivestreams.Publisher。例如。

@GraphQLSubscription
public Publisher<Issue> issueStatusChanged(String code) {
    return ...;
}

但实际上，这对你没有多大帮助，除非你已经知道如何获得发布者。

从Java9开始，您可以使用FlowAPI，并使用org.reactivestreams.Flow适配器#toPublisher，您可以将Flow. Publisher转换为org.reactivestreams.Publisher。尽管如此，JDK只有一个内置发布者，SubmissionPublisher，它可能不是您需要的。

相反，使用兼容的库是最容易的，比如RxJava或Spring Reactor。他们使用的类型要么是< code > org . react vestreams . publisher 的直接实例，要么非常容易转换。

对于使用RxJava的示例，您可以从图ql-java看到这个演示项目。或者SPQR的这个测试。但是，这两个都太简单了，无法实际使用。

有关更真实的示例，请参阅SPQR Spring Boot Starter项目的演示。它使用Spring Reactor，无论您是否使用Spring，都可以使用它。该示例在每次相关变异运行时发布更新。

现在，创建一个< code >发布者只是问题的一半。您需要有一种方法将更新发送到客户端。此外，客户机和服务器需要就它们用来交换消息的协议达成一致(新的结果、遇到的任何错误以及控制消息)。目前，只有一个广泛使用的协议存在——Apollo graph QL-ws协议。它基于WebSockets。

版本0.0.3的SPQR Spring Boot启动程序实现了该协议，因此它可以开箱即用地与Apollo客户端一起使用。当然也可以使用其他兼容的客户端，例如GraphQL Playground。

即使您根本不想使用 SPQR Spring Boot Starter 或 Spring，您仍然可以从那里的示例学习如何实现服务器。至于客户端，任何阿波罗教程都会让你开始。你可以在测试和开发期间使用 GraphQL Playground（GraphiQL 目前不支持订阅）。