Golang dig框架与GraphQL的完美结合

news2025/6/12 22:28:04

将 Go 的 Dig 依赖注入框架与 GraphQL 结合使用，可以显著提升应用程序的可维护性、可测试性以及灵活性。

Dig 是一个强大的依赖注入容器，能够帮助开发者更好地管理复杂的依赖关系，而 GraphQL 则是一种用于 API 的查询语言，能够提供更高效、灵活的数据查询方式。

将 Dig 与 GraphQL 完美结合的详细指南，包括架构设计、实现步骤以及最佳实践。

1. 架构设计

1.1 核心组件

  • GraphQL Server：处理客户端的查询和变更请求。
  • Resolver：解析 GraphQL 查询并返回相应的数据。
  • 依赖注入容器（Dig）：管理 Resolver 和其他服务的依赖关系。
  • 服务层：包含业务逻辑和数据访问逻辑。
  • 数据源：如数据库、第三方 API 等。

1.2 工作流程

1.客户端请求：客户端发送 GraphQL 查询或变更请求到服务器。

2.GraphQL Server 处理请求：服务器接收请求并解析查询。

3.Resolver 调用：GraphQL Server 调用相应的 Resolver 来获取数据。

4.依赖注入：Resolver 通过 Dig 容器获取所需的服务和依赖。

5.业务逻辑处理：服务层处理业务逻辑，访问数据源。

6.响应客户端：将处理后的数据返回给客户端。

    2. 实现步骤

    2.1 安装必要的库

    首先，需要安装 GraphQL 和 Dig 相关的 Go 库。

    bash

    go get github.com/99designs/gqlgen@v0.17.24
go get go.uber.org/dig

    2.2 初始化 Dig 容器

    使用 Dig 容器来管理服务的依赖关系。

    go

    // container/container.go
package container

import (
    "github.com/99designs/gqlgen/graphql/handler"
    "github.com/99designs/gqlgen/graphql/playground"
    "go.uber.org/dig"
    "your_project/graph"
    "your_project/graph/generated"
    "your_project/services"
)

func BuildContainer() *dig.Container {
    container := dig.New()

    // 提供 GraphQL 服务器
    container.Provide(func() *handler.Server {
        return handler.NewDefaultServer(generated.NewExecutableSchema(generated.Config{Resolvers: &graph.Resolver{}}))
    })

    // 提供 Playground 处理函数
    container.Provide(func() http.Handler {
        return playground.Handler("GraphQL playground", "/query")
    })

    // 提供 Resolver
    container.Provide(func(services *services.Services) *graph.Resolver {
        return &graph.Resolver{
            Services: services,
        }
    })

    // 提供服务层
    container.Provide(services.NewServices)

    return container
}

    2.3 定义服务层

    定义服务层，包含业务逻辑和数据访问逻辑。

    go

    // services/services.go
package services

import (
    "your_project/models"
    "your_project/repositories"
)

type Services struct {
    UserService UserService
}

type UserService interface {
    GetUserByID(id string) (*models.User, error)
}

type userService struct {
    userRepo repositories.UserRepository
}

func NewServices(userRepo repositories.UserRepository) *Services {
    return &Services{
        UserService: &userService{
            userRepo: userRepo,
        },
    }
}

func (s *userService) GetUserByID(id string) (*models.User, error) {
    return s.userRepo.FindByID(id)
}

    2.4 定义 Resolver

    定义 GraphQL Resolver，通过 Dig 容器获取所需的服务。

    go

    // graph/resolver.go
package graph

import (
    "context"
    "your_project/services"
)

type Resolver struct {
    Services *services.Services
}

func (r *Resolver) Query() QueryResolver {
    return &queryResolver{r.Services}
}

type queryResolver struct {
    services *services.Services
}

func (r *queryResolver) User(ctx context.Context, id string) (*User, error) {
    user, err := r.services.UserService.GetUserByID(id)
    if err != nil {
        return nil, err
    }
    return &User{
        ID:   user.ID,
        Name: user.Name,
    }, nil
}

    2.5 定义 GraphQL Schema

    定义 GraphQL Schema 和生成的代码。

    graphql

    # graph/schema.graphqls
