From f98c1def896db21a7c8756caed128b51af484d6d Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期三, 30 十月 2019 20:12:21 +0800
Subject: [PATCH] 拼上tcp，愚蠢的错误
---
labelFilter/req.go | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/labelFilter/req.go b/labelFilter/req.go
index b61af43..bbe80e3 100644
--- a/labelFilter/req.go
+++ b/labelFilter/req.go
@@ -14,7 +14,7 @@
"time"
)
-var sock mangos.Socket
+
var urlPool = make(map[string]chan structure.ResultMsg)
func Die(format string, v ...interface{}) {
logger.Info("+++++++",format)
@@ -77,6 +77,7 @@
func GoPush(url string) {
var err error
var msg []byte
+ var sock mangos.Socket
if sock, err = req.NewSocket(); err != nil {
Die("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
}
@@ -91,7 +92,7 @@
return
}
sock.AddTransport(tcp.NewTransport())
- if err = sock.Dial(url); err != nil {
+ if err = sock.Dial("tcp://"+url); err != nil {
logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: ", err.Error())
}
logger.Info("搴忓垪鍖栨暟鎹�")
--
Gitblit v1.8.0