go使用trpc案例

news2024/11/15 16:58:00

1.go下载trpc

go install trpc.group/trpc-go/trpc-cmdline/trpc@latest

有报错的话尝试配置一些代理（选一个）

go env -w GOPROXY=https://goproxy.cn,direct
go env -w GOPROXY=https://goproxy.io,direct
go env -w GOPROXY=https://goproxy.baidu.com/ 
go env -w GOPROXY=https://mirrors.aliyun.com/goproxy/

cmd运行

trpc version

#打印版本号就是成功了
trpc-group/trpc-cmdline version: v1.0.5

2.下载protoc

下载地址：Release Protocol Buffers v25.3 · protocolbuffers/protobuf · GitHub

把protoc加入环境变量

不会加环境变量的自己百度。我都懒得写

cmd查看版本：

protoc --version

3.编写一个proto文件

syntax = "proto3";  /
option go_package="./;baomin1";

package baomin;

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

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

然后执行

trpc create -p trpcDemo.proto -o out
// -o 指定文件存放目录，proto文件中，option go_package="./;baomin1"; 已经指定了文件的存放目录，如果使用-o 指定为out，会覆盖./目录。out目录会自动创建

生成out文件，内容如下：

3.1 proto文件解释

syntax 用于制定protoc的版本，proto2或proto3，新版本proto3中必填。

option go_package = "path;name";
        path 表示生成的go文件的存放地址，会自动生成目录的。
        name 表示生成的go文件所属的包名。

package baomin; 指定文件包名，优先级会高于上面的name,所以报名会是baomin，不是baomin1。

message: protobuf中定义一个消息类型式是通过关键字 message字段指定的。消息就是需要传输的数据格式的定义message关键字类似于C++中的class，JAVA中的class，go中的struct。

        字段规则



        required: 消息体中必填字段，不设置会导致编码异常。

                        在protobuf2中使用，在protobuf3中被删去

        optional : 消息体中可选字段。protobuf3没有了required，

optional等说明关键字，都默认为optional

        repeate: 消息体中可重复字段，重复的值的顺序会被保留在go中

重复的会被定义为切片。

消息号：

在消息体的定义中，每个字段都必须要有一个唯一的标识号，

标识号是[1，2^29-1] 范国内的一个整数



                必须是正整数（1 到 2^29-1）。

                标签不能重复出现在同一个消息中。

                标签的顺序可以是任意的。不需要连续，可以跳过一些数值。



  嵌套消息：可以在其他消息类型中定义、使用消息类型，

                        在下面的例子中，person消息就定义在Personlnfo消息内如
message PersonInfo{
	message Person{
		string name = 1;
		int32 height =2;
		repeated int32 weight = 3;
	}
	repeated Person info = 1;
}
如果要在它的父消息类型的外部重用这个消息类型，需要Personlnfo.Person的形式使用它，如:
message PersonMessage{
	PersonInfo.Person info = 1;
}
服务定义：
service $earchService{
# rpc 服务函数名 (参》返回(返回参)
	rpc Search(SearchRequest) returns (SearchResponse)
}

上面的proto文件是主要是给你解释用的，一般不建议代码存放用./当前位子，容易出错

改成下面

syntax = "proto3";
option go_package="tengxun/trpc/code";

package baomin;

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

message HelloRequest {
  string name = 1;
}

message HelloReply {
  string message = 1;
}

删除生成的out文件

再次执行

trpc create -p trpcDemo.proto -o out

服务端代码修改一下

out/main.go

package main

import (
	"context"
	"fmt"
	pb "tengxun/trpc/code"

	_ "trpc.group/trpc-go/trpc-filter/debuglog"
	_ "trpc.group/trpc-go/trpc-filter/recovery"
	trpc "trpc.group/trpc-go/trpc-go"
	"trpc.group/trpc-go/trpc-go/log"
)

type helloserver struct {
	pb.UnimplementedHelloserver
}

func (s *helloserver) SayHello(ctx context.Context, req *pb.HelloRequest) (*pb.HelloReply, error) {
	fmt.Println("hello " + req.Name)
	return &pb.HelloReply{Message: "SayHello::::::::::: " + req.Name}, nil
}

func main() {
	s := trpc.NewServer()
	pb.RegisterHelloserverService(s.Service("baomin.Helloserver"), &helloserver{})
	if err := s.Serve(); err != nil {
		log.Fatal(err)
	}
}