GraphQL(二)Spring boot + Netflix DGS

简介: Spring boot + Netflix Domain Graph Service(DGS) + Apollo FederationNetflix DGS根据GraphQl schema及对应实体类,加载模式并结合DataFetcher将对象的字段进行绑定,执行相应的逻辑

Netflix Domain Graph Service(DGS)是在Netflix内部创建的一个新的开放源代码框架,该框架简化并帮助了使用GraphQL实现Spring Boot应用程序。

GraphQL(一)基础介绍及应用示例

shcema

与创建关系数据库的表结构一样,我们将对GraphQL进行相同的操作,即创建schema。我们创建的必须位于以下路径/src/main/resources/schema中,并且在此路径中,Netflix DGS将负责加载模式。

对于每个模式,我们创建了一个扩展名为graphqls的不同文件。其中有一个QueryResolver类型,它将具有两个不同的搜索,以及一个MutationResolver以便能够在数据库中创建对象。
创建3个不同的方案,帐户,用户和银行:

type QueryResolver {
   
   
    users: [User]
    user(id: ID!): User!
}

type MutationResolver {
   
   
    createUser(user: UserInput!): User
}

input UserInput {
   
   
    firstName: String!
    lastName: String!
    address: String!
    country: String!
    city: String!
    age: Int
}

type User {
   
   
    id: ID!
    firstName: String!
    lastName: String!
    address: String!
    country: String!
    city: String!
    age: Int!
    bank: Bank
    accounts: [Account]
}

schema {
   
   
    query: QueryResolver
    mutation: MutationResolver
}

实体类

@AllArgsConstructor
@NoArgsConstructor
@Getter
@Setter
public class UserInput {
   
   

    private String firstName;

    private String lastName;

    private int age;

    private String address;

    private String country;

    private String city;
}

定义好schema,并创建好对应的实体类,Netflix DGS将负责加载模式。结合下述的DataFetcher即可将对象的字段绑定,执行相应的逻辑

DataFetcher

DataFetcherGraphQL Java服务器中是一个非常重要的概念,在执行查询时,通过Datafetcher获取一个字段的数据。也就是说我们需要为querymutation中定义的方法,以及对定义的对象中的字段绑定一个DataFetcher实现,这样在GraphQL执行语法后才能通过绑定的DataFetcher执行相应的逻辑。

Netflix已经创建了它的基于注释的DGS框架,该框架由Spring Boot支持,能简化DataFetcher的使用。下面为DGS框架的基本注释:

  • @DgsComponent:此注释负责指示类将要执行查询,DataFetcher类应在定义中带有此注释。
  • @DgsData:每个带有逻辑以执行查询的方法都必须使用@DgsData进行注释。我们将在其中添加父类型的位置,这是架构的类型以及在架构中定义的字段。
  • @InputArgument:用于定义在查询中作为参数传递的参数。
  • @DgsQueryparentTypeQuery@DgsData的缩写。
  • @DgsMutationparentTypeMutation@DgsData的缩写。

使用DGS能够通过实现DgsCustomContextBuilder类来创建自己的上下文。可以使用它来记录或存储状态,或保存一些通过DataFetchingEnvironment类访问的信息。

在示例类UserQuery中,可以看到DataFetchingEnvironment的用法

@DgsComponent
@RequiredArgsConstructor
public class UserQuery {
   
   

    private final UserRepository userRepository;
    private final CustomContextBuilder contextBuilder;

    @DgsData(parentType = "QueryResolver", field = "users")
    public Iterable<User> findAll(DgsDataFetchingEnvironment dfe) {
   
   
        var users = (List<User>) userRepository.findAll();
        contextBuilder.customContext(users, null, null).build();
        return users;
    }

    @DgsData(parentType = "QueryResolver", field = "user")
    public User findById(@InputArgument("id") String id, DataFetchingEnvironment dfe) {
   
   
        CustomContext customContext = DgsContext.getCustomContext(dfe);
        var users = customContext.getUsers();
        if (null != users) {
   
   
            var user = users.stream().filter(u -> u.getId().equals(UUID.fromString(id))).findFirst();
            return user.orElseGet(() -> userRepository.findById(UUID.fromString(id)).orElseThrow(DgsEntityNotFoundException::new));
        } else {
   
   
            return userRepository.findById(UUID.fromString(id)).orElseThrow(DgsEntityNotFoundException::new);
        }
    }
}

