server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-08-17 07:22:31 +08:00
parent 4d7dbb1175
commit 184c7e2f85
6 changed files with 31 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
server/imserver/app.go
View File

@ -2,6 +2,7 @@ package main
import ( import (
"cs" "cs"
"ss"
"f5" "f5"
"mt" "mt"
"q5" "q5"
@ -39,15 +40,25 @@ func (this *App) Update() {
next := this.netMsgQueue.WorkList.Next() next := this.netMsgQueue.WorkList.Next()
hdr, ok := next.GetData().(*f5.MsgHdr) hdr, ok := next.GetData().(*f5.MsgHdr)
if ok { if ok {
handler := cs.GetNetMsgHandler(hdr.MsgId) if hdr.MsgId < 100 {
if handler != nil { handler := ss.GetNetMsgHandler(hdr.MsgId)
switch handler.HandlerId { if handler != nil {
case PLAYER_MGR_HANDLER_ID: switch handler.HandlerId {
cs.DispatchMsg(handler, hdr, playerMgr) case WSP_LISTENER_HANDLER_ID:
case PLAYER_HANDLER_ID: ss.DispatchMsg(handler, hdr, wspListener)
player := playerMgr.getPlayerBySocket(hdr.GetSocket()) }
if player != nil { }
cs.DispatchMsg(handler, hdr, player) } else {
handler := cs.GetNetMsgHandler(hdr.MsgId)
if handler != nil {
switch handler.HandlerId {
case PLAYER_MGR_HANDLER_ID:
cs.DispatchMsg(handler, hdr, playerMgr)
case PLAYER_HANDLER_ID:
player := playerMgr.getPlayerBySocket(hdr.GetSocket())
if player != nil {
cs.DispatchMsg(handler, hdr, player)
}
} }
} }
} }

1
server/imserver/constant.go
View File

@ -3,6 +3,7 @@ package main
const ( const (
PLAYER_MGR_HANDLER_ID = 1 PLAYER_MGR_HANDLER_ID = 1
PLAYER_HANDLER_ID = 2 PLAYER_HANDLER_ID = 2
WSP_LISTENER_HANDLER_ID = 3
) )
const ( const (

3
server/imserver/handlermgr.go
View File

@ -9,7 +9,8 @@ type HandlerMgr struct {
} }
func (this *HandlerMgr) init() { func (this *HandlerMgr) init() {
ss.RegHandlerId(int(ss.SSMessageIdE__SS_Ping), PLAYER_MGR_HANDLER_ID) ss.RegHandlerId(int(ss.SSMessageIdE__SS_Ping), WSP_LISTENER_HANDLER_ID)
ss.RegHandlerId(int(ss.SSMessageIdE__SS_WSP_SocketDisconnect), WSP_LISTENER_HANDLER_ID)
cs.RegHandlerId(int(cs.CMMessageIdE__CMPing), PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMPing), PLAYER_MGR_HANDLER_ID)
cs.RegHandlerId(int(cs.CMMessageIdE__CMLogin), PLAYER_MGR_HANDLER_ID) cs.RegHandlerId(int(cs.CMMessageIdE__CMLogin), PLAYER_MGR_HANDLER_ID)

3
server/imserver/proto/ss_msgid.proto
View File

@ -10,8 +10,5 @@ enum SSMessageId_e
_SS_Pong = 9; _SS_Pong = 9;
_SS_WSP_SocketDisconnect = 10; _SS_WSP_SocketDisconnect = 10;
_SS_WSP_RequestTargetServer = 11;
_SS_MS_ResponseTargetServer = 12;
_SS_ForceCloseSocket = 13; _SS_ForceCloseSocket = 13;
} }

16
server/imserver/proto/ss_proto.proto
View File

@ -16,22 +16,6 @@ message SS_WSP_SocketDisconnect
{ {
} }
message SS_WSP_RequestTargetServer
{
optional int64 context_id = 1;
optional string account_id = 2;
optional string team_id = 3;
}
message SS_MS_ResponseTargetServer
{
optional int32 error_code = 1;
optional string error_msg = 2;
optional int64 context_id = 3;
optional string host = 4;
optional int32 port = 5;
}
message SS_ForceCloseSocket message SS_ForceCloseSocket
{ {
} }

8
server/imserver/wsplistener.go
View File

@ -7,12 +7,14 @@ import (
"q5" "q5"
"f5" "f5"
"cs" "cs"
"ss"
"mt" "mt"
proto "github.com/golang/protobuf/proto" proto "github.com/golang/protobuf/proto"
) )
type WSPListener struct { type WSPListener struct {
ss.MsgHandlerImpl
listener net.Listener listener net.Listener
ch chan *f5.MsgHdr ch chan *f5.MsgHdr
msgList q5.ListHead msgList q5.ListHead
@ -34,6 +36,12 @@ func (this *WSPListener) init() {
func (this *WSPListener) unInit() { func (this *WSPListener) unInit() {
} }
func (this *WSPListener) SS_ping(hdr *f5.MsgHdr, msg *ss.SS_Ping) {
}
func (this *WSPListener) SS_WSP_SocketDisconnect(hdr *f5.MsgHdr, msg *ss.SS_WSP_SocketDisconnect) {
}
func (this *WSPListener) accept() { func (this *WSPListener) accept() {
fmt.Println("accpet") fmt.Println("accpet")
for { for {