diff --git a/dsBaseRpc/main.go b/dsBaseRpc/main.go index e52c80fc..2d18e5db 100644 --- a/dsBaseRpc/main.go +++ b/dsBaseRpc/main.go @@ -1,6 +1,7 @@ package main import ( + "dsBaseRpc/DataExchange" "dsBaseRpc/RpcService/BaseClass/BaseClassProto" "dsBaseRpc/RpcService/BaseClass/BaseClassService" "dsBaseRpc/RpcService/BaseGlobal/BaseGlobalProto" @@ -115,9 +116,15 @@ func main() { BasePositionProto.RegisterBasePositionManageServer(s, &BasePositionService.Rpc{}) //五、开启一个数据上报的协程 - //go func() { - // DataExchange.DataExchange() - //}() + go func() { + //异常处理 + defer func() { + if err := recover(); err != nil { + fmt.Printf("%s\n", err) + } + }() + DataExchange.DataExchange() + }() //六、 注册反射服务 这个服务是CLI使用的 跟服务本身没有关系 reflection.Register(s) //七、启动