bug fix: 捕获panic，防止程序停止运行

bitxx · Aug 2, 2023 · 744dcd1 · 744dcd1
1 parent 7bd379a
commit 744dcd1
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/client/app/app.go b/client/app/app.go
@@ -58,7 +58,7 @@ func (a *App) Start() {
 	defer func() {
 		a.close(conn, readTicker, latencyTicker)
 		// if not interrupt,restart the client
-		if !isInterrupt {
+		if r := recover(); r != nil || !isInterrupt {
 			time.Sleep(5 * time.Second)
 			a.Start()
 		}
@@ -112,6 +112,12 @@ func (a *App) Start() {
 }
 
 func (a *App) readLoop(conn *connutil.ConnWrapper) {
+	defer func() {
+		if r := recover(); r != nil {
+			return
+		}
+	}()
+
 	for {
 		blob := json.RawMessage{}
 		if err := conn.ReadJSON(&blob); err != nil {