go使用trpc案例

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可以用于更复杂的应用程序。