---

panlei

2019-12-13 6fd9af45e0cd30838b221f759ba59adc50653093

---

 algorithm/personTrack/personTrack.go

@@ -143,21 +143,21 @@
func Push(){
    var err error
    var msg []byte

    logger.Info("追踪请求通道建立")
    if sock, err = req.NewSocket(); err != nil {
        logger.Error("创建请求socket失败: %s", err.Error())
    }
    errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
    errSize := sock.SetOption(mangos.OptionMaxRecvSize,20*1024*1024)
    if errSize != nil {
        logger.Error("Failed set MaxRecvSize: %v", err)
    }
    //sock.AddTransport(ipc.NewTransport())
    sock.AddTransport(tcp.NewTransport())
    serverIP, _ := GetLocalIP()
    if err = sock.Dial("tcp://"+serverIP+":4010"); err != nil {
    if err = sock.Dial("tcp://"+serverIP+":4011"); err != nil {
        logger.Error("请求socket拨号失败: %s", err.Error())
    }
    logger.Info("序列化数据")
    //logger.Info("序列化数据")
    initFlag = true
    for {
        select {