From e6982607fbbeaa96d3d14409df780266646b793d Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 01 十一月 2019 18:22:44 +0800 Subject: [PATCH] 换一个chan --- labelFilter/req.go | 26 ++++++++++++++++++++++---- 1 files changed, 22 insertions(+), 4 deletions(-) diff --git a/labelFilter/req.go b/labelFilter/req.go index 3da1e61..77b7e7c 100644 --- a/labelFilter/req.go +++ b/labelFilter/req.go @@ -11,11 +11,13 @@ "nanomsg.org/go-mangos/transport/ipc" "nanomsg.org/go-mangos/transport/tcp" "ruleprocess/structure" + "strings" "time" ) var urlPool = make(map[string]chan structure.ResultMsg) +var pool chan *structure.ResultMsg = make(chan *structure.ResultMsg) func Die(format string, v ...interface{}) { logger.Info("+++++++",format) //os.Exit(1) @@ -67,8 +69,10 @@ if ruleGroup.Enable { // 澶ц鍒欏紑鍏冲紑鍚姸鎬� for _, url := range ruleGroup.Urls { // 涓烘瘡涓猽rl寤虹珛涓�涓猚han - urlPool[url.Url] = make(chan structure.ResultMsg,50) - go GoPush(url.Url) + if strings.Contains(url.Url,"114") { + //urlPool[url.Url] = make(chan structure.ResultMsg,10) + go GoPush(url.Url) + } } } } @@ -91,18 +95,32 @@ 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()) } logger.Info("搴忓垪鍖栨暟鎹�") + //for v := range pool{ + // logger.Info("鏃犻檺寰幆",v.Cid) + //} + for { select { // case <-ctx.Done(): // return - case data := <- urlPool[url]: - + case data := <- pool: + logger.Info("鎺ユ敹鍒版暟鎹�",data.Cid) bytes,err1 := proto.Marshal(data) logger.Info("鏁版嵁闀垮害涓猴細",len(bytes)) if err1 != nil { -- Gitblit v1.8.0