修复并发处理

zhangzengfei

2024-07-08 56f1c6f01920f20924114a946dabb851b6cb3f3f

 serve/serve.go

@@ -24,16 +24,20 @@
         logger.Infof("worker %d done", id)
         return
      default:
         msg, err := sock.Recv()
         if err != nil || len(msg) <= 0 {
            continue
         var msg *mangos.Message
         var err error
         if msg, err = sock.RecvMsg(); err != nil {
            return
         }

         var request facecompare.CompareRequest
         err = proto.Unmarshal(msg, &request)
         err = proto.Unmarshal(msg.Body, &request)
         if err != nil {
            logger.Warn("CompareRequest json unmarshal error")
            continue
            if err = sock.SendMsg(msg); err != nil {
               logger.Warn("send reply err:", err.Error())
               continue
            }
         }

         var result []byte
@@ -45,7 +49,6 @@
               logger.Debug("用时：", time.Since(timeStart))
            } else {
               logger.Warn("CompareArgs or EsPersonCacheChange json unmarshal error")
               continue
            }
         } else if request.CompareType == facecompare.CompareType_UpdateCache {
            var compareEvent protomsg.CompareEvent
@@ -63,12 +66,12 @@
               }
            } else {
               logger.Warn("CompareEvent json unmarshal error")
               continue
            }
         }

         err = sock.Send(result)
         if err != nil {
         msg.Body = result

         if err = sock.SendMsg(msg); err != nil {
            logger.Warn("send reply err:", err.Error())
         }
      }