| | |
|---|
| | | "sort" |
|---|
| | | "strconv" |
|---|
| | | "sync" |
|---|
| | | "time" |
|---|
| | | "webserver/extend/config" |
|---|
| | | "webserver/extend/logger" |
|---|
| | | "webserver/extend/util" |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | func doCompareRequest(url string,args []byte) *[]byte{ |
|---|
| | | reqUrl := "tcp://"+url |
|---|
| | | logger.Debug("reqUrl:",reqUrl) |
|---|
| | | logger.Debug("reqUrl:",url) |
|---|
| | | var sock mangos.Socket |
|---|
| | | var err error |
|---|
| | | var msg []byte |
|---|
| | |
|---|
| | | } |
|---|
| | | sock.AddTransport(ipc.NewTransport()) |
|---|
| | | sock.AddTransport(tcp.NewTransport()) |
|---|
| | | sock.SetOption(mangos.OptionRecvDeadline, time.Second*10) |
|---|
| | | if err = sock.Dial(url);err !=nil { |
|---|
| | | logger.Debug("can't dial on req socket:%s",err.Error()) |
|---|
| | | return nil |
|---|
| | | } |
|---|
| | | sock.SetOption(mangos.OptionMaxRecvSize, 1024*1024*100) |
|---|
| | | //sock.SetOption(mangos.OptionRecvDeadline, time.Second*10) |
|---|
| | | if err = sock.Send(args);err !=nil { |
|---|
| | | logger.Debug("can't send message on push socket:%s",err.Error()) |
|---|
| | | return nil |
|---|
