trpc-go RPC框架插件库使用指南

trpc-go是腾讯开源的一款高性能、可插拔的RPC框架，支持多种协议和插件扩展。下面我将详细介绍如何使用trpc-go构建RPC服务。

1. 安装与基础配置

首先安装trpc-go核心库和代码生成工具：

go get git.code.oo.tencent.com/trpc-go/trpc-go
go install git.code.oo.tencent.com/trpc-go/trpc-go/cmd/trpc

2. 创建服务项目结构

典型的trpc项目结构如下：

.
├── go.mod
├── go.sum
├── main.go          # 服务入口
├── stub            # 协议文件目录
│   └── helloworld
│       └── helloworld.proto
└── trpc_go.yaml    # 配置文件

3. 定义Proto协议

在stub/helloworld/helloworld.proto中定义服务：

syntax = "proto3";

package helloworld;

service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply) {}
}

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

4. 生成代码

使用trpc工具生成代码：

trpc create -p stub/helloworld/helloworld.proto -o stub/helloworld

5. 实现服务端

在main.go中实现服务：

package main

import (
	"context"
	"fmt"
	
	"git.code.oo.tencent.com/trpc-go/trpc-go"
	"git.code.oo.tencent.com/trpc-go/trpc-go/log"
	pb "your_module_path/stub/helloworld"
)

type greeterServer struct{}

func (s *greeterServer) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloReply, error) {
	log.Infof("Received request: %v", req.GetName())
	return &pb.HelloReply{Message: "Hello " + req.GetName()}, nil
}

func main() {
	s := trpc.NewServer()
	pb.RegisterGreeterService(s, &greeterServer{})
	
	if err := s.Serve(); err != nil {
		log.Fatal(err)
	}
}

6. 配置trpc_go.yaml

server:
  app: test
  server: helloworld
  service:
    - name: trpc.test.helloworld.Greeter
      ip: 127.0.0.1
      port: 8000
      protocol: trpc
      network: tcp

7. 客户端调用

package main

import (
	"context"
	"fmt"
	"time"
	
	"git.code.oo.tencent.com/trpc-go/trpc-go"
	"git.code.oo.tencent.com/trpc-go/trpc-go/client"
	pb "your_module_path/stub/helloworld"
)

func main() {
	proxy := pb.NewGreeterClientProxy(
		client.WithTarget("ip://127.0.0.1:8000"),
		client.WithTimeout(time.Second*3),
	)
	
	ctx := trpc.BackgroundContext()
	rsp, err := proxy.SayHello(ctx, &pb.HelloRequest{Name: "trpc-go"})
	if err != nil {
		panic(err)
	}
	
	fmt.Println("Response:", rsp.Message)
}

8. 插件系统使用

trpc-go支持丰富的插件系统，下面演示如何使用日志和监控插件：

8.1 日志插件

import (
	"git.code.oo.tencent.com/trpc-go/trpc-go/log"
)

func main() {
	// 设置日志级别
	log.SetLevel(log.LevelDebug)
	
	// 记录日志
	log.Debug("debug message")
	log.Info("info message")
	log.Warn("warn message")
	log.Error("error message")
}

8.2 监控插件

import (
	"git.code.oo.tencent.com/trpc-go/trpc-go/metrics"
)

func main() {
	// 记录计数器
	metrics.IncrCounter("request.count", 1)
	
	// 记录耗时
	start := time.Now()
	// ... 业务逻辑
	metrics.RecordTimer("request.latency", time.Since(start))
}

9. 高级特性

9.1 拦截器使用

func LoggingInterceptor(ctx context.Context, req interface{}, info *server.RPCInfo, handler server.Handler) (interface{}, error) {
	log.Infof("Before call: %s", info.Method)
	rsp, err := handler(ctx, req)
	log.Infof("After call: %s, err: %v", info.Method, err)
	return rsp, err
}

func main() {
	s := trpc.NewServer(
		server.WithInterceptor(LoggingInterceptor),
	)
	// ... 注册服务
}

9.2 多协议支持

trpc-go支持多种协议，只需修改配置文件：

service:
  - name: trpc.test.helloworld.Greeter
    ip: 127.0.0.1
    port: 8000
    protocol: http  # 支持trpc/http/grpc等
    network: tcp

10. 性能优化建议

1. 使用连接池：客户端默认启用连接池，可通过配置调整
2. 合理设置超时：避免请求长时间阻塞
3. 启用压缩：对于大数据量传输可配置压缩
4. 使用批处理：对于高频小请求可合并处理

trpc-go提供了丰富的功能和良好的扩展性，适合构建高性能分布式系统。通过插件系统可以轻松集成各种中间件和工具，满足不同业务场景需求。