注册上传服务

scagent/main.go

@@ -64,6 +64,14 @@ func main() {
 			logger.Error("Register failed", zap.Error(err))
 			return
 		}
+
+		// 文件上传功能
+		err = rpc.RegisterName("FileUploadService", new(core.FileService))
+		if err != nil {
+			logger.Error("Register failed", zap.Error(err))
+			return
+		}
+
 		//
 		sport := fmt.Sprintf(":%v", config.G.Port)
 		logger.Info("Listen port", zap.String("port", sport))
@@ -87,7 +95,7 @@ func main() {
 				logger.Error("AcceptTCP failed", zap.Error(err))
 				continue
 			}
-			jsonrpc.ServeConn(conn)
+			go jsonrpc.ServeConn(conn)
 		}
 
 	}