akWebNet

Documentation

Index

• Constants
• Variables
• func BinaryMessageFunc(sess *WebSession, msg *wsMessage)
• func BroadCastMsgExceptID(msgid int, msgparams []uint32)
• func BroadCastMsgExceptSession(selfsess *WebSession, bMsg2Me bool, msgid int, msgparams []uint32)
• func CloseMessageFunc(sess *WebSession, msg *wsMessage)
• func GetMessageHandler(id int) receiveMsgProc
• func HeartBeat(sess *WebSession, data []uint32) (error, bool)
• func MsgRegister(id int, cb WsCallback)
• func PingMessageFunc(sess *WebSession, msg *wsMessage)
• func PongMessageFunc(sess *WebSession, msg *wsMessage)
• func SendMsg(sess *WebSession, msgid int, msgparams []uint32)
• func TextMessageFunc(sess *WebSession, msg *wsMessage)
• type WebSession
  • func NewWebSession(conn *websocket.Conn, off chan *WebSession) *WebSession
  • func (this *WebSession) GetId() uint32
  • func (this *WebSession) Handle()
  • func (this *WebSession) SetId(id uint32)
  • func (this *WebSession) Write(msgtype int, data []byte)
• type WebSocketSvr
  • func NewWebsocketSvr(addr string) *WebSocketSvr
  • func (this *WebSocketSvr) Run()
• type WsCallback
  • func GetGameLogicProcMsg(id int) WsCallback

Constants

const (
	MID_login          = 1  //上线 (获取自己的数据)
	MID_logout         = 2  //离线
	MID_move           = 3  //移动
	MID_Bump           = 4  //撞击
	MID_HeartBeat      = 5  //心跳
	MID_StarBorn       = 6  //星星出生
	MID_GM             = 7  //gm
	MID_Online4Other   = 8  //上线获取别人数据显示或者广播自己数据给别人显示
	MID_Register       = 9  //注册
	MID_SyncPos        = 10 //同步位置
	MID_MonsterInfo    = 11 //同步moster信息
	MID_LogicFrameSync = 12 //逻辑帧同步其他客户端moster信息
)

message ID

const (
	MsgSendType_P2P       = 1 //点对点 直接发送
	MsgSendType_BroadCast = 2 //广播
)

Variables

var (
	GwebSessionMgr *wsClientSession
)

Functions

func BinaryMessageFunc

func BinaryMessageFunc(sess *WebSession, msg *wsMessage)

func BroadCastMsgExceptID

func BroadCastMsgExceptID(msgid int, msgparams []uint32)

func BroadCastMsgExceptSession

func BroadCastMsgExceptSession(selfsess *WebSession, bMsg2Me bool, msgid int, msgparams []uint32)

广播消息

@param 1: 自身会话
@param 2：是否不给自己广播
@param 3：消息ID
@param 4：消息参数

func CloseMessageFunc

func CloseMessageFunc(sess *WebSession, msg *wsMessage)

func GetMessageHandler

func GetMessageHandler(id int) receiveMsgProc

func HeartBeat

func HeartBeat(sess *WebSession, data []uint32) (error, bool)

func MsgRegister

func MsgRegister(id int, cb WsCallback)

func PingMessageFunc

func PingMessageFunc(sess *WebSession, msg *wsMessage)

func PongMessageFunc

func PongMessageFunc(sess *WebSession, msg *wsMessage)

func SendMsg

func SendMsg(sess *WebSession, msgid int, msgparams []uint32)

func TextMessageFunc

func TextMessageFunc(sess *WebSession, msg *wsMessage)

Types

type WebSession

type WebSession struct {
	RemoteAddr string

	IdCh *uint32
	// contains filtered or unexported fields
}

func NewWebSession

func NewWebSession(conn *websocket.Conn, off chan *WebSession) *WebSession

func (*WebSession) GetId

func (this *WebSession) GetId() uint32

func (*WebSession) Handle

func (this *WebSession) Handle()

func (*WebSession) SetId

func (this *WebSession) SetId(id uint32)

func (*WebSession) Write

func (this *WebSession) Write(msgtype int, data []byte)

type WebSocketSvr

type WebSocketSvr struct {
	Addr string
	// contains filtered or unexported fields
}

func NewWebsocketSvr

func NewWebsocketSvr(addr string) *WebSocketSvr

func (*WebSocketSvr) Run

func (this *WebSocketSvr) Run()

type WsCallback

type WsCallback func(ws *WebSession, data []uint32) (error, bool)

func GetGameLogicProcMsg

func GetGameLogicProcMsg(id int) WsCallback