免去繁琐的手动埋点,Gin 框架可观测性最佳实践

作者:牧思

背景

在云原生时代的今天,Golang 编程语言越来越成为开发者们的首选,而对于 Golang 开发者来说,最著名的 Golang Web 框架莫过于 Gin [ 1] 框架了,Gin 框架作为 Golang 编程语言官方的推荐框架 [ 2] ,其提供了丰富的路由与中间件功能,使得 Golang 开发者可以轻松地构建复杂的 Web 应用。对于如此重要的 Web 框架,如何去快速而全面地对 Gin 应用进行监控成为了一大难题,本文将着重介绍 Gin 框架官方推荐的几种可观测性方案并进行对比,从而得出 Gin 框架可观测性的最佳实践。

观测方案一览

Gin 官方提供了丰富的插件来帮助开发者快速地搭建 Web 应用,在官方提供的插件列表 [ 3] 中,提供了对 OpenTelemetry 的几种支持方案,分别是 SDK 手动埋点方案 [ 4] ,编译时注入方案 [ 5] ,以及 eBPF 方案 [6 ] ,下面分别来对官方推荐的三种观测方案进行实践:

前置准备

  1. 首先使用 Gin 框架编写一个简单的 Golang 应用:
package mainimport ("io""log""net/http""time""github.com/gin-gonic/gin"
)func main() {r := gin.Default()r.GET("/hello-gin", func(c *gin.Context) {c.String(http.StatusOK, "hello\n")})go func() {_ = r.Run()}()// give time for auto-instrumentation to start uptime.Sleep(5 * time.Second)for {resp, err := http.Get("http://localhost:8080/hello-gin")if err != nil {log.Fatal(err)}body, err := io.ReadAll(resp.Body)if err != nil {log.Fatal(err)}log.Printf("Body: %s\n", string(body))_ = resp.Body.Close()// give time for auto-instrumentation to report signaltime.Sleep(5 * time.Second)}
}
  1. 根据文档 [ 7] 快速拉起 OpenTelemetry 的各种服务端依赖,比如 OpenTelemetry Collector,Jaeger,Prometheus 等等。

手动埋点

手动埋点方案即是利用了 Gin 框架的 Middleware 机制,在 Gin 的请求处理过程中为本次请求生成 span,我们需要基于以上代码进行改造:

