通知短信+运营短信,5秒速达,支持群发助手一键发送🚀高效触达和通知客户 广告
创建服务器 === 现在服务端要去实现pb.go中service的interface ~~~ // AddServiceServer is the server API for AddService service. type AddServiceServer interface { Add(context.Context, *Request) (*Response, error) Multiply(context.Context, *Request) (*Response, error) } ~~~ 实现 ~~~ package main import ( "GRPC-Study/demo1/proto" "context" "google.golang.org/grpc" "google.golang.org/grpc/reflection" "net" ) type server struct {} func main() { // 创建一个tcp服务 listener, e := net.Listen("tcp", ":9001") if e != nil { panic(e.Error()) } // 创建一个没有注册的grpc srv := grpc.NewServer() proto.RegisterAddServiceServer(srv,&server{})// 注册上去 reflection.Register(srv) // 注册在给定的gRPC服务器上注册服务器反射服务 // 监听 if e := srv.Serve(listener);e != nil { panic(e.Error()) } } // 要去实现service.proto定义的方法 func (s *server) Add(ctx context.Context,req *proto.Request) (*proto.Response,error) { a,b := req.GetA(),req.GetB() result := a + b return &proto.Response{Result:result},nil } func (s *server) Multiply(ctx context.Context,req *proto.Request) (*proto.Response,error) { b,a := req.GetB(),req.GetA() result := b*a return &proto.Response{ Result:result, },nil } ~~~