服务器未从 GO 中的 TCP 客户端接收数据

Question

你好，我在 GO 中实现了一个服务器，它从客户端读取数据并打印它。为了从网络流中读取，我从服务器上的 conn.Read() 方法中读取。下面是我从网络流中读取一个字节的代码// return a single byte after reading from bufferfunc readByte(conn net.Conn,buf []byte,numberofbytes *int,bufCurrPos *int) (byte){    fmt.Printf("Byte read")    if *bufCurrPos == *numberofbytes {        for {                *bufCurrPos = 0                *numberofbytes,_ = conn.Read(buf)                if *numberofbytes ==0 {                continue            } else {                break            }        }    }    b := buf[*bufCurrPos]    *bufCurrPos++    return b}现在我创建了两个将数据写入服务器的客户端。第一个客户端使用 conn.Write() 方法写入流，而第二个方法使用 fmt.Fprintf(bufio.NewWriter(),format string) 方法写入流。客户 1conn, err := net.Dial("tcp","localhost:8080")if err != nil {    checkError(err)}go readHandler(conn)for {    reader := bufio.NewReader(os.Stdin)    text, _ := reader.ReadString('\n')    conn.Write([]byte(text[0:len(text)-1]+"\r\n"))}客户 2 :name := "hi.txt"        contents := "bye"        exptime := 300000        conn, err := net.Dial("tcp", "localhost:8080")        if err != nil {                t.Error(err.Error()) // report error through testing framework        }        scanner := bufio.NewScanner(conn)        // Write a file        n,err := fmt.Fprintf(bufio.NewWriter(conn), "write %v %v %v\r\n%v\r\n", name, exptime, len(contents), contents)        if err !=nil {                fmt.Printf("error in writing in buffer\n")        }服务器使用第一个客户端正确读取数据，但对于第二个客户端，它总是读取 0 字节。我是 GO 初学者，不知道原因。有人可以帮我吗

Answer 1

client2 应用程序必须刷新缓冲区。

bw := bufio.NewWriter(conn)

n,err := fmt.Fprintf(bw, "write %v %v %v\r\n%v\r\n", name, exptime, len(contents), contents)

bw.Flush()

应用程序还应该检查错误。

bw := bufio.NewWriter(conn)

_, err := fmt.Fprintf(bw, "write %v %v %v\r\n%v\r\n", name, exptime, len(contents), contents)

if err != nil {

     // handle error

}

if err := bw.Flush(); err != nil {

     // handle error

}

fmt.Fprintf 在内部缓冲。如果这是对连接的唯一写入，则删除缓冲写入器。

_, err := fmt.Fprintf(conn, "write %v %v %v\r\n%v\r\n", name, exptime, len(contents), contents)

if err != nil {

    // handle error

}