给事件推送设置响应超时

panlei

2019-10-25 79c8a582be31f49f0fab414771a0bbbab2224172

给事件推送设置响应超时

 labelFilter/req.go

@@ -66,6 +66,11 @@
        fmt.Errorf("Failed set MaxRecvSize: %v", err)
        return
    }
    errTimeOut := sock.SetOption(mangos.OptionRecvDeadline,time.Millisecond * 500)
    if errTimeOut != nil {
        fmt.Errorf("Failed set MaxRecvSize: %v", err)
        return
    }
    //sock.AddTransport(ipc.NewTransport())
    sock.AddTransport(tcp.NewTransport())
    if err = sock.Dial(url); err != nil {

 main.go

@@ -12,12 +12,13 @@
    "ruleprocess/util"
    "time"

    "basic.com/valib/logger.git"
    //"bufio"
    //"bytes"
    "flag"
    "fmt"
    "github.com/golang/protobuf/proto"
    "basic.com/valib/logger.git"
    "github.com/spf13/viper"
    //"gocv.io/x/gocv"
    //"image"
    //"image/color"
@@ -25,7 +26,6 @@
    "ruleprocess/cache"
    "ruleprocess/ruleserver"
    "sync"
    "github.com/spf13/viper"
)

var dbIp = flag.String("dbIp", "127.0.0.1", "dbserver ip")