新增：服务内部通道执行异常捕获

git-svn-id: svn://47.119.165.148/zhub@111 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
2021-02-26 07:18:53 +00:00
parent 40caa50fb7
commit e1ad0399ff
1 changed files with 5 additions and 0 deletions
--- a/zsub/msg-consumer.go
+++ b/zsub/msg-consumer.go
@@ -65,6 +65,11 @@ func msgAccept(v Message) {

 	// 内部执行指令 加入执行队列
 	funChan <- func() {
+		defer func() {
+			if r := recover(); r != nil {
+				log.Println("funChan Recovered:", r)
+			}
+		}()
 		switch cmd {
 		case "subscribe":
 			// subscribe x y z