const (SERVICE_NAME       = ""SERVICE_VERSION    = ""DEPLOY_ENVIRONMENT = ""HTTP_ENDPOINT      = ""HTTP_URL_PATH      = ""
)// 设置应用资源
func newResource(ctx context.Context) *resource.Resource {hostName, _ := os.Hostname()r, err := resource.New(ctx,resource.WithFromEnv(),resource.WithProcess(),resource.WithTelemetrySDK(),resource.WithHost(),resource.WithAttributes(semconv.ServiceNameKey.String(SERVICE_NAME), // 应用名semconv.ServiceVersionKey.String(SERVICE_VERSION), // 应用版本semconv.DeploymentEnvironmentKey.String(DEPLOY_ENVIRONMENT), // 部署环境semconv.HostNameKey.String(hostName), // 主机名),)if err != nil {log.Fatalf("%s: %v", "Failed to create OpenTelemetry resource", err)}return r
}func newHTTPExporterAndSpanProcessor(ctx context.Context) (*otlptrace.Exporter, sdktrace.SpanProcessor) {traceExporter, err := otlptrace.New(ctx, otlptracehttp.NewClient(otlptracehttp.WithEndpoint(HTTP_ENDPOINT),otlptracehttp.WithURLPath(HTTP_URL_PATH),otlptracehttp.WithInsecure(),otlptracehttp.WithCompression(1)))if err != nil {log.Fatalf("%s: %v", "Failed to create the OpenTelemetry trace exporter", err)}batchSpanProcessor := sdktrace.NewBatchSpanProcessor(traceExporter)return traceExporter, batchSpanProcessor
}// InitOpenTelemetry OpenTelemetry 初始化方法
func InitOpenTelemetry() func() {ctx := context.Background()var traceExporter *otlptrace.Exportervar batchSpanProcessor sdktrace.SpanProcessortraceExporter, batchSpanProcessor = newHTTPExporterAndSpanProcessor(ctx)otelResource := newResource(ctx)traceProvider := sdktrace.NewTracerProvider(sdktrace.WithSampler(sdktrace.AlwaysSample()),sdktrace.WithResource(otelResource),sdktrace.WithSpanProcessor(batchSpanProcessor))otel.SetTracerProvider(traceProvider)otel.SetTextMapPropagator(propagation.NewCompositeTextMapPropagator(propagation.TraceContext{}, propagation.Baggage{}))return func() {cxt, cancel := context.WithTimeout(ctx, time.Second)defer cancel()if err := traceExporter.Shutdown(cxt); err != nil {otel.Handle(err)}}
}func main() {r := gin.Default()// 初始化您的OpenTelemetrytp, err := InitOpenTelemetry()if err != nil {log.Fatal(err)}defer func() {if err := tp.Shutdown(context.Background()); err != nil {log.Printf("Error shutting down tracer provider: %v", err)}}()// 添加gin的OpenTelemetry中间件实现r.Use(otelgin.Middleware("my-server"))r.GET("/hello-gin", func(c *gin.Context) {c.String(http.StatusOK, "hello\n")})
}

通过在代码里面对 Gin 服务添加 OpenTelemetry 中间件,可以有效地收集到 Gin 应用本身的调用链路信息:

可以看到,手动接入的方案需要对代码进行比较大的改造,需要去手动引入依赖,初始化 SDK,并手动注入 middleware,此外,该方案只能收集到 Gin 应用本身的链路信息,对于 Gin 的上游和下游应用也需要进行代码的改造才能将整个链路进行打通和串联。

编译时注入自动埋点

除了手动埋点方案,官方还推荐了编译时自动注入方案来实现在零代码修改的观测方案,用户可以参考阿里巴巴开源的编译时自动插桩项目 [ 8] 对上述实例程序进行插桩:

step 1:下载 Golang Agent 二进制包

首先,可以进入主页 [ 9] 下载最新版本的 Golang Agent 二进制包。

step 2:使用 Golang Agent 二进制包编译 Golang 应用

在拥有了 Golang Agent 的二进制包后,即可使用该二进制包代替 go build 编译 Golang 应用的二进制程序。

otel-linux-amd64 go build .

在执行上述命令后,即可在对应应用的根目录下找到具有可观测能力的 Golang 二进制程序。

step 3:配置上报端点,运行二进制程序

最后,通过文档 [ 10] 配置观测数据的上报端点,并且启动上一步中编译出来的具有可观测能力的 Golang 二进制程序:

可以看到,编译出来的二进制 Golang 程序可以完整地展示出应用的调用链路。

除了链路,编译出来的二进制 Golang 程序还可以有效地收集 Gin 应用的运行时指标,比如 Gin 应用的调用耗时,GC 次数,内存申请次数等等:

eBPF 自动埋点

官方提供的最后一种 Gin 应用的观测办法是通过 OpenTelemetry 的 eBPF 方案进行自动埋点,eBPF 方式只需要在部署应用时在应用进程命名空间下添加一个特权级的 Sidecar 容器,特权级的 Sidecar 容器会自动捕捉应用容器产生的观测数据,并且进行上报。

我们还是对第一步中使用的简易 Golang 应用进行观测,在 Kubernetes 环境中部署以下 yaml:

apiVersion: apps/v1
kind: Deployment
metadata:labels:app.kubernetes.io/name: emojiapp.kubernetes.io/part-of: emojivotoapp.kubernetes.io/version: v11name: emojinamespace: emojivoto
spec:progressDeadlineSeconds: 600replicas: 1revisionHistoryLimit: 10selector:matchLabels:app: emoji-svcversion: v11template:metadata:labels:app: emoji-svcversion: v11spec:containers:- env:- name: HTTPvalue: '8080'image: 'registry.cn-hangzhou.aliyuncs.com/private-mesh/ginotel:latest'imagePullPolicy: Alwaysname: emoji-svcports:- containerPort: 8080name: grpcprotocol: TCPresources:requests:cpu: 100mterminationMessagePath: /dev/termination-logterminationMessagePolicy: File- env:- name: OTEL_GO_AUTO_TARGET_EXEvalue: /usr/local/bin/app- name: OTEL_EXPORTER_OTLP_ENDPOINTvalue: 'http://jaeger.default.svc:4318'- name: OTEL_SERVICE_NAMEvalue: emojivoto-emojiimage: >-ghcr.io/open-telemetry/opentelemetry-go-instrumentation/autoinstrumentation-go:v0.19.0-alphaimagePullPolicy: IfNotPresentname: emojivoto-emoji-instrumentationresources: {}securityContext:privileged: truerunAsUser: 0terminationMessagePath: /dev/termination-logterminationMessagePolicy: FilednsPolicy: ClusterFirstrestartPolicy: AlwaysschedulerName: default-schedulersecurityContext: {}shareProcessNamespace: trueterminationGracePeriodSeconds: 0

Gin 应用产生的观测数据将会被自动地收集并上报至 jaeger 中:

eBPF 方案看起来非常的美好,但是实际使用时却有着各种限制,比如其对于 Golang 的小版本非常的敏感,demo 中的应用,如果我们使用 Go 1.23.4 版本(升级 1 个小版本)来进行编译,eBPF 就将因为 Golang 的版本不匹配而无法收集到任何观测数据:

此外,eBPF 方案还有其他较多的限制,比如 client 传递的 HTTP Header 不能超过 8 个,又比如 eBPF 对操作系统的内核版本的要求较高等等,具体可以参照这篇文章。

观测方案对比

总的来说,手动埋点的自由度更高,但是接入和维护的成本也最高,适合技术能力强的用户自己完全控制。eBPF 自动埋点方案接入成本最低,但是随之而来的是性能的开销以及使用场景的各种限制。而编译时注入自动埋点的方案相对来说解决了前两种方案的各种问题,在降低了用户接入维护成本的同时也解决了插桩的性能,安全性等问题,某种程度上是目前最适合客户的 Gin 应用观测方案!

总结和展望

Golang Agent 成功解决了 Golang 应用监控中繁琐的手动埋点问题,并已商业化上线至阿里云公有云,为客户提供强大的监控能力。这项技术最初的设计初衷是为了让用户能够在不改动现有代码的前提下轻松地插入监控代码,从而实现对应用程序性能状态的实时监测与分析,但它的实际应用领域超越预期,包括服务治理、代码审计、应用安全、代码调试等,甚至在许多未被探索的领域中也展现出潜力。

我们已经将这项创新方案开源,并成功捐赠给 OpenTelemetry 社区 [ 11] 。开源不仅促进技术共享与提升,借助社区的力量还可以持续探索该方案在更多领域上的可能。

最后诚邀大家试用我们的商业化产品,并加入我们的钉钉群 (开源群:102565007776,商业化群:35568145) ,共同提升 Go 应用监控与服务治理能力。通过群策群力,我们相信能为 Golang 开发者社区带来更加优质的云原生体验。

相关链接:

[1] Gin

https://github.com/gin-gonic/gin

[2] 推荐框架

https://go.dev/doc/tutorial/web-service-gin

[3] 插件列表

https://github.com/gin-gonic/contrib

[4] SDK 手动埋点方案

https://github.com/open-telemetry/opentelemetry-go-contrib/tree/main/instrumentation/github.com/gin-gonic/gin/otelgin

[5] 编译时注入方案

https://github.com/alibaba/opentelemetry-go-auto-instrumentation

[6] eBPF 方案

https://github.com/open-telemetry/opentelemetry-go-instrumentation

[7] 文档

https://opentelemetry.io/docs/demo/kubernetes-deployment/

[8] 编译时自动插桩项目

https://github.com/alibaba/opentelemetry-go-auto-instrumentation

[9] 主页

https://github.com/alibaba/opentelemetry-go-auto-instrumentation

[10] 文档

https://opentelemetry.io/docs/specs/otel/configuration/sdk-environment-variables/

[11] OpenTelemetry 社区

https://github.com/open-telemetry/opentelemetry-go-compile-instrumentation

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

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

深入浅出WPF命令系统之InputBinding(MouseBinding与KeyBinding)

之前的随笔中剖析了WPF命令系统的一部分,文中是通过CommandBinding或Binding两种方式将命令(ICommand)与Button控件关联,如下: 方式一,CommandBinding1 <Window.Resources>2 3 <RoutedCommand x:Key="MyTestCommand"/>4 5 </Window.Resou…

20241217 实验二《Python程序设计》实验报告

20241217 2024-2025-2 《Python程序设计》实验二报告 课程:《Python程序设计》 班级: 2412 姓名: 黄迅 学号:20241217 实验教师:王志强 实验日期:2025年3月26日 必修/选修: 公选课 一、实验内容 1.设计并完成一个完整的应用程序,完成加减乘除模等运算,功能多多益善; …

教师教学质量分析评价系统 A教育大模型

教师教学质量分析评价系统基于YOLOv12+RNN的深度学习算法,教师教学质量分析评价系统精准地检测到学生是否在玩手机、举手、睡觉、交头接耳、趴桌子、行走运动等行为。同时,该模型还能够捕捉学生的情绪表情,如开心、厌恶、愤怒、悲伤、沮丧、恐惧、无表情等。这些行为和表情数…

服务器数据备份方法,服务器数据备份方法推荐

在当今数字化浪潮中,服务器宛如企业运营的“数据心脏”,承载着海量核心数据。一旦数据丢失,企业可能面临难以估量的损失。从财务报表到客户信息,从业务文档到关键代码,这些数据的安全维系着企业的生命线。因此,选择有效的服务器数据备份方法,成为企业数据管理的重中之重…

nocoding-codes-xxt

// UserScript // @name 🐮ABC 网课助手|超星学习通|智慧树|🚀自动答题|▶️一键操作|🏆超全题库(每日更新、自动收录)|支持划词搜题 // @namespace oolikeABC // @version 3.2.3 // @author oolikeABC // @description 【🥇懒人操作】…

牛客 小白112 20250326

牛客 小白112 20250326 https://ac.nowcoder.com/acm/contest/103957 A: 题目大意:天平一端有 \(w\) 重的物品,给定砝码 \(a,b\) 判断能否是天平平衡 #include<bits/stdc++.h> #define cintie ios::sync_with_stdio(false);cin.tie(0);cout.tie(0); #define Trd int T…

web132笔记(php运算符优先级 || 优先级低于 )

打开是⼀个⽹站,robots.txt⾥有个/admin,访问之后<?php/* # -*- coding: utf-8 -*- # @Author: h1xa # @Date: 2020-10-13 06:22:13 # @Last Modified by: h1xa # @Last Modified time: 2020-10-13 20:05:36 # @email: h1xa@ctfer.com # @link: https://ctfer.com*/#…

ElevenLabs 对话式 AI 支持 RAG;阿里 TaoAvatar 快速生成 3D 数字人:实时渲染兼容移动设备丨日报

开发者朋友们大家好:这里是 「RTE 开发者日报」 ,每天和大家一起看新闻、聊八卦。我们的社区编辑团队会整理分享 RTE(Real-Time Engagement) 领域内「有话题的 技术 」、「有亮点的 产品 」、「有思考的 文章 」、「有态度的 观点 」、「有看点的 活动 」,但内容仅代表编辑…

川崎机器人减速机齿轮维修解析

一、齿轮磨损的原因正常磨损:长期使用时,齿轮齿面在不断啮合的过程中,会因摩擦等因素而逐渐磨损。 润滑不良:润滑油不足或油质不良会导致齿轮间的摩擦磨损增加,同时也会使齿轮温度升高,进一步影响齿轮的精度和寿命。 过载运行:当川崎机器人过载时,减速器齿轮承受的载荷…

Oracle驱动下载和本地maven仓库文件结构的创建

写在前面: 2I2Rc*@JY8 本文章用于记录博主平时遇到的问题,步骤略粗糙,目的在于记录便于后续博主自己查找,如果能帮助到其他人更好。文章中用到的链接均为自行引入,侵删,谢谢 问题描述:1、需要 maven 工程引入 Oracle jdbc驱动;2、查找了 maven 中央仓库,发现 ojdbc 的…

阿里云Tair KVCache:打造以缓存为中心的大模型Token超级工厂

一、Tair KVCache 简介 Tair KVCache 是阿里云瑶池旗下云数据库 Tair 面向大语言模型推理场景推出的 KVCache 缓存加速服务。 随着互联网技术的演进与流量规模的激增,缓存技术逐渐成为系统架构的核心组件。该阶段催生了 Redis 等开源缓存数据库,阿里巴巴基于自身业务需求自主…