diff --git a/scagent/main.go b/scagent/main.go index 3eefa90..6c149b6 100644 --- a/scagent/main.go +++ b/scagent/main.go @@ -50,7 +50,12 @@ func main() { if isDaemon() { // 以守护进程方式运行 jrpc := new(core.FileRpc) - rpc.Register(jrpc) + // 注册服务名 + err := rpc.RegisterName("FileRpcService", jrpc) + if err != nil { + logger.Error("Register failed", zap.Error(err)) + return + } // sport := fmt.Sprintf(":%v", config.G.Port) tcpAddr, err := net.ResolveTCPAddr("tcp", sport) @@ -67,7 +72,7 @@ func main() { } for { - conn, err := listenr.AcceptTCP() + conn, err := listenr.Accept() if err != nil { logger.Error("AcceptTCP failed", zap.Error(err)) continue