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