type Query {
    user(id: ID!): User
}

type User {
    id: ID!
    name: String!
}

    go

    // graph/generated/generated.go
// This file is generated by gqlgen. DO NOT EDIT.
// ...

    2.6 配置 HTTP 服务器

    配置 HTTP 服务器，将 GraphQL 端点和 Playground 集成到 Web 服务器中。

    go

    // server/server.go
package main

import (
    "net/http"
    "your_project/container"
    "your_project/graph"
    "your_project/graph/generated"
)

func main() {
    // 构建依赖注入容器
    container := container.BuildContainer()

    // 获取 GraphQL 服务器
    var server *http.Handler
    if err := container.Invoke(func(s *http.Handler) {
        server = s
    }); err != nil {
        panic(err)
    }

    // 获取 Playground 处理函数
    var playgroundHandler http.Handler
    if err := container.Invoke(func(p http.Handler) {
        playgroundHandler = p
    }); err != nil {
        panic(err)
    }

    // 设置路由
    http.Handle("/", playgroundHandler)
    http.Handle("/query", *server)

    // 启动服务器
    http.ListenAndServe(":8080", nil)
}

    2.7 启动应用

    启动应用并访问 GraphQL Playground。

    bash

    go run server/server.go

    然后，访问 http://localhost:8080 可以看到 GraphQL Playground 界面。

    3. 最佳实践

    3.1 使用接口

    通过接口定义服务，使得依赖项可以轻松地被替换为模拟对象（mock），提高测试的灵活性。

    3.2 单一职责原则

    确保每个服务只负责一个功能，保持代码的简洁性和可维护性。

    3.3 模块化设计

    将代码按功能模块化，每个模块都有自己的依赖关系和职责，便于管理和扩展。

    3.4 错误处理

    在 Resolver 和服务层中实现统一的错误处理机制，确保错误信息的一致性和可读性。

    3.5 性能优化

    • 缓存：使用缓存机制减少数据库查询，提高性能。
    • 批量请求：优化 GraphQL 查询，避免 N+1 查询问题。

    3.6 安全性

    • 输入验证：对 GraphQL 查询进行严格的输入验证，防止注入攻击。
    • 权限控制：实现基于角色的访问控制，确保用户只能访问授权的数据。

    4. 示例

    以下是一个简化的示例，展示了如何将 Dig 与 GraphQL 结合使用。

    go

    // container/container.go
package container

import (
    "github.com/99designs/gqlgen/graphql/handler"
    "github.com/99designs/gqlgen/graphql/playground"
    "go.uber.org/dig"
    "your_project/graph"
    "your_project/graph/generated"
    "your_project/services"
)

func BuildContainer() *dig.Container {
    container := dig.New()

    // 提供 GraphQL 服务器
    container.Provide(func() *handler.Server {
        return handler.NewDefaultServer(generated.NewExecutableSchema(generated.Config{Resolvers: &graph.Resolver{}}))
    })

    // 提供 Playground 处理函数
    container.Provide(func() http.Handler {
        return playground.Handler("GraphQL playground", "/query")
    })

    // 提供 Resolver
    container.Provide(func(services *services.Services) *graph.Resolver {
        return &graph.Resolver{
            Services: services,
        }
    })

    // 提供服务层
    container.Provide(services.NewServices)

    return container
}

    go

    // services/services.go
package services

import (
    "your_project/models"
    "your_project/repositories"
)

type Services struct {
    UserService UserService
}

type UserService interface {
    GetUserByID(id string) (*models.User, error)
}

type userService struct {
    userRepo repositories.UserRepository
}

func NewServices(userRepo repositories.UserRepository) *Services {
    return &Services{
        UserService: &userService{
            userRepo: userRepo,
        },
    }
}

func (s *userService) GetUserByID(id string) (*models.User, error) {
    return s.userRepo.FindByID(id)
}

    go

    // graph/resolver.go
package graph

import (
    "context"
    "your_project/services"
)

