解决事件推送内存问题

panlei

2019-11-02 b8614ca71294cc7847afa83dd0764f90597aa7ce

解决事件推送内存问题

 labelFilter/req.go

@@ -9,7 +9,6 @@
    "nanomsg.org/go-mangos/protocol/req"
    "nanomsg.org/go-mangos/transport/ipc"
    "nanomsg.org/go-mangos/transport/tcp"
    "strings"
    "time"
)

@@ -71,8 +70,7 @@
        if ruleGroup.Enable { // 大规则开关开启状态
            for _, url := range ruleGroup.Urls {
                // 为每个url建立一个chan

                if !strings.Contains(url.Url,"116") {
                if urlPool[url.Url] == nil {
                    urlPool[url.Url] = make(chan []byte,10)
                    logger.Info("初始化信息：",urlPool)
                    go GoPush(url.Url)
@@ -104,12 +102,12 @@
        logger.Error("发送超时")
        return
    }
    errWrite := sock.SetOption(mangos.OptionWriteQLen,10)
    errWrite := sock.SetOption(mangos.OptionWriteQLen,5)
    if errWrite != nil {
        logger.Error("设置传输缓存大小失败")
        return
    }
    errRead := sock.SetOption(mangos.OptionReadQLen,10)
    errRead := sock.SetOption(mangos.OptionReadQLen,5)
    if errRead != nil {
        logger.Error("设置传输缓存大小失败")
        return

 main.go

@@ -108,7 +108,7 @@
                    insertdata.InsertToEs(resultMsg)
                    logger.Debug("插入完Es所用时间：", time.Since(start))
                    //事件推送
                    labelFilter.PushSomthing(resultMsg)
                    go labelFilter.PushSomthing(resultMsg)
                //}(msg)
            }
        }