diff --git a/server/imserver/WSPListener.go b/server/imserver/WSPListener.go new file mode 100644 index 00000000..8737e243 --- /dev/null +++ b/server/imserver/WSPListener.go @@ -0,0 +1,36 @@ +package main + +import ( + "net" +) + +type GGListener_ struct { + listener net.Listener +} + +var GGListener = new (GGListener_) + +func (this *GGListener_) Init() { + listener, err := net.Listen("tcp", "0.0.0.0:8888") + if err != nil { + + } else { + this.listener = listener + go this.accept() + } +} + +func (this *GGListener_) UnInit() { +} + +func (this *GGListener_) accept() { + for { + conn, err := this.listener.Accept() + if err == nil { + go this.socketRead(conn) + } + } +} + +func (this *GGListener_) socketRead(conn net.Conn) { +} diff --git a/server/imserver/app.go b/server/imserver/app.go index 8d8f6ead..4c3b49ac 100644 --- a/server/imserver/app.go +++ b/server/imserver/app.go @@ -27,7 +27,7 @@ func (this *App_) UnInit() { } func (this *App_) goReportServerState() { - for (true) { + for { params := q5.NewMxoObject() params.SetXValue("node_id", q5.NewXInt32(1)) params.SetXValue("instance_id", q5.NewXInt32(1))