k8s deploy

2022-05-23 16:07:52 +08:00
parent 48940272ae
commit ce15c26b59
2 changed files with 2 additions and 2 deletions
@@ -77,7 +77,7 @@ func (rpc *rpcChat) Run() {
 		log.Error("", "register rpcChat to etcd failed ", err.Error())
 		return
 	}
-
+	go rpc.runCh()
 	err = srv.Serve(listener)
 	if err != nil {
 		log.Error("", "rpc rpcChat failed ", err.Error())