ziface

Documentation

Index

• type HandleFunc
• type IConnection
• type IDataPack
• type IMessage
• type IRequest
• type IRouter
• type IServer

Types

type HandleFunc

type HandleFunc func(*net.TCPConn, []byte, int) error

定义一个处理链接业务的方法

type IConnection

type IConnection interface {
	//启动链接，让当前的链接准备开始工作
	Start()
	//停止链接，结束当前链接的工作
	Stop()
	//获取当前链接的绑定socket conn
	GetTCPConnection() *net.TCPConn
	//获取当前链接模块的链接ID
	GetConnID() uint32
	//获取远程客户端的TCP状态 IP port
	GetRemoteAddr() net.Addr
	//发送数据，将数据发送给远程的客户端
	SendMsg(msgId uint32, data []byte) error
}

定义连接模块的抽象层

type IDataPack

type IDataPack interface {
	//获取包的长度方法
	GetHeadLen() uint32
	//封包方法
	Pack(msg IMessage) ([]byte, error)
	//拆包方法
	Unpack([]byte) (IMessage, error)
}

type IMessage

type IMessage interface {
	//获取消息的ID
	GetMsgId() uint32
	//获取消息的长度
	GetMsgLen() uint32
	//获取消息的内容
	GetData() []byte
	//设置消息的ID
	SetMsgId(uint32)
	//设置消息的长度
	SetMsgLen(uint32)
	//设置消息的内容
	SetData([]byte)
}

将请求的消息封装到一个Message中，定义抽象的接口。

type IRequest

type IRequest interface {
	//得到当前链接
	GetConnection() IConnection
	//得到请求的消息数据
	GetData() []byte
	//得到请求的消息ID
	GetMsgID() uint32
}

type IRouter

type IRouter interface {
	//处理之前的方法
	BeforeHandle(request IRequest)
	//处理时的方法
	Handle(request IRequest)
	//处理后的方法
	AfterHandle(request IRequest)
}

路由的抽象接口,

type IServer

type IServer interface {
	//启动服务器
	Start()
	//停止服务器
	Stop()
	//运行服务器
	Serve()
	//添加路由
	AddRouter(router IRouter)
}

定义一个服务器接口