我有以下原稿文件:
服务_myservice.proto
service MyService {
rpc GetData(GetRequest) returns (GetResponse) {}
}
Server.go
type Server struct {
pb.UnimplementedMyServiceServer
config util.Config
}
// NewServer creates a new gRPC server.
func NewServer(config util.Config) (*Server, error) {
server := &Server{
config: config,
}
return server, nil
}
然后在主包中调用此函数
func runGrpcServer(config util.Config) {
server, err := gapi.NewServer(config)
if err != nil {
log.Fatal().Err(err).Msg("cannot create server")
}
grpcLogger := grpc.UnaryInterceptor(gapi.GrpcLogger)
grpcServer := grpc.NewServer(grpcLogger)
pb.RegisterMyServiceServer(grpcServer, server)
reflection.Register(grpcServer)
listener, err := net.Listen("tcp", config.GRPCServerAddress)
if err != nil {
log.Fatal().Err(err).Msg("cannot create listener")
}
log.Info().Msgf("start gRPC server at %s", listener.Addr().String())
err = grpcServer.Serve(listener)
if err != nil {
log.Fatal().Err(err).Msg("cannot start gRPC server")
}
}
我正在使用Evans(https://github.com/ktr0731/evans)测试我的GRPC调用. 我的GRPC服务器正在运行,我可以使用Evans连接到特定端口(9090)上的本地主机.
然而,当我在Evans中呼叫show service
时,我得到以下响应:
localhost:9090> show service
+---------+-----+--------------+---------------+
| SERVICE | RPC | REQUEST TYPE | RESPONSE TYPE |
+---------+-----+--------------+---------------+
+---------+-----+--------------+---------------+
localhost:9090> call GetData
command call: failed to get the RPC descriptor for: GetData: service unselected
我认为如果我在Server
struct 中添加pb.UnimplementedMyServiceServer
,这是向前兼容的.但很明显,我遗漏了一些代码.
为了使MyService
向前兼容,缺少了什么部件?