package serverimport ( "net" "bufio" "ftj-data-synchro/protocol" "golang.org/x/text/transform" "golang.org/x/text/encoding/simplifiedchinese" "io/ioutil" "bytes" "ftj-data-synchro/logic" "fmt" "strconv")/* 客戶(hù)端結(jié)構(gòu)體 */type Client struct { DeviceID string  //客戶(hù)端連接的唯標(biāo)志 Conn  net.Conn  //連接 reader *bufio.Reader //讀取 writer *bufio.Writer //輸出 Data  []byte  //接收數(shù)據(jù)}func NewClient(conn *net.TCPConn) *Client { reader := bufio.NewReaderSize(conn, 10240) writer := bufio.NewWriter(conn) c := &Client{Conn:conn, reader:reader, writer:writer} return c}/** 數(shù)據(jù)讀取（粘包處理） */func (this *Client)read() { for {  var data []byte  var err error  //讀取指令頭 返回輸入流的前4個(gè)字節(jié)，不會(huì)移動(dòng)讀取位置  data, err = this.reader.Peek(4)  if len(data) == 0 || err != nil {   continue  }  //返回緩沖中現(xiàn)有的可讀取的字節(jié)數(shù)  var byteSize = this.reader.Buffered()  fmt.Printf("讀取字節(jié)長(zhǎng)度：%d/n", byteSize)  //生成一個(gè)字節(jié)數(shù)組，大小為緩沖中可讀字節(jié)數(shù)  data = make([]byte, byteSize)  //讀取緩沖中的數(shù)據(jù)  this.reader.Read(data)  fmt.Printf("讀取字節(jié)：%d/n", data)  //保存到新的緩沖區(qū)  for _, v := range data {   this.Data = append(this.Data, v)  }  if len(this.Data) < 4 {   //數(shù)據(jù)包緩沖區(qū)清空   this.Data = []byte{}   fmt.Printf("非法數(shù)據(jù)，無(wú)指令頭.../n")   continue  }  data, err = protocol.HexBytesToBytes(this.Data[:4])  instructHead, _ := strconv.ParseUint(string(data), 16, 16)  //指令頭效驗(yàn)  if uint16(instructHead) != 42330 {   fmt.Printf("非法數(shù)據(jù)/n")   //數(shù)據(jù)包緩沖區(qū)清空   this.Data = []byte{}   continue  }  data = this.Data[:protocol.HEADER_SIZE]  var p = protocol.Decode(data)  fmt.Printf("消息體長(zhǎng)度：%d/n", p.Len)  var bodyLength = len(this.Data)    /**   判斷數(shù)據(jù)包緩沖區(qū)的大小是否小于協(xié)議請(qǐng)求頭中數(shù)據(jù)包大小   如果小于，等待讀取下一個(gè)客戶(hù)端數(shù)據(jù)包，否則對(duì)數(shù)據(jù)包解碼進(jìn)行業(yè)務(wù)邏輯處理   */  if int(p.Len) > len(this.Data) - protocol.HEADER_SIZE {   fmt.Printf("body體長(zhǎng)度：%d,讀取的body體長(zhǎng)度：%d/n", p.Len, bodyLength)   continue  }  fmt.Printf("實(shí)際處理字節(jié)：%v/n", this.Data)  p = protocol.Decode(this.Data)  //邏輯處理  go this.logicHandler(p)  //數(shù)據(jù)包緩沖區(qū)清空  this.Data = []byte{} }}

type Client struct { DeviceID string  //客戶(hù)端連接的唯標(biāo)志 Conn  net.Conn  //連接 reader *bufio.Reader //讀取 writer *bufio.Writer //輸出 Data  []byte  //接收數(shù)據(jù)}