type Resolver struct {
    Services *services.Services
}

func (r *Resolver) Query() QueryResolver {
    return &queryResolver{r.Services}
}

type queryResolver struct {
    services *services.Services
}

func (r *queryResolver) User(ctx context.Context, id string) (*User, error) {
    user, err := r.services.UserService.GetUserByID(id)
    if err != nil {
        return nil, err
    }
    return &User{
        ID:   user.ID,
        Name: user.Name,
    }, nil
}

    graphql

    # graph/schema.graphqls
type Query {
    user(id: ID!): User
}

type User {
    id: ID!
    name: String!
}

    go

    // server/server.go
package main

import (
    "net/http"
    "your_project/container"
    "your_project/graph"
    "your_project/graph/generated"
)

func main() {
    container := container.BuildContainer()

    var server *http.Handler
    if err := container.Invoke(func(s *http.Handler) {
        server = s
    }); err != nil {
        panic(err)
    }

    var playgroundHandler http.Handler
    if err := container.Invoke(func(p http.Handler) {
        playgroundHandler = p
    }); err != nil {
        panic(err)
    }

    http.Handle("/", playgroundHandler)
    http.Handle("/query", *server)

    http.ListenAndServe(":8080", nil)
}

    5. 总结

    通过将 Dig 依赖注入框架与 GraphQL 结合使用，可以实现高度模块化、可测试和可维护的应用程序。

    Dig 提供了强大的依赖管理能力，而 GraphQL 则提供了灵活、高效的数据查询方式。

    关键点：

    • 依赖管理：使用 Dig 管理依赖关系，使代码更加模块化和松耦合。
    • Resolver 注入：通过 Dig 注入 Resolver 所需的服务，简化依赖关系。
    • 服务层抽象：将业务逻辑和数据访问逻辑抽象到服务层，提高代码的可复用性。
    • 测试友好：依赖注入使得单元测试更加容易，因为可以轻松地替换依赖项为模拟对象。

    通过合理地应用 Dig 和 GraphQL，您可以构建出更加灵活和可维护的 Go 应用程序。

    联系方式:https://t.me/XMOhost26

    交流技术群:https://t.me/owolai008

    本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2407747.html

    如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

    相关文章

    2.Vue编写一个app

    2.Vue编写一个app

    1.src中重要的组成 1.1main.ts // 引入createApp用于创建应用 import { createApp } from "vue"; // 引用App根组件 import App from ./App.vue;createApp(App).mount(#app)1.2 App.vue 其中要写三种标签 <template> <!--html--> </template>…
    阅读更多...
    全球首个30米分辨率湿地数据集(2000—2022)

    全球首个30米分辨率湿地数据集(2000—2022)

    数据简介 今天我们分享的数据是全球30米分辨率湿地数据集&#xff0c;包含8种湿地亚类&#xff0c;该数据以0.5X0.5的瓦片存储&#xff0c;我们整理了所有属于中国的瓦片名称与其对应省份&#xff0c;方便大家研究使用。 该数据集作为全球首个30米分辨率、覆盖2000–2022年时间…
    阅读更多...
    定时器任务——若依源码分析

    定时器任务——若依源码分析

    分析util包下面的工具类schedule utils&#xff1a; ScheduleUtils 是若依中用于与 Quartz 框架交互的工具类&#xff0c;封装了定时任务的 创建、更新、暂停、删除等核心逻辑。 createScheduleJob createScheduleJob 用于将任务注册到 Quartz&#xff0c;先构建任务的 JobD…
    阅读更多...
    STM32标准库-DMA直接存储器存取

    STM32标准库-DMA直接存储器存取

    文章目录 一、DMA1.1简介1.2存储器映像1.3DMA框图1.4DMA基本结构1.5DMA请求1.6数据宽度与对齐1.7数据转运DMA1.8ADC扫描模式DMA 二、数据转运DMA2.1接线图2.2代码2.3相关API 一、DMA 1.1简介 DMA&#xff08;Direct Memory Access&#xff09;直接存储器存取 DMA可以提供外设…
    阅读更多...
    376. Wiggle Subsequence

    376. Wiggle Subsequence

    376. Wiggle Subsequence 代码 class Solution { public:int wiggleMaxLength(vector<int>& nums) {int n nums.size();int res 1;int prediff 0;int curdiff 0;for(int i 0;i < n-1;i){curdiff nums[i1] - nums[i];if( (prediff > 0 && curdif…
    阅读更多...
    《用户共鸣指数（E）驱动品牌大模型种草：如何抢占大模型搜索结果情感高地》

    《用户共鸣指数（E）驱动品牌大模型种草：如何抢占大模型搜索结果情感高地》

    在注意力分散、内容高度同质化的时代&#xff0c;情感连接已成为品牌破圈的关键通道。我们在服务大量品牌客户的过程中发现&#xff0c;消费者对内容的“有感”程度&#xff0c;正日益成为影响品牌传播效率与转化率的核心变量。在生成式AI驱动的内容生成与推荐环境中&#xff0…
    阅读更多...
    学校招生小程序源码介绍

    学校招生小程序源码介绍

    基于ThinkPHPFastAdminUniApp开发的学校招生小程序源码&#xff0c;专为学校招生场景量身打造&#xff0c;功能实用且操作便捷。 从技术架构来看&#xff0c;ThinkPHP提供稳定可靠的后台服务&#xff0c;FastAdmin加速开发流程&#xff0c;UniApp则保障小程序在多端有良好的兼…
    阅读更多...
    家政维修平台实战20：权限设计

    家政维修平台实战20：权限设计

    目录 1 获取工人信息2 搭建工人入口3 权限判断总结 目前我们已经搭建好了基础的用户体系&#xff0c;主要是分成几个表&#xff0c;用户表我们是记录用户的基础信息&#xff0c;包括手机、昵称、头像。而工人和员工各有各的表。那么就有一个问题&#xff0c;不同的角色&#xf…
    阅读更多...
    最新SpringBoot+SpringCloud+Nacos微服务框架分享

    最新SpringBoot+SpringCloud+Nacos微服务框架分享

    文章目录 前言一、服务规划二、架构核心1.cloud的pom2.gateway的异常handler3.gateway的filter4、admin的pom5、admin的登录核心 三、code-helper分享总结 前言 最近有个活蛮赶的&#xff0c;根据Excel列的需求预估的工时直接打骨折&#xff0c;不要问我为什么&#xff0c;主要…
    阅读更多...
    基于当前项目通过npm包形式暴露公共组件

    基于当前项目通过npm包形式暴露公共组件

    1.package.sjon文件配置 其中xh-flowable就是暴露出去的npm包名 2.创建tpyes文件夹&#xff0c;并新增内容 3.创建package文件夹
    阅读更多...
    MMaDA: Multimodal Large Diffusion Language Models

    MMaDA: Multimodal Large Diffusion Language Models

    CODE &#xff1a; https://github.com/Gen-Verse/MMaDA Abstract 我们介绍了一种新型的多模态扩散基础模型MMaDA&#xff0c;它被设计用于在文本推理、多模态理解和文本到图像生成等不同领域实现卓越的性能。该方法的特点是三个关键创新:(i) MMaDA采用统一的扩散架构&#xf…
    阅读更多...
    智能在线客服平台：数字化时代企业连接用户的 AI 中枢

    智能在线客服平台：数字化时代企业连接用户的 AI 中枢

    随着互联网技术的飞速发展&#xff0c;消费者期望能够随时随地与企业进行交流。在线客服平台作为连接企业与客户的重要桥梁&#xff0c;不仅优化了客户体验&#xff0c;还提升了企业的服务效率和市场竞争力。本文将探讨在线客服平台的重要性、技术进展、实际应用&#xff0c;并…
    阅读更多...
    【CSS position 属性】static、relative、fixed、absolute 、sticky详细介绍，多层嵌套定位示例

    【CSS position 属性】static、relative、fixed、absolute 、sticky详细介绍，多层嵌套定位示例

    文章目录 ★ position 的五种类型及基本用法 ★ 一、position 属性概述 二、position 的五种类型详解（初学者版） 1. static（默认值） 2. relative（相对定位） 3. absolute（绝对定位） 4. fixed（固定定位） 5. sticky（粘性定位） 三、定位元素的层级关系（z-i…
    阅读更多...
    [ICLR 2022]How Much Can CLIP Benefit Vision-and-Language Tasks?

    [ICLR 2022]How Much Can CLIP Benefit Vision-and-Language Tasks?

    论文网址&#xff1a;pdf 英文是纯手打的&#xff01;论文原文的summarizing and paraphrasing。可能会出现难以避免的拼写错误和语法错误&#xff0c;若有发现欢迎评论指正&#xff01;文章偏向于笔记&#xff0c;谨慎食用 目录 1. 心得 2. 论文逐段精读 2.1. Abstract 2…
    阅读更多...
    转转集团旗下首家二手多品类循环仓店“超级转转”开业

    转转集团旗下首家二手多品类循环仓店“超级转转”开业

    6月9日&#xff0c;国内领先的循环经济企业转转集团旗下首家二手多品类循环仓店“超级转转”正式开业。 转转集团创始人兼CEO黄炜、转转循环时尚发起人朱珠、转转集团COO兼红布林CEO胡伟琨、王府井集团副总裁祝捷等出席了开业剪彩仪式。 据「TMT星球」了解&#xff0c;“超级…
    阅读更多...
    【快手拥抱开源】通过快手团队开源的 KwaiCoder-AutoThink-preview 解锁大语言模型的潜力

    【快手拥抱开源】通过快手团队开源的 KwaiCoder-AutoThink-preview 解锁大语言模型的潜力

    引言&#xff1a; 在人工智能快速发展的浪潮中&#xff0c;快手Kwaipilot团队推出的 KwaiCoder-AutoThink-preview 具有里程碑意义——这是首个公开的AutoThink大语言模型&#xff08;LLM&#xff09;。该模型代表着该领域的重大突破&#xff0c;通过独特方式融合思考与非思考…
    阅读更多...
    什么是库存周转？如何用进销存系统提高库存周转率？

    什么是库存周转？如何用进销存系统提高库存周转率？

    你可能听说过这样一句话&#xff1a; “利润不是赚出来的&#xff0c;是管出来的。” 尤其是在制造业、批发零售、电商这类“货堆成山”的行业&#xff0c;很多企业看着销售不错&#xff0c;账上却没钱、利润也不见了&#xff0c;一翻库存才发现&#xff1a; 一堆卖不动的旧货…
    阅读更多...
    el-switch文字内置

    el-switch文字内置

    el-switch文字内置 效果 vue <div style"color:#ffffff;font-size:14px;float:left;margin-bottom:5px;margin-right:5px;">自动加载</div> <el-switch v-model"value" active-color"#3E99FB" inactive-color"#DCDFE6"…
    阅读更多...
    Vue2 第一节_Vue2上手_插值表达式{{}}_访问数据和修改数据_Vue开发者工具

    Vue2 第一节_Vue2上手_插值表达式{{}}_访问数据和修改数据_Vue开发者工具

    文章目录 1.Vue2上手-如何创建一个Vue实例,进行初始化渲染2. 插值表达式{{}}3. 访问数据和修改数据4. vue响应式5. Vue开发者工具--方便调试 1.Vue2上手-如何创建一个Vue实例,进行初始化渲染 准备容器引包创建Vue实例 new Vue()指定配置项 ->渲染数据 准备一个容器,例如: …
    阅读更多...
    linux arm系统烧录

    linux arm系统烧录

    1、打开瑞芯微程序 2、按住linux arm 的 recover按键 插入电源 3、当瑞芯微检测到有设备 4、松开recover按键 5、选择升级固件 6、点击固件选择本地刷机的linux arm 镜像 7、点击升级 &#xff08;忘了有没有这步了 估计有&#xff09; 刷机程序 和 镜像 就不提供了。要刷的时…
    阅读更多...
    推荐文章
    最新文章

    Copyright @ 2022~2023