xiugai

service/sendMsg.go

@@ -152,14 +152,14 @@ func ClassCountUnread(msgType int, userId string, appId string) (int64, string,
 func EtcdCountAdd(userId, msgType string) {
 	s1, err := concurrency.NewSession(entity.EtcdCli)
 	if err != nil {
-		log.Fatal(err)
+		log.Println(err)
 	}
 	defer s1.Close()
 	keyString := fmt.Sprintf(EtcdCount, userId, msgType)
 	m1 := concurrency.NewMutex(s1, keyString)
 	// 会话s1获取锁
 	if err := m1.Lock(context.TODO()); err != nil {
-		log.Fatal("EtcdCountAdd获取锁失败", err)
+		log.Println("EtcdCountAdd获取锁失败", err)
 	}
 	// 操作数量
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
@@ -170,7 +170,7 @@ func EtcdCountAdd(userId, msgType string) {
 
 		// 释放锁
 		if err := m1.Unlock(context.TODO()); err != nil {
-			log.Fatal("EtcdCountAdd释放锁失败", err)
+			log.Println("EtcdCountAdd释放锁失败", err)
 		}
 		return
 	}
@@ -193,14 +193,14 @@ func EtcdCountAdd(userId, msgType string) {
 		fmt.Printf("put to etcd failed, err:%v\n", err)
 		// 释放锁
 		if err := m1.Unlock(context.TODO()); err != nil {
-			log.Fatal("EtcdCountAdd释放锁失败2", err)
+			log.Println("EtcdCountAdd释放锁失败2", err)
 		}
 		return
 	}
 
 	// 释放锁
 	if err := m1.Unlock(context.TODO()); err != nil {
-		log.Fatal("EtcdCountAdd释放锁失败3", err)
+		log.Println("EtcdCountAdd释放锁失败3", err)
 	}
 }
 
@@ -208,14 +208,14 @@ func EtcdCountAdd(userId, msgType string) {
 func EtcdCountMinusOne(userId, msgType string) {
 	s1, err := concurrency.NewSession(entity.EtcdCli)
 	if err != nil {
-		log.Fatal(err)
+		log.Println(err)
 	}
 	defer s1.Close()
 	keyString := fmt.Sprintf(EtcdCount, userId, msgType)
 	m1 := concurrency.NewMutex(s1, keyString)
 	// 会话s1获取锁
 	if err := m1.Lock(context.TODO()); err != nil {
-		log.Fatal("EtcdCountMinusOne获取锁失败", err)
+		log.Println("EtcdCountMinusOne获取锁失败", err)
 	}
 	// 操作数量
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
@@ -226,7 +226,7 @@ func EtcdCountMinusOne(userId, msgType string) {
 
 		// 释放锁
 		if err := m1.Unlock(context.TODO()); err != nil {
-			log.Fatal("EtcdCountMinusOne释放锁失败", err)
+			log.Println("EtcdCountMinusOne释放锁失败", err)
 		}
 		return
 	}
@@ -255,14 +255,14 @@ func EtcdCountMinusOne(userId, msgType string) {
 		fmt.Printf("put to etcd failed, err:%v\n", err)
 		// 释放锁
 		if err := m1.Unlock(context.TODO()); err != nil {
-			log.Fatal("EtcdCountMinusOne释放锁失败2", err)
+			log.Println("EtcdCountMinusOne释放锁失败2", err)
 		}
 		return
 	}
 
 	// 释放锁
 	if err := m1.Unlock(context.TODO()); err != nil {
-		log.Fatal("EtcdCountMinusOne释放锁失败3", err)
+		log.Println("EtcdCountMinusOne释放锁失败3", err)
 	}
 }
 
@@ -271,14 +271,14 @@ func EtcdSetCountZero(userId, msgType string) {
 	log.Println(" 消息类别置0", userId, msgType)
 	s1, err := concurrency.NewSession(entity.EtcdCli)
 	if err != nil {
-		log.Fatal(err)
+		log.Println(err)
 	}
 	defer s1.Close()
 	keyString := fmt.Sprintf(EtcdCount, userId, msgType)
 	m1 := concurrency.NewMutex(s1, keyString)
 	// 会话s1获取锁
 	if err := m1.Lock(context.TODO()); err != nil {
-		log.Fatal("EtcdSetCountZero获取锁失败", err)
+		log.Println("EtcdSetCountZero获取锁失败", err)
 	}
 	// 操作数量
 
@@ -289,14 +289,14 @@ func EtcdSetCountZero(userId, msgType string) {
 		fmt.Printf("put to etcd failed, err:%v\n", err)
 		// 释放锁
 		if err := m1.Unlock(context.TODO()); err != nil {
-			log.Fatal("EtcdSetCountZero释放锁失败", err)
+			log.Println("EtcdSetCountZero释放锁失败", err)
 		}
 		return
 	}
 
 	// 释放锁
 	if err := m1.Unlock(context.TODO()); err != nil {
-		log.Fatal("EtcdSetCountZero释放锁失败", err)
+		log.Println("EtcdSetCountZero释放锁失败", err)
 	}
 }