'commit'

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() {
+	go func() {
-	//	DataExchange.DataExchange()
+		//异常处理
-	//}()
+		defer func() {
+			if err := recover(); err != nil {
+				fmt.Printf("%s\n", err)
+			}
+		}()
+		DataExchange.DataExchange()
+	}()
 	//六、 注册反射服务 这个服务是CLI使用的 跟服务本身没有关系
 	reflection.Register(s)
 	//七、启动