手机网站前端如何建网站赚取佣金
使用 ttrpc 实现高效的进程间通信（附 Go Demo）
ttrpc（Tiny Transport RPC）是由 containerd 社区开发的一种轻量级 RPC 协议，它专为本地进程间通信（IPC）设计，使用 UNIX domain socket 与 protobuf，实现了比 gRPC 更快、更小、更适合容器运行时的通信机制。
本文将介绍：
- ttrpc 是什么
- ttrpc 与 gRPC 的区别
- 如何使用 ttrpc 开发一个服务端和客户端
- 完整 Demo 与运行方法
✳️ 一、ttrpc 简介
ttrpc 是一个基于 Protobuf 的简化 RPC 框架，主要用于容器运行时如 containerd 与其 shim 之间的通信。相比 gRPC，它去除了 TLS、多路复用、流式接口等复杂功能，专注于在同主机中通过 UNIX socket 进行高性能通信。
✅ 特点
| 特性 | ttrpc | gRPC |
|---|---|---|
| 通信协议 | Protobuf over UNIX socket | Protobuf over HTTP/2 |
| TLS 支持 | ❌ 不支持 | ✅ 支持 |
| 多路复用 | ❌ 不支持 | ✅ 支持 |
| 使用场景 | 本地进程通信（如 shim） | 网络服务间通信 |
| 性能开销 | ✅ 极小 | ❌ 相对较大 |
🔧 二、环境准备
1. 安装依赖
确保 Go 和 protoc 安装完成：
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install github.com/containerd/ttrpc/cmd/protoc-gen-go-ttrpc@latest
将 $GOPATH/bin 加入 PATH：
export PATH=$PATH:$HOME/go/bin
📁 三、定义 Protobuf 接口（hello.proto）
创建文件 hello.proto：
syntax = "proto3";package hello;service HelloService {rpc SayHello(HelloRequest) returns (HelloReply);
}message HelloRequest {string name = 1;
}message HelloReply {string message = 1;
}
🛠️ 四、生成 ttrpc 代码
执行以下命令生成 Go 文件：
protoc \--go_out=. \--go-ttrpc_out=. \--go_opt=paths=source_relative \--go-ttrpc_opt=paths=source_relative \hello.proto
会生成：
hello.pb.go：Protobuf 消息定义hello.ttrpc.pb.go：ttrpc 服务/客户端接口
🚀 五、服务端实现（模拟 shim）
文件：server.go
package mainimport ("context""fmt""net""os""github.com/containerd/ttrpc"pb "yourmodule/hello" // 修改为实际路径
)type helloService struct{}func (s *helloService) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloReply, error) {return &pb.HelloReply{Message: "Hello, " + req.Name}, nil
}func main() {socket := "/tmp/hello.sock"_ = os.Remove(socket)l, err := net.Listen("unix", socket)if err != nil {panic(err)}server := ttrpc.NewServer()pb.RegisterHelloService(server, &helloService{})fmt.Println("shim 服务启动，监听：", socket)if err := server.Serve(context.Background(), l); err != nil {panic(err)}
}
🧑💻 六、客户端实现（模拟 containerd）
文件：client.go
package mainimport ("context""fmt""net""time""github.com/containerd/ttrpc"pb "yourmodule/hello" // 修改为实际路径
)func main() {conn, err := net.Dial("unix", "/tmp/hello.sock")if err != nil {panic(err)}defer conn.Close()client := ttrpc.NewClient(conn)defer client.Close()c := pb.NewHelloServiceClient(client)ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)defer cancel()resp, err := c.SayHello(ctx, &pb.HelloRequest{Name: "小诸葛"})if err != nil {panic(err)}fmt.Println("收到响应:", resp.Message)
}
📦 七、运行 demo
1. 运行服务端：
go run server.go
输出：
shim 服务启动，监听： /tmp/hello.sock
2. 启动客户端（新终端）：
go run client.go
输出：
收到响应: Hello, 小诸葛
📌 八、总结
ttrpc 提供了一个专为本地通信优化的 RPC 框架，特别适合容器运行时、shim 等无需网络的通信场景：
- 更快：无 HTTP/TLS 负担
- 更轻：简单 protobuf 实现
- 更专注：适用于容器生命周期控制等场景
🧩 附：常见问题排查
| 问题 | 解决办法 |
|---|---|
protoc-gen-go-ttrpc not found | 执行 go install github.com/containerd/ttrpc/cmd/protoc-gen-go-ttrpc@latest 并加入 PATH |
import path 错误 | 确保 import "yourmodule/hello" 指向你实际的模块路径 |
| socket 无法连接 | 确保服务端正在运行，socket 路径一致且权限正确 |