数据推送加大小设置5兆，事件推送改为并发OC

panlei

2019-08-07 edfa73a39c2daccaf169764904fe797f9df98fa9

数据推送加大小设置5兆，事件推送改为并发OC

 labelFilter/req.go

@@ -61,6 +61,11 @@
    if sock, err = req.NewSocket(); err != nil {
        Die("创建请求socket失败: %s", err.Error())
    }
    errSize := sock.SetOption(mangos.OptionMaxRecvSize,5*1024*1024)
    if errSize != nil {
        fmt.Errorf("Failed set MaxRecvSize: %v", err)
        return
    }
    //sock.AddTransport(ipc.NewTransport())
    sock.AddTransport(tcp.NewTransport())
    if err = sock.Dial(url); err != nil {

 main.go

@@ -79,7 +79,7 @@
                // 将打完标签的数据插入到ES
                insertdata.InsertToEs(resultMsg)
                //事件推送
                labelFilter.Judge(resultMsg)
                go labelFilter.Judge(resultMsg)
            }
        }
    }