修复并发处理

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())
            }
        }