ruleserver/readyDataForRule.go
@@ -280,7 +280,7 @@ //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,10*1024*1024) if errSize != nil { logger.Error("Failed set MaxRecvSize: %v", err) return nil @@ -356,7 +356,7 @@ logger.Debug("数据推送成功!收到响应,数据长度为:",len(msg)) receiver <- msg default: time.Sleep(10 * time.Millisecond) } } }