| | |
|---|
| | | |
|---|
| | | import ( |
|---|
| | | "flag" |
|---|
| | | "fmt" |
|---|
| | | "net" |
|---|
| | | "strconv" |
|---|
| | | "time" |
|---|
| | |
|---|
| | | log "github.com/long/test/log" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | var addr = flag.String("addr", "192.168.1.124", "The address to listen to;") |
|---|
| | | var addr = flag.String("addr", "0.0.0.0", "The address to listen to;") |
|---|
| | | var Eurl = flag.String("eurl", "http://192.168.1.182:9200/", "The port to listen on; ") |
|---|
| | | var Picurl = flag.String("picurl", "http://58.118.225.79:41242/", "picture url ") |
|---|
| | | |
|---|
| | | var port = flag.Int("port", 6000, "The port to listen on; ") |
|---|
| | | var sec = flag.Int("sec", 10, "the second for query data. ") |
|---|
| | |
|---|
| | | func main() { |
|---|
| | | flag.Parse() |
|---|
| | | |
|---|
| | | log.Log.Infoln("starting server...") |
|---|
| | | |
|---|
| | | fmt.Println(*port) |
|---|
| | | src := *addr + ":" + strconv.Itoa(*port) |
|---|
| | | listener, err := net.Listen("tcp", src) |
|---|
| | | if err != nil { |
|---|
| | |
|---|
| | | } |
|---|
| | | log.Log.Infof("Listening on %s.\n", src) |
|---|
| | | |
|---|
| | | fmt.Println("starting server success.") |
|---|
| | | defer listener.Close() |
|---|
| | | |
|---|
| | | for { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | func handleMessage(conn net.Conn) { |
|---|
| | | jsonstring := esutil.PostAction(*sec, *Eurl) |
|---|
| | | jsonstring := esutil.PostAction(*sec, *Eurl, *Picurl) |
|---|
| | | if jsonstring == nil { |
|---|
| | | log.Log.Infoln("the data is nil") |
|---|
| | | return |
|---|