Apollo Federation

Apollo FederationGraphQL API组合成一个统一的超图(supergraph)

在联合架构中,您的各个 GraphQL API 被称为subgraphs ,它们被组合成一个supergraph。通过查询您的超图,客户端可以同时查询您的所有子图:

在这里插入图片描述

网关充当您的超图的公共访问点。它接收传入的1GraphQL1操作并智能地将它们分布在您的子图中。对于客户端来说,这看起来与查询任何其他GraphQL服务器完全相同——不需要特殊配置。
Apollo Federation可以做到,通过网关将多个graphql对外输出成一个,客户端即可通过一次请求获取多个业务线的所有Graphql

Apollo Federation目前不支持GraphQL 订阅操作

优化思路

  1. 优化关注数量获取。如果已经拿过关注列表,就从关注列表中获取关注总数

参考资料:

  1. GraphQL
  2. graphql-java-tools
  3. GraphQL Java从入门到实践
  4. DGS框架
  5. Spring Boot和Netflix DGS的GraphQL源码案例
  6. Apollo Federation
相关文章
|
3月前
|
Cloud Native Java 对象存储
面向未来的架构设计:Spring Cloud和Netflix OSS在云原生环境下的发展趋势
展望未来,随着5G、边缘计算等新技术的兴起,微服务架构的设计理念将会更加深入人心,Spring Cloud和Netflix OSS也将继续引领技术潮流,为企业带来更为高效、灵活且强大的解决方案。无论是对于初创公司还是大型企业而言,掌握这些前沿技术都将是在激烈市场竞争中脱颖而出的关键所在。
71 0
|
3月前
|
Java 对象存储 开发者
解析Spring Cloud与Netflix OSS:微服务架构中的左右手如何协同作战
Spring Cloud与Netflix OSS不仅是现代微服务架构中不可或缺的一部分,它们还通过不断的技术创新和社区贡献推动了整个行业的发展。无论是对于初创企业还是大型组织来说,掌握并合理运用这两套工具,都能极大地提升软件系统的灵活性、可扩展性以及整体性能。随着云计算和容器化技术的进一步普及,Spring Cloud与Netflix OSS将继续引领微服务技术的发展潮流。
70 0
|
5月前
|
前端开发 Java API
Spring Boot与GraphQL的集成
Spring Boot与GraphQL的集成
|
5月前
|
Java API 开发者
如何在Spring Boot中使用GraphQL
如何在Spring Boot中使用GraphQL
|
2月前
|
Cloud Native Java 对象存储
面向未来的架构设计:Spring Cloud和Netflix OSS在云原生环境下的发展趋势
面向未来的架构设计:Spring Cloud和Netflix OSS在云原生环境下的发展趋势
55 1
|
2月前
|
监控 Java 对象存储
监控与追踪:如何利用Spring Cloud Sleuth和Netflix OSS工具进行微服务调试
监控与追踪:如何利用Spring Cloud Sleuth和Netflix OSS工具进行微服务调试
50 1
|
2月前
|
安全 Java 对象存储
安全性考量:Spring Security与Netflix OSS在微服务安全中的作用
安全性考量:Spring Security与Netflix OSS在微服务安全中的作用
50 1
|
3月前
|
Java 开发工具 对象存储
简化配置管理:Spring Cloud Config与Netflix OSS中的动态配置解决方案
简化配置管理:Spring Cloud Config与Netflix OSS中的动态配置解决方案
57 2
|
3月前
|
消息中间件 Java 对象存储
数据一致性挑战:Spring Cloud与Netflix OSS下的分布式事务管理
数据一致性挑战:Spring Cloud与Netflix OSS下的分布式事务管理
62 2
|
3月前
|
Java 对象存储 开发者
故障隔离与容错处理:Hystrix在Spring Cloud和Netflix OSS中的应用
故障隔离与容错处理:Hystrix在Spring Cloud和Netflix OSS中的应用
63 3