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

1

Browse Source
This commit is contained in:
aozhiwei 2024-04-05 14:23:56 +08:00
parent 4059a1c207
commit 571ea3655d
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
server/imserver_new/listener/handlermgr.go
View File

@ -12,6 +12,7 @@ type HandlerMgr struct {
func (this *HandlerMgr) Init() {
ss.RegHandlerId(int(ss.SSMessageIdE__SS_Ping), constant.WSP_LISTENER_HANDLER_ID)
ss.RegHandlerId(int(ss.SSMessageIdE__SS_WSP_SocketDisconnect), constant.WSP_LISTENER_HANDLER_ID)
ss.RegHandlerId(int(ss.SSMessageIdE__SS_HttpTunnelRequest), constant.WSP_LISTENER_HANDLER_ID)
cs.RegHandlerId(int(cs.CMMessageIdE__CMLogin), constant.PLAYER_MGR_HANDLER_ID)
cs.RegHandlerId(int(cs.CMMessageIdE__CMReconnect), constant.PLAYER_MGR_HANDLER_ID)

8
server/imserver_new/listener/wsplistener.go
View File

@ -47,6 +47,14 @@ func (this *WSPListener) SS_WSP_SocketDisconnect(hdr *f5.MsgHdr, msg *ss.SS_WSP_
GetPlayerMgr().OnSocketClose(hdr.GetSocket())
}
func (this *WSPListener) SS_HttpTunnelRequest(hdr *f5.MsgHdr, msg *ss.SS_HttpTunnelRequest) {
rspMsg := new(ss.SS_HttpTunnelResponse)
rspMsg.ContextId = msg.ContextId
rspMsg.SocketHandle = msg.SocketHandle
rspMsg.Response = proto.String("hello")
this.SendProxyMsg(hdr.Conn, 0, rspMsg)
}
func (this *WSPListener) accept() {
fmt.Println("accpet")
for {