SpringBoot中实现GraphQL订阅的示例代码

<dependency>
    <groupId>com.graphql-java-kickstart</groupId>
    <artifactId>graphql-spring-boot-starter</artifactId>
    <version>11.1.0</version>
</dependency>
<dependency>
    <groupId>com.graphql-java-kickstart</groupId>
    <artifactId>graphql-java-tools</artifactId>
    <version>11.1.0</version>
</dependency>

package cn.juwatech.graphql;

import cn.juwatech.data.SomeDataService;
import com.coxautodev.graphql.tools.GraphQLQueryResolver;
import com.coxautodev.graphql.tools.GraphQLSubscriptionResolver;
import org.reactivestreams.Publisher;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class GraphQLResolver implements GraphQLQueryResolver, GraphQLSubscriptionResolver {

    private final SomeDataService someDataService;

    @Autowired
    public GraphQLResolver(SomeDataService someDataService) {
        this.someDataService = someDataService;
    }

    public String hello() {
        return "Hello, GraphQL!";
    }

    public Publisher<String> newData() {
        return someDataService.getDataStream();
    }
}

package cn.juwatech.data;

import org.springframework.stereotype.Component;
import reactor.core.publisher.Flux;

import java.time.Duration;

@Component
public class SomeDataService {

    public Flux<String> getDataStream() {
        // 模拟数据流，每秒生成一个新的数据
        return Flux.interval(Duration.ofSeconds(1))
                .map(sequence -> "Data " + sequence);
    }
}

package cn.juwatech.config;

import graphql.kickstart.tools.SchemaParser;
import graphql.kickstart.tools.SchemaParserOptions;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GraphQLConfig {

    @Bean
    public SchemaParserOptions schemaParserOptions() {
        return SchemaParserOptions.newOptions()
                .build();
    }

    @Bean
    public SchemaParser schemaParser(SchemaParserOptions options) {
        return SchemaParser.newParser()
                .schemaString("schema.graphqls")
                .options(options)
                .build();
    }
}

type Query {
    hello: String
}

type Subscription {
    newData: String
}