diff --git a/scagent/main.go b/scagent/main.go index dd8a534..808ad36 100644 --- a/scagent/main.go +++ b/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) } }