diff --git a/server/imserver_new/listener/handlermgr.go b/server/imserver_new/listener/handlermgr.go index 730df999..bdc94ace 100644 --- a/server/imserver_new/listener/handlermgr.go +++ b/server/imserver_new/listener/handlermgr.go @@ -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) diff --git a/server/imserver_new/listener/wsplistener.go b/server/imserver_new/listener/wsplistener.go index a461252b..86bf8a69 100644 --- a/server/imserver_new/listener/wsplistener.go +++ b/server/imserver_new/listener/wsplistener.go @@ -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 {