| | |
| | | //} |
| | | //var pool chan *structure.ResultMsg = make(chan *structure.ResultMsg) |
| | | func Die(format string, v ...interface{}) { |
| | | logger.Info("+++++++",format) |
| | | logger.Info("+++++++",format,v) |
| | | //os.Exit(1) |
| | | } |
| | | |
| | |
| | | // 为每个url建立一个chan |
| | | |
| | | if !strings.Contains(url.Url,"116") { |
| | | ch := make(chan []byte,10) |
| | | urlPool[url.Url] = ch |
| | | logger.Info("初始化信息:",ch,urlPool) |
| | | urlPool[url.Url] = make(chan []byte,10) |
| | | logger.Info("初始化信息:",urlPool) |
| | | go GoPush(url.Url) |
| | | } |
| | | } |
| | |
| | | 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 |
| | | //} |
| | | errTimeOut1 := sock.SetOption(mangos.OptionSendDeadline,time.Millisecond * 2000) |
| | | if errTimeOut1 != nil { |
| | | 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()) |
| | |
| | | // ch = v.ch |
| | | // } |
| | | //} |
| | | //logger.Info("chan信息:",ch) |
| | | logger.Info("chan信息:",urlPool[url]) |
| | | for { |
| | | select { |
| | | // case <-ctx.Done(): |