0721从最原始案例代码中的ReadPkg分析socket的标准化通信流程

先上代码：

//这里将这些方法关联到结构体中
type Transfer struct {
//分析它应该有哪些字段
Conn net.Conn
Buf [8096]byte //这时传输时，使用缓冲
}

func (this *Transfer) ReadPkg() (mes message.Message, err error) {

//buf := make([]byte, 8096)
fmt.Println("读取客户端发送的数据...")
//conn.Read 在conn没有被关闭的情况下，才会阻塞
//如果客户端关闭了 conn 则，就不会阻塞
_, err = this.Conn.Read(this.Buf[:4])
if err != nil {
	//err = errors.New("read pkg header error")
	return
}
//根据buf[:4] 转成一个 uint32类型
var pkgLen uint32
pkgLen = binary.BigEndian.Uint32(this.Buf[0:4])
//根据 pkgLen 读取消息内容
n, err := this.Conn.Read(this.Buf[:pkgLen])
if n != int(pkgLen) || err != nil {
	//err = errors.New("read pkg body error")
	return 
}
//把pkgLen 反序列化成 -> message.Message
// 技术就是一层窗户纸 &mes！！
err = json.Unmarshal(this.Buf[:pkgLen], &mes)
if err != nil {
	fmt.Println("json.Unmarsha err=", err)
	return 
}
return 
}

func (this *Transfer) WritePkg(data []byte) (err error) {

//先发送一个长度给对方
var pkgLen uint32
pkgLen = uint32(len(data)) 
//var buf [4]byte
binary.BigEndian.PutUint32(this.Buf[0:4], pkgLen)
// 发送长度
n, err := this.Conn.Write(this.Buf[:4])
if n != 4 || err != nil {
	fmt.Println("conn.Write(bytes) fail", err)
	return 
}

//发送data本身
n, err = this.Conn.Write(data)
if n != int(pkgLen) || err != nil {
	fmt.Println("conn.Write(bytes) fail", err)
	return 
}
return 
}

首先还有另一个基于串口通信的参考案例，那就是华为ups6000项目的开发说明书，从这个新项目中也可以验证一次安全的socket通信函数内可进行多次conn.read()操作，第一次读取往往都是为了验证数据的有效性，第二次才是读取真实的数据：

华为6000通信步骤：
1.首先发送查询modbus码
2.等待下位机返回响应modbus码,获得后证明设备在线状态正常
3.发送其他需求对应的功能modbus码
4.下位机对功能码进行响应（如开关门，改变设备参数）
5.下位机完成响应后，返回响应状态码
6.上位机获得响应状态码，翻译后汇报给ui或用户，必要时进行相应的记录

虽然是串口通信，但是和tcp网络通信一样，都遵循一切皆文件原则与数据单行道原则，在设计通信规则时，二者是同样的套路

而这套路正是上面所描述的“通信步骤”

补充，上面展示了华为的“通信步骤”，而Transfer结构体与Transfer结构体的读写方法并不是某种通信规则（Transfer对应的通信规则是tcp-socket）的“通信步骤”，而是组成某种通信需求所需要去设计的“通信步骤”的氨基酸（可将某个完整的“通信步骤”比喻成蛋白质，而Transfer的读写方法是氨基酸）