设置推送缓存

panlei

2019-11-01 d6242c4a792b2a6d06faf8920db9e3848592dedb

设置推送缓存

 labelFilter/req.go

@@ -94,6 +94,16 @@
        logger.Error("接收响应超时")
        return
    }
    errWrite := sock.SetOption(mangos.OptionWriteQLen,10)
    if errWrite != nil {
        logger.Error("设置传输缓存大小失败")
        return
    }
    errRead := sock.SetOption(mangos.OptionReadQLen,10)
    if errRead != nil {
        logger.Error("设置传输缓存大小失败")
        return
    }
    sock.AddTransport(tcp.NewTransport())
    if err = sock.Dial("tcp://"+url); err != nil {
        logger.Error("请求socket拨号失败: ", err.Error())