有关golang tcp编程的一个问题

Question

问题描述：
lis.Accept()得到conn之后，bufio.NewReader(conn)是可以正常读取请求中数据的，之后bufio.NewWriter(conn)不知道为什么不能返回给客户端数据。是我哪里写错了吗？如果有问题的话，我要实现客户端、服务端互相传输数据，应该怎么写呢？有没有大神可以指导一下，感激不尽。

服务端代码

package main

import (
    "bufio"
    "fmt"
    "io"
    "net"
)

func main() {
    l, err := net.Listen("tcp", ":9091")
    if err != nil {
        fmt.Println("listen error:", err)
        return
    }
    for {
        c, err := l.Accept()
        if err != nil {
            fmt.Println("accept error:", err)
            break
        }
        go handle(c)
    }
}

func handle(c net.Conn) {
    temp := make([]byte, 6)
    rBuf := bufio.NewReader(c)
    n, err := rBuf.Read(temp)
    for err != io.EOF {
        if err != nil {
            fmt.Println("read error:", err)
            return
        }
        fmt.Printf("%d:%v\n", n, (string(temp)))
        temp = make([]byte, 6)
        n, err = rBuf.Read(temp)
    }
    /** 下面发送的代码无效，客户端read一直阻塞 **/
    ret := []byte("rrrs")
    wbuf := bufio.NewWriter(c)
    wbuf.Write(ret)
    wbuf.Flush()
}

Answer 1

func handle(c net.Conn) {
    go func() {
        temp := make([]byte, 6)
        rBuf := bufio.NewReader(c)
        for {
            n, err := rBuf.Read(temp)
            if err != nil {
                fmt.Println("read error:", err)
                return
            }
            fmt.Printf("%d:%v\n", n, (string(temp)))
       }
    }()
    ret := []byte("rrrs")
    wbuf := bufio.NewWriter(c)
    //下面一般要判断错误
    wbuf.Write(ret)
    wbuf.Flush()
}

Answer 2

为何不直接用conn的write

Answer 3

a.这段时间也在看go的tcp编程，也发觉了类似的问题，不过后来客户端主动关闭连接，即是告诉服务端不再有数据会发送了，或者结束（ctrl+c）服务端进程，服务端的信息就会全部返回给客户端，下面为客户端主动关闭连接的例子：

// 当客户端停止写入时, 需要告诉服务端, 信息发送终止, 服务端就返回全部的数据
if err = conn.CloseWrite(); err != nil {
    fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
    os.Exit(1)
}

b.也发现，服务端的设置，读取的缓冲长度，比如你的：

temp = make([]byte, 6)

如果缓冲写满时，不一定必须写满，服务端也会主动返回数据给客户端。但是也并非都是写满后才返回给客户端, 有可能提前返回数据, 需要一个协议。

c.这是原始的tcp编程，需要有一个协议protocol来控制。比如http协议常见的头信息，内容长度，版本等信息每次发送给服务端，告诉服务端要返回数据，按什么格式返回数据等。由于只是学习，没能在项目中使用，就没研究该怎么制定一种协议来保持通讯了。

d.要不然服务端是不知道你还要发送什么多少信息的，只能盲目的一直等待着，可以体验式的设置超时

// 超时时间, 当一定时间内客户端无请求发送, conn便会自动关闭
conn.SetReadDeadline(time.Now().Add(1 * time.Minute))

来模拟感受下了。