Zinx Learn

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15

//启动服务器方法
Start()
//停止服务器方法
Stop()
//开启业务服务方法 
//TODO Server.Serve() 是否在启动服务的时候 还要处理其他的事情呢 可以在这个方法里添加添加
Serve()

服务器获取客户端的连接步骤
//1 获取一个TCP的Addr
addr, err := net.ResolveTCPAddr(s.IPVersion, fmt.Sprintf("%s:%d", s.IP, s.Port))
//2 监听服务器地址
listenner, err:= net.ListenTCP(s.IPVersion, addr)
//3.1 阻塞等待客户端建立连接请求
conn, err := listenner.AcceptTCP()

1
2

//发送一个请求
conn,err := net.Dial("tcp", "127.0.0.1:7777")

1
2
3
4
5
6
7
8
9

//客户端
_, err := conn.Write([]byte("hello ZINX"))
buf :=make([]byte, 512)
cnt, err := conn.Read(buf)

//服务端
buf := make([]byte, 512)
cnt, err := conn.Read(buf)
err := conn.Write(buf[:cnt])

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//定义连接接口
type IConnection interface {
	//启动连接，让当前连接开始工作
	Start()
	//停止连接，结束当前连接状态M
	Stop()
	//从当前连接获取原始的socket TCPConn
	GetTCPConnection() *net.TCPConn
	//获取当前连接ID
	GetConnID() uint32
	//获取远程客户端地址信息
	RemoteAddr() net.Addr
}

//定义一个统一处理链接业务的接口
type HandFunc func(*net.TCPConn, []byte, int) error


type Connection struct {
	//当前连接的socket TCP套接字
	Conn *net.TCPConn
	//当前连接的ID 也可以称作为SessionID，ID全局唯一
	ConnID uint32
	//当前连接的关闭状态
	isClosed bool

	//该连接的处理方法api
	handleAPI ziface.HandFunc

	//告知该链接已经退出/停止的channel
	ExitBuffChan chan bool
}

//3.3 处理该新连接请求的 业务 方法， 此时应该有 handler 和 conn是绑定的
dealConn := NewConntion(conn, cid, CallBackToClient)
cid ++

//3.4 启动当前链接的处理业务
go dealConn.Start()

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

/*
	路由接口， 这里面路由是 使用框架者给该链接自定的 处理业务方法
	路由里的IRequest 则包含用该链接的链接信息和该链接的请求数据信息
*/
type IRouter interface{
	PreHandle(request IRequest)  //在处理conn业务之前的钩子方法
	Handle(request IRequest)	 //处理conn业务的方法
	PostHandle(request IRequest) //处理conn业务之后的钩子方法
}

//实现router时，先嵌入这个基类，然后根据需要对这个基类的方法进行重写
type BaseRouter struct {}

//这里之所以BaseRouter的方法都为空，
// 是因为有的Router不希望有PreHandle或PostHandle
// 所以Router全部继承BaseRouter的好处是，不需要实现PreHandle和PostHandle也可以实例化
func (br *BaseRouter)PreHandle(req ziface.IRequest){}
func (br *BaseRouter)Handle(req ziface.IRequest){}
func (br *BaseRouter)PostHandle(req ziface.IRequest){}

//3.3 处理该新连接请求的 业务 方法， 此时应该有 handler 和 conn是绑定的
dealConn := NewConntion(conn, cid, s.Router)
cid ++

//3.4 启动当前链接的处理业务
go dealConn.Start()

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14

type IMessage interface {
	GetDataLen() uint32	//获取消息数据段长度
	GetMsgId() uint32	//获取消息ID
	GetData() []byte	//获取消息内容

	SetMsgId(uint32)	//设计消息ID
	SetData([]byte)		//设计消息内容
	SetDataLen(uint32)	//设置消息数据段长度
}
type Message struct {
	Id      uint32 //消息的ID
	DataLen uint32 //消息的长度
	Data    []byte //消息的内容
}

1
2

//类型断言 接口转为
msg := msgHead.(*znet.Message) 

1
2
3
4
5
6
7

Apis map[uint32] ziface.IRouter

//路由功能：给当前服务注册一个路由业务方法，供客户端链接处理使用
AddRouter(router IRouter)  ---->  AddRouter(msgId uint32, router IRouter)

//int 转string
strconv.Itoa(int(msgId)))