diff --git a/grpc/grpc.go b/grpc/grpc.go index c23e18a..b8e6e1e 100644 --- a/grpc/grpc.go +++ b/grpc/grpc.go @@ -4,6 +4,7 @@ import ( "fmt" "log" "net" + "sync" "google.golang.org/grpc" "google.golang.org/grpc/reflection" @@ -49,8 +50,9 @@ func Port() int { func Start() { //注册反射 用于grpcurl调试 reflection.Register(rpc) - - // grpc服务启动,本局IP支持 + wg := sync.WaitGroup{} + wg.Add(1) + // grpc服务启动 go func() { addr, err := net.ResolveTCPAddr("tcp", fmt.Sprintf("%s:%d", conf.Address, conf.Port)) if err != nil { @@ -67,5 +69,7 @@ func Start() { if err != nil { log.Fatal("fail to open microservice: ", err) } + wg.Done() }() + wg.Wait() }