fix:消息保存优化

rpc/etc/message.yaml

@@ -12,8 +12,8 @@ DataSource:
     Address: 192.168.3.217:4000
     UserName: root
     PassWord: =PDT49#80Z!RVv52_z
-    MaxOpenConns: 20
-    MaxIdleConns: 20
+    MaxOpenConns: 50
+    MaxIdleConns: 50
 Redis:
   Host: 192.168.3.206
   Addr: 192.168.3.206:1712
@@ -23,5 +23,5 @@ FileSystemConf:
     Hosts:
       - 127.0.0.1:2379
     Key: message.rpc
-SurvivalTime:  86400
-SaveConcurrency: 5
+SurvivalTime: 86400
+SaveConcurrency: 10

service/sendMsg.go

@@ -213,19 +213,17 @@ func MultSave(this message.MultipleSaveMsgReq) (int64, string) {
 	}
 	wg := &sync.WaitGroup{}
 	for i := 0; i < len(userIdArr); i++ {
-
-		v := userIdArr[i]
-		if v == "" {
+		if userIdArr[i] == "" {
 			continue
 		}
-		userName := userNameArr[i]
 		wg.Add(1)
 		entity.SaveConcurrencyChan <- 1
-		go func() {
+		go func(v string) {
 			defer func() {
 				<-entity.SaveConcurrencyChan
 				wg.Done()
 			}()
+			userName := userNameArr[i]
 			//消息数组
 			c := entity.Mysql.Count("conversation", map[string]interface{}{"receive_id": v, "send_id": this.SendUserId})
 			sql3 := `INSERT INTO message(appid,receive_userid,receive_name,send_userid,send_name,title,content,msg_type,link,cite_id,createtime,isRead,isdel,msg_log_id,show_buoy,show_content) values ("%s",'%s','%s','%s','%s','%s','%s',%d,'%s',0,'%s',0,1,%d,%d,'%s');`
@@ -258,7 +256,7 @@ func MultSave(this message.MultipleSaveMsgReq) (int64, string) {
 					log.Println("存redis：", ok)
 				}
 			}
-		}()
+		}(userIdArr[i])
 
 	}
 	wg.Wait()