| | |
| | | var sec = flag.Int("sec", 10, "the second for query data. ") |
| | | |
| | | var Level = flag.String("level","ErrorLevel","log level") |
| | | var IsHub = flag.String("hub", "hub", "hub is personIsHub=1") |
| | | |
| | | func main() { |
| | | flag.Parse() |
| | |
| | | } |
| | | |
| | | func handleMessage(conn net.Conn, connArr []net.Conn) bool { |
| | | jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl) |
| | | jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl, *IsHub) |
| | | if jsonstring == nil { |
| | | log.Log.Infoln("the data is nil,remoteArr:",conn.RemoteAddr()) |
| | | conn.Write([]byte("\000")) |
| | | return true |
| | | if _, err := conn.Write([]byte("\000"));err !=nil { |
| | | log.Log.Infoln("conn.WriteErr:",err) |
| | | return false |
| | | } else { |
| | | return true |
| | | } |
| | | } |
| | | jsonstring = append(jsonstring, []byte("\000")...) |
| | | log.Log.Infoln("jsonstring len: ", len(jsonstring), "\000 data: ", len("\000")) |