注册服务

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