tRPC-Go 框架 01：tRPC-Go 总览与核心架构

tRPC-Go 框架 01tRPC-Go 总览与核心架构tRPC 是腾讯开源的多语言 RPC 框架tRPC-Go是其 Go 语言实现已在腾讯内部支撑了海量服务视频、音乐、新闻、广告等日均调用量万亿级。本篇我们站高一点俯瞰 tRPC-Go 的整体架构与设计理念。一、tRPC 是什么tRPC tencentRPCFramework它是一个多语言Go / C / Java / Python / Node.js / Rust …多协议原生 trpc / gRPC / HTTP / 自定义可插拔服务治理、配置、可观测皆为插件云原生与 Kubernetes、Polaris 深度集成官方仓库https://github.com/trpc-group/trpc-go二、为什么需要又一个 RPC 框架业界已有 gRPC、Dubbo为什么腾讯还要做 tRPC维度gRPCtRPC协议绑定仅 HTTP/2Protobuf协议可插拔多语言一致性各语言实现略有差异各语言行为一致服务治理需要自行集成 Istio 等内建 Polaris、配置中心、可观测国内生态适配弱强腾讯/北极星/天机阁/七彩石周边脚手架需要自行拼装trpc-cmdline 一键创建核心动因在腾讯内部多语言、多协议、多基础设施环境下需要一个统一、灵活、易扩展的 RPC 框架。三、设计理念3.1 一切皆插件tRPC-Go 的核心非常薄所有能力编解码、传输、注册中心、负载均衡、限流、日志、监控都通过插件接口实现typePlugininterface{Type()stringSetup(namestring,decoder Decoder)error}这意味着切换注册中心、加监控点、改协议只需改配置或加一行 import业务代码零侵入。3.2 接口定义先行tRPC 强制以.proto为接口契约通过trpc-cmdline工具生成桩代码trpc create-phello.proto-o.生成的代码包含服务端接口你来实现客户端 stub直接调用mock测试用。3.3 配置驱动所有运行时行为通过trpc_go.yaml配置server:service:-name:trpc.app.server.Greeterip:127.0.0.1port:8000protocol:trpcclient:service:-name:trpc.app.user.Usertarget:polaris://trpc.app.user.Userprotocol:trpctimeout:1000plugins:log:default:...registry:polaris:...四、整体架构图┌─────────────────────────────────────────────────────────┐ │ 业务代码 (handler) │ └─────────────────────────────────────────────────────────┘ ▲ ▲ │ 服务端 │ 客户端 ┌───────────┴──────────────┐ ┌──────────────┴──────────┐ │ Filter Chain (拦截器) │ │ Filter Chain (拦截器) │ └───────────┬──────────────┘ └──────────────┬──────────┘ ▼ ▼ ┌──────────────────────────┐ ┌─────────────────────────┐ │ Codec编解码 │ │ Codec编解码 │ └───────────┬──────────────┘ └──────────────┬──────────┘ ▼ ▼ ┌──────────────────────────┐ ┌─────────────────────────┐ │ Transport传输层 │ │ Transport传输层 │ └───────────┬──────────────┘ └──────────────┬──────────┘ └─────────── Network ────────────┘ ┌─────────────────┐ │ 插件层贯穿全局 │ │ 注册中心 / LB │ │ 监控 / 日志 │ │ 配置中心 / 限流 │ └─────────────────┘五、核心组件详解5.1 Service / Server / ClientServer进程级别可以承载多个 ServiceService一个 RPC 服务一组方法Client调用端代理。// Server 启动s:trpc.NewServer()pb.RegisterGreeterService(s,greeterImpl{})s.Serve()// Client 调用proxy:pb.NewGreeterClientProxy()resp,err:proxy.Hello(ctx,req)5.2 Codec编解码负责消息打包/拆包、协议头与 body 的处理。tRPC 内置trpc默认二进制protobufhttpHTTPJSON 或 HTTPprotobufgrpcHTTP/2protobuf与 gRPC 互通通过protocol配置切换protocol:trpc|http|grpc|http_no_protocol5.3 Transport传输层抽象底层网络通信默认 TCP支持TCP / UDP自定义 transport如基于共享内存5.4 Filter拦截器类似 Java Servlet Filter / Express middleware对所有调用做横切处理typeFilterfunc(ctx context.Context,req,rsp any,next Handler)error经典用途日志、监控、链路追踪鉴权限流熔断重试。注册server:filter:[recovery,debuglog,openTelemetry]client:filter:[retry,breaker,debuglog]5.5 Selector服务发现 LB 路由selector(polaris://trpc.app.user) │ ├─ Discovery拉实例列表 ├─ ServiceRouter路由筛选 ├─ LoadBalancer负载均衡 └─ CircuitBreaker熔断每一步都可独立替换。5.6 Naming命名服务target 的格式schema://service-name?keyvaluekeyvalue例polaris://trpc.app.user?namespaceProduction ip://127.0.0.1:8000 dns://www.example.com:805.7 Plugin插件框架是 tRPC-Go 的骨架。注册一个插件plugin.Register(polaris,PolarisPlugin{})启动时根据trpc_go.yaml加载对应插件。六、一次完整的服务端调用流程1. TCP accept Transport 2. 拆包 解码协议头 Codec 3. 解码 body 为 message Codec 4. 路由到 method Server 5. Filter 链日志 / 监控 / 鉴权… Filter 6. 调用 handler 业务代码 7. 返回值经 Filter 反向链 Filter 8. 编码响应 Codec 9. 写回 TCP Transport七、一次完整的客户端调用流程1. proxy.Method(ctx, req) 2. Filter 链retry / circuit / 监控 3. Selector选目标实例 4. Codec编码 req 5. Transport网络发送 6. Transport接收 response 7. Codec解码 response 8. Filter 链反向 9. 返回业务调用方八、生态全景围绕 tRPC-Go 还有一系列周边工具/库作用trpc-cmdline项目脚手架与代码生成trpc-cli客户端调试trpc-go-database数据库驱动封装trpc-filter-*各类内置 filtertrpc-naming-polaris北极星命名服务插件trpc-config-*配置中心插件rainbow/etcd…trpc-log-*日志插件atta/zaptrpc-metrics-*监控指标插件trpc-opentelemetry链路追踪九、与 gRPC 的关系tRPC 不是要取代 gRPC而是包含 gRPC你可以让 tRPC 服务以 gRPC 协议对外提供你可以让 tRPC 客户端调用 gRPC 服务也可以让 tRPC 服务被 gRPC 客户端调用。所谓协议互通是 tRPC 设计中重要的一环。十、最小化体验# 1. 安装命令行工具goinstalltrpc.group/trpc-go/trpc-cmdline/trpclatest# 2. 创建一个 protocathello.protoEOF syntax proto3; package helloworld; option go_package git.code.oa.com/examples/helloworld; service HelloWorld { rpc Hello(HelloReq) returns (HelloRsp); } message HelloReq { string msg 1; } message HelloRsp { string msg 1; } EOF# 3. 生成项目骨架trpc create-phello.proto-o.# 4. 启动go run main.go十一、小结tRPC-Go 多语言 多协议 全插件化的 RPC 框架一切皆插件 / 接口先行 / 配置驱动 三大设计原则核心组件Codec、Transport、Filter、Selector、Plugin与 Polaris、北极星、七彩石、天机阁等深度集成。下一篇我们将动手搭建第一个 tRPC-Go 服务从 0 到 1 跑通 Hello World。