syntax = "proto3";package helloworld;// The greeting service definition.service Greeter { / Sends a greeting rpc SayHello (HelloRequest) returns (HelloReply) {}/ The request message containing the user's name.message HelloRequest { string name = 1;}// The response message containing the greetingsmessage HelloReply { string message = 1;} 8 y2 q9 d4 C( R& g+ v8 x0 j" f4 X% r
greeter_server主要类型为:/ u/ \+ ~4 q5 R0 C" G
// server is used to implement helloworld.GreeterServer.type server struct{}// SayHello implements helloworld.GreeterServerfunc (s *server) SayHello(ctx context.Context,in *pb.HelloRequest) (*pb.HelloReply,error) return &pb.HelloReply{Message: "Hello " in.Name},nil}/ q0 @. c6 b) `4 c' A7 c+ _1 O
我已经找到了一个例子,但是我找不到任何关于如何在 Go 中实现 gRPC 服务测试示例。 8 W) \' r* Y2 H' ^ Q - p. x& {* Y% M& C4 z _ 解决方案: 1 h* G/ x& ~$ G0 U( i$ X 我想你正在寻找它google.golang.org/grpc/test/bufconn包帮助您避免使用真实的端口号启动服务,但仍允许测试流式 RPC。/ Z& v: Q1 o" L
import "google.golang.org/grpc/test/bufconn"const bufSize = 1024 * 1024var lis *bufconn.Listenerfunc init() lis = bufconn.Listen(bufSize) s := grpc.NewServer() pb.RegisterGreeterServer(s,&server go func() if err := s.Serve(lis); err != nil log.Fatalf("Server exited with error: %v",err) } }()}func bufDialer(context.Context,string) (net.Conn,error) return lis.Dial()}func TestSayHello(t *testing.T) ctx := context.Background() conn,err := grpc.DialContext(ctx,"bufnet",grpc.WithContextDialer(bufDialer),grpc.WithInsecure() if err != nil t.Fatalf("Failed to dial bufnet: %v",err) } defer conn.Close() client := pb.NewGreeterClient(conn) resp,err := client.SayHello(ctx,&pb.HelloRequest{"Dr. Seuss"}) if err != nil t.Fatalf("SayHello failed: %v",err) } log.Printf("Response: % v",resp) // Test for output here.}$ h. r8 o- Y" n5 _. `& q1 Q, q