项目章节

• ch01

  基础的server

• ch02

  将ch01 里的硬编码的Connection改成Connection

• ch03

  将ch02里的硬编码的clientCallback改成Router

• ch04

  将硬编码的ip,port等改成从配置文件里读出来

• ch05

  标识域（Tag）+长度域（Length）+值域（Value），简称TLV格式。

  TLV 是一种可变的格式，其中：

  T 可以理解为 Tag 或 Type ，用于标识标签或者编码格式信息； L 定义数值的长度； V 表示实际的数值。 T 和 L 的长度固定，一般是2或4个字节，V 的长度由 Length 指定。

• ch06 多路由

• ch07 消息的读写分离

之前的章节里的所有的消息的读和写都是放在StartReader()这个方法里的， 现在要将读放到StartReader()而写放到StartWriter()里， StartReader()和StartWriter()是2个协程

封装消息格式，以及进行消息的封包，拆包处理
消息格式

消息定义	字节数
消息头长度	4
消息ID	4
消息体	消息长度

消息=消息头+消息体

消息头 ： 消息头长度+ 消息ID 消息体

DataPack 对消息进行拆包和封包

测试 DataPack

• ch08 消息队列和工作池机制

10 个 task,每个task 有自己的 taskQueue 实现将消息放到taskqueue里

 type Task struct{
    //task里有一个队列
    TaskQueue chan ziface.IRequest
 }

type TaskPool struct{
   Tasks []Task
}

流程

go self.MsgHandler.Process(request)

改成

self.MsgHandler.SendMsgToTaskQueue(request)

• ch09 实现连接的管理

连接的管理有几个功能

1. 拒绝超过最大的连接数的连接
2. 提供连接连上的hook函数

第44讲：我看完后将CallonConnStart的hook放到了NewConnection里 导致了测试

func OnConnConnected(conn ziface.IConnection) {
	fmt.Println("connId=",conn.GetConnId(), "is connected")
	resp := fmt.Sprintf("[zinx server] welcome connId=%d", conn.GetConnId())
	//这步一直阻塞，为什么？
	conn.Send(200, []byte(resp))
}

3. 连接断开后的hook函数

删除map里的元素，要使用delete() delete() 函数用于删除集合的元素, 参数为 map 和其对应的 key

delete(self.conns,connId)
//self.conns[connId] = nil

go语言的总结

go并发

goroutine 类似于线程，但是可以根据需要创建多个 goroutine 并发工作。 goroutine 是由 Go 语言的运行时调度完成，而线程是由操作系统调度完成 goroutine 是一种非常轻量级的实现，可在单个进程里执行成千上万的并发任务，它是Go语言并发设计的核心

goroutine 在多核 cpu 环境下是并行的，如果代码块在多个 goroutine 中执行，那么我们就实现了代码的并行。

使用普通函数创建 goroutine 格式 ： go 函数名( 参数列表 )

func main() {
    go func() {
 		fmt.Println("in go func ")
 	}()
 
 	fmt.Println("in go main ")
 
 	select {}
}

所有 goroutine 在 main() 函数结束时会一同结束。

协程/线程 协程：独立的栈空间，共享堆空间，调度由用户自己控制，本质上有点类似于用户级线程， 这些用户级线程的调度也是自己实现的。

线程：一个线程上可以跑多个协程，协程是轻量级的线程。

上面的不是很理解，协程讲的不就是java的线程？

channel channel 是Go语言在语言级别提供的 goroutine 间的通信方式。 我们可以使用 channel 在两个或多个 goroutine 之间传递消息。

对比java 中管道用于2个流之间的数据传输

channel 是类型相关的，也就是说，一个 channel 只能传递一种类型的值，这个类型需要在声明 channel 时指定

ci := make(chan int)
cs := make(chan string)
cf := make(chan interface{})

命名规则

• 包名称

  保持package的名字和目录保持一致，包名应该为小写单词，不要使用下划线或者混合大小写

• 文件命名 应该为小写单词，使用下划线分隔各个单词

• 结构体命名 采用驼峰命名法，首字母根据访问控制大写或者小写

• 接口命名 文件为

Zinx的GoPath

GOPATH是一个开发环境目录的意思，下面必须包含bin、pkg、src，然后再src下面新建项目zinx project setting 里的gopath设置成 D:\dev-code\my_github_code\go

告别GOPATH，快速使用 go mod（Golang包管理工具） go mod 类似java的maven 使用go mod 管理项目，就不需要非得把项目放到GOPATH指定目录下，你可以在你磁盘的任何位置新建一个项目。

步骤

1. 新建一个名为 wserver 的项目，项目路径 D:\test\wserver
2. 进入项目目录 D:\test\wserver 里，新建一个 go源码文件： main.go
3. go mod init wserver

注意： GOPROXY 需要设置，默认的从https://proxy.golang.org/下载 包下载路径是在 C:\Users\sdrag\go\pkg\mod\cache\download
目前还不知道如何更改

idea的project setting->go->go modules里 enviroments 点击后加入GOPROXY , 值填入 https://proxy.golang.org/ 填写完毕后需要重启

字节数组

 //直接字符串转成字节数组
 []byte("i love you")

defer

这些调用直到 return 前才被执。因此，可以用来做资源清理。 多个defer语句，按先进后出的方式执行。

用途

1. 关闭文件句柄
2. 锁资源释放
3. 数据库连接释放

type定义

用途

1. 定义struct

  type User struct{}

2. 定义interface

 type IUser interface{} 

3. 定义func

 type HandleFunc func()

golang -- 网络编程

channel

Channel 类型的定义格式如下

  ChannelType = ( "chan" | "chan" "<-" | "<-" "chan" ) ElementType .

它包括三种类型的定义。可选的<-代表channel的方向。如果没有指定方向，那么Channel就是双向的，既可以接收数据，也可以发送数据。

e.g

ExitChan chan bool
MsgChan chan []byte

解码

①使用bytes.NewReader/bytes.Buffer来存储要解码的ascii串

②使用binary.Read来解码

go 语言测试

问题记录

1. ch01 里的server 如果发生了错误

        addr,err:=net.ResolveTCPAddr(self.TCPVersion,fmt.Sprintf("%s:%d",self.IP,self.Port))
   	if err!=nil{
           //这里发生了错误
   		fmt.Println("resolve tcp addr error:",err)
           //但是照样会打印出start Zinx server success，因为用了go func(){}()处理
           //该怎么改？
           return 
   	}

2. ch03 我将PingRouter的逻辑写到一个pingrouter.go里 再在server.go的main里写为啥不行，会报

D:\dev-code\my_github_code\go\src\zinx\ch03\demo\Zinx_ch03>go run server.go # command-line-arguments .\server.go:7:15: undefined: PingRouter

提供两种解决办法

• 一是同时编译两个文件

go run main.go quickSort.go

• 二是直接运行整个 package ，编译器会自己找到入口。

go run ./