diff --git a/node/app/app.go b/node/app/app.go index 169259a..b02c884 100644 --- a/node/app/app.go +++ b/node/app/app.go @@ -57,14 +57,6 @@ func Start() { } go nodeSerRpcListen() - // aggNode 注册,无数据后处理环节 - //aggWorker := agg_worker.NewAggWorker() - //err1 := rpc.RegisterName("aggNode", aggWorker) - //if err1 != nil { - // log.Fatal("注册 aggNode rpc 异常", err1) - //} - //aggWorker.RegisterToMaster() - //后移注册流程,避免node启动异常的无效注册 nodeWorker.RegisterToMaster()