From 53941272739616d56cf980afe81bd0f5e164e11d Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期三, 30 十月 2019 20:03:48 +0800
Subject: [PATCH] 一个socket拨一个号
---
labelFilter/req.go | 28 +++++++++++++---------------
1 files changed, 13 insertions(+), 15 deletions(-)
diff --git a/labelFilter/req.go b/labelFilter/req.go
index 1f4be77..b61af43 100644
--- a/labelFilter/req.go
+++ b/labelFilter/req.go
@@ -57,21 +57,6 @@
func Init(){
- var err error
-
- if sock, err = req.NewSocket(); err != nil {
- Die("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
- }
- errSize := sock.SetOption(mangos.OptionMaxRecvSize,30*1024*1024)
- if errSize != nil {
- logger.Error("浼犺緭鐨勬暟鎹秴杩囧ぇ灏忛檺鍒�")
- return
- }
- errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 2000)
- if errTimeOut != nil {
- logger.Error("鎺ユ敹鍝嶅簲瓒呮椂")
- return
- }
var api dbapi.EventPushApi
b, allRules := api.FindAllDetails()
logger.Info("鏌ョ湅鎵�鏈夎鍒欑粍锛�", allRules)
@@ -92,6 +77,19 @@
func GoPush(url string) {
var err error
var msg []byte
+ if sock, err = req.NewSocket(); err != nil {
+ Die("鍒涘缓璇锋眰socket澶辫触: %s", err.Error())
+ }
+ errSize := sock.SetOption(mangos.OptionMaxRecvSize,30*1024*1024)
+ if errSize != nil {
+ logger.Error("浼犺緭鐨勬暟鎹秴杩囧ぇ灏忛檺鍒�")
+ return
+ }
+ errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 2000)
+ if errTimeOut != nil {
+ logger.Error("鎺ユ敹鍝嶅簲瓒呮椂")
+ return
+ }
sock.AddTransport(tcp.NewTransport())
if err = sock.Dial(url); err != nil {
logger.Error("璇锋眰socket鎷ㄥ彿澶辫触: ", err.Error())
--
Gitblit v1.8.0