使用GoLang开发游戏服务器(七)

读写分离模型

  • 之前的框架要发送消息,直接就发送出去了
  • 现在需要将写消息单独拿出来,和读消息分离开
  • 使用channel管道传递数据
    在这里插入图片描述
  • 新增写数据的方法
func (c *Connection) StartWriter() {
	fmt.Println("Writer Goroutine Start...")
	defer fmt.Println("Writer is Exit Remote Addr is:", c.RemoteAddr().String())
	for true {
		select {
		case data := <-c.MsgChan:
			if _, err := c.Conn.Write(data); err != nil {
				fmt.Println("Send Data Error", err)
				return
			}
		case <-c.ExitChan:
			return
		}
	}
}
  • 修改发送消息方法
func (c *Connection) SendMsg(msgID uint32, data []byte) error {
	if c.isClosed {
		return errors.New("connection closed when sendMsg")
	}
	dp := NewDataPack()
	buffer, err := dp.Pack(NewMessage(msgID, data))
	if err != nil {
		fmt.Println(err)
		return err
	}

	c.MsgChan <- buffer

	return nil
}

对于有客户端断开连接,也是使用channel管道进行通讯,在reader中,如果读数据出错,证明有客户端断开了连接,此时需要发送给writer告知writer关闭
在这里插入图片描述
在这里插入图片描述

测试

和之前的测试代码相同,可以实现读写操作