Go 如何编写 Swoole 的 客户端？

read可以不指定吧。看返回值，读取多少。

//处理连接Connection func handleReceive(conn net.Conn) { buf:=new(Buffer) buffer := make([]byte, 2048) tick:=time.Tick(time.Millisecond*200) for { <-tick n, err := conn.Read(buffer) if err != nil { buf.Reset() delete(clients,conn.RemoteAddr().String()); Log(conn.RemoteAddr().String(), "Connection Error:", err) return } buf.Write(buffer[:n]) //解析数据包 //读取定长8个字节i pLength:=8 pBuf:=make([]byte,pLength) for buf.Len()>=pLength{ if _,err:= buf.Read(pBuf,pLength);err==nil{ msg:=string(pBuf) Log(conn.RemoteAddr().String(), "Receive Data:\n",msg ) //conn.Write([]byte("ClientSend:"+msg)) } } } }

//处理连接Connection func handleReceive(conn net.Conn) {

buf:=new(Buffer)
buffer := make([]byte, 2048)
tick:=time.Tick(time.Millisecond*200)
for {
    <-tick
    n, err := conn.Read(buffer)
    if err != nil {
        buf.Reset()
        delete(clients,conn.RemoteAddr().String());
        Log(conn.RemoteAddr().String(), "Connection Error:", err)
        return
    }
    buf.Write(buffer[:n])
    //解析数据包
    //读取定长8个字节i
    pLength:=8
    pBuf:=make([]byte,pLength)
    for buf.Len()>=pLength{
        if _,err:= buf.Read(pBuf,pLength);err==nil{
            msg:=string(pBuf)
            Log(conn.RemoteAddr().String(), "Receive Data:\n",msg )
            //conn.Write([]byte("ClientSend:"+msg))
        }
    }
}

}

不会发代码，但发现回个车就行了。

SORRY我好像看错了，不是SOCKET

感谢你的回答

我的问题是这样的。我想用 GO TCP 连接 Swoole 服务端。但是在传输数据的时候遇到问题了。我弄了个 EOF 协议头。但我想学习了解下 如何使用 固定包头+包体协议 ，也就是 GO 这边组包和解包 是根据包头来判断的

下面是一段服务端从客户端接收数据包的简化代码：

func (self *ClientConn) recv() {
        var err error
        defer func() {
                if e := recover(); e != nil {
                }
                self.Close(false)
        }()

        _buf := make([]byte, 1)
        buf := make([]byte, 0)
        var bufLen uint32 = 0
        var readSize int
        var packet *pb.Packet
        for {
                deadline := time.Now().Add(hb * time.Second)
                self.conn.SetReadDeadline(deadline)
                readSize, err = self.conn.Read(_buf)
                if err != nil {
                        return
                }
                if readSize <= 0 {
                        continue
                }
                buf = append(buf, _buf[:readSize]...)
                bufLen += uint32(readSize)
                for {
                        if bufLen < pb.DATA_LEN_HEAD {
                                break
                        }
                        packLen := (uint32)(pb.BytesToUint16(buf[:pb.DATA_LEN_HEAD]))
                        if pb.HB_FLAG == packLen {
                                if err = self.onHeartBeat(); err != nil {
                                        return
                                }
                                buf = buf[pb.DATA_LEN_HEAD:]
                                bufLen -= pb.DATA_LEN_HEAD
                                continue
                        }
                        if packLen > pb.DATA_LEN_LIMIT || packLen < pb.DATA_LEN_HEAD {
                                err = fmt.Errorf("invalid packet length:%v, buf:%v, conn:%p", packLen, buf, self)
                                return
                        }
                        if bufLen < packLen {
                                break
                        }
                        packetData := buf[:packLen]
                        packet, err = self.unmarshalPacket(packetData)
                        if err != nil {
                                return
                        }
                        if err = self.OnRecvPacket(packet); err != nil {
                                return
                        }
                        buf = buf[packLen:]
                        bufLen -= packLen
                        continue
                }
        }
}