TRPC是一个基于Go的高性能RPC框架，它提供了代码生成、路由、中间件等功能。以下是一个简单的TRPC示例，展示了如何定义服务、创建服务器以及调用服务。
首先，你需要安装TRPC：
go get github.com/cs3238-2021/go-trpc
定义服务：
// hello.proto
syntax = "proto3";
package pb;
service Hello {
rpc Hello(HelloRequest) returns (HelloResponse);
}
message HelloRequest {
string name = 1;
}
message HelloResponse {
string message = 1;
}
生成Go代码：
trpc-go-gen -in hello.proto -out .
实现服务：
package main
import (
"context"
"fmt"
"github.com/cs3238-2021/go-trpc/examples/helloworld/pb"
)
type helloService struct{}
func (h *helloService) Hello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloResponse, error) {
return &pb.HelloResponse{Message: "Hello, " + req.Name + "!"}, nil
}
func main() {
server := trpc.NewServer()
server.Register(new(helloService))
// ... start the server
}
启动服务并调用服务：
package main
import (
"context"
"fmt"
"log"
"net"
"github.com/cs3238-2021/go-trpc/examples/helloworld/pb"
)
func main() {
listener, err := net.Listen("tcp", ":8080")
if err != nil {
log.Fatal(err)
}
defer listener.Close()
server := trpc.NewServer()
server.Register(new(helloService))
go func() {
if err := server.Serve(listener); err != nil {
log.Fatal(err)
}
}()
client := trpc.NewClient(listener.Addr().String())
resp, err := client.Call(context.Background(), &pb.HelloRequest{Name: "World"})
if err != nil {
log.Fatal(err)
}
fmt.Println(resp.(*pb.HelloResponse).Message)
}
以上代码展示了如何定义一个RPC服务，如何实现它，以及如何启动服务器并从客户端调用该服务。这个例子是基于一个简单的“Hello World”服务，但TRPC可以用于更复杂的应用程序。