From 9898df35363f554657088c81219eed673004ce26 Mon Sep 17 00:00:00 2001 From: azw Date: Sun, 13 Aug 2023 12:51:19 +0800 Subject: [PATCH] 1 --- server/imserver/WSPListener.go | 2 -- server/imserver/app.go | 29 ----------------------------- server/imserver/export.go | 6 ++++++ server/imserver/handlermgr.go | 2 -- server/imserver/playermgr.go | 25 +++++++++++++++++++++++-- 5 files changed, 29 insertions(+), 35 deletions(-) create mode 100644 server/imserver/export.go diff --git a/server/imserver/WSPListener.go b/server/imserver/WSPListener.go index f00bf034..9c69c0e2 100644 --- a/server/imserver/WSPListener.go +++ b/server/imserver/WSPListener.go @@ -18,8 +18,6 @@ type WSPListener struct { msgList q5.ListHead } -var wspListener = new (WSPListener) - func (this *WSPListener) Init() { this.ch = make(chan *f5.MsgHdr) listener, err := net.Listen("tcp", "0.0.0.0:" + diff --git a/server/imserver/app.go b/server/imserver/app.go index 8d30d5b0..7cfdfb87 100644 --- a/server/imserver/app.go +++ b/server/imserver/app.go @@ -1,9 +1,6 @@ package main import ( - "time" - "fmt" - "q5" "f5" "cs" @@ -14,8 +11,6 @@ type App struct { netMsgQueue q5.Queue } -var app = new (App) - func (this *App) GetPkgName() string { return "imserver" } @@ -23,11 +18,9 @@ func (this *App) GetPkgName() string { func (this *App) Init() { this.netMsgQueue.Init() f5.LoadMetaTable(mt.Table) - fmt.Println("listen_port", mt.Table.IMServer.GetById(0).GetListenPort()) handlerMgr.Init() wspListener.Init() - go this.goReportServerState() } func (this *App) UnInit() { @@ -50,28 +43,6 @@ func (this *App) Update() { } } -func (this *App) goReportServerState() { - for { - /* - params := q5.NewMxoObject() - params.SetXValue("node_id", q5.NewXInt32(1)) - params.SetXValue("instance_id", q5.NewXInt32(1)) - params.SetXValue("ip", q5.NewXString("192.168.100.39")) - params.SetXValue("port", q5.NewXInt32(8888)) - params.SetXValue("online_num", q5.NewXInt32(1)) - params.SetXValue("room_num", q5.NewXInt32(1)) - params.SetXValue("channel", q5.NewXInt32(0)) - params.SetXValue("alive_count", q5.NewXInt32(1)) - params.SetXValue("servicing", q5.NewXInt32(1)) - _, err := q5.HttpGet( - "http://192.168.100.45:7821/webapp/index.php?c=GS&a=report&", - params.AsXObject()) - fmt.Println(err); - */ - time.Sleep(time.Duration(1) * time.Second) - } -} - func (this *App) addNetMsg(hdr *f5.MsgHdr) { this.netMsgQueue.Push(&hdr.Entry) f5.GetApp().NotifyLoopCond() diff --git a/server/imserver/export.go b/server/imserver/export.go new file mode 100644 index 00000000..1371e1f7 --- /dev/null +++ b/server/imserver/export.go @@ -0,0 +1,6 @@ +package main + +var app = new (App) +var wspListener = new (WSPListener) +var playerMgr = new (PlayerMgr) +var handlerMgr = new (HandlerMgr) diff --git a/server/imserver/handlermgr.go b/server/imserver/handlermgr.go index 1399e367..553b60e8 100644 --- a/server/imserver/handlermgr.go +++ b/server/imserver/handlermgr.go @@ -7,8 +7,6 @@ import ( type HandlerMgr struct { } -var handlerMgr = new (HandlerMgr) - func (this *HandlerMgr) Init() { cs.RegHandlerId(int(cs.CMMessageIdE__CMPing), PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMLogin), PLAYER_MGR_HANDLER_ID) diff --git a/server/imserver/playermgr.go b/server/imserver/playermgr.go index 4d52c539..151c6927 100644 --- a/server/imserver/playermgr.go +++ b/server/imserver/playermgr.go @@ -3,17 +3,38 @@ package main import ( "cs" "f5" + "time" ) type PlayerMgr struct { cs.MsgHandlerImpl } -var playerMgr = new (PlayerMgr) - func (this *PlayerMgr) CMLogin(hdr *f5.MsgHdr, msg *cs.CMLogin) { serverInfo := "192.168.100.39:1000" rspMsg := &cs.SMLogin{} rspMsg.ServerInfo = &serverInfo wspListener.sendProxyMsg(hdr.Conn, hdr.SocketHandle, rspMsg) } + +func (this *PlayerMgr) goReportServerState() { + for { + /* + params := q5.NewMxoObject() + params.SetXValue("node_id", q5.NewXInt32(1)) + params.SetXValue("instance_id", q5.NewXInt32(1)) + params.SetXValue("ip", q5.NewXString("192.168.100.39")) + params.SetXValue("port", q5.NewXInt32(8888)) + params.SetXValue("online_num", q5.NewXInt32(1)) + params.SetXValue("room_num", q5.NewXInt32(1)) + params.SetXValue("channel", q5.NewXInt32(0)) + params.SetXValue("alive_count", q5.NewXInt32(1)) + params.SetXValue("servicing", q5.NewXInt32(1)) + _, err := q5.HttpGet( + "http://192.168.100.45:7821/webapp/index.php?c=GS&a=report&", + params.AsXObject()) + fmt.Println(err); + */ + time.Sleep(time.Duration(1) * time.Second) + } +}