深入理解Go语言bufio与Unix域套接字：确保消息可靠传输

package main

import (
    "bufio"
    "fmt"
    "net"
    "os"
    "time"
)

func main() {
    // 注册服务器套接字
    socketPath := "serversock"
    os.Remove(socketPath) // 确保套接字文件不存在
    socket, err := net.ListenUnix("unix", &net.UnixAddr{socketPath, "unix"})
    if err != nil {
        panic(err)
    }
    defer socket.Close() // 确保服务器套接字关闭

    // 服务器端：在一个goroutine中接受连接并读取数据
    go func() {
        for {
            conn, err := socket.Accept()
            if err != nil {
                // 忽略在socket关闭时可能出现的错误
                if netErr, ok := err.(net.Error); ok && netErr.Temporary() {
                    fmt.Println("服务器：临时接受错误:", err)
                    continue
                }
                fmt.Println("服务器：接受连接错误:", err)
                return // 退出循环
            }
            fmt.Println("服务器：已接受连接")

            reader := bufio.NewReader(conn)
            line, err := reader.ReadString(byte('\n')) // 尝试读取一行
            if err != nil {
                fmt.Println("服务器：读取错误", err)
                conn.Close()
                continue
            }
            fmt.Println("服务器：收到消息:", line)
            conn.Close() // 读取完毕后关闭连接
        }
    }()

    // 客户端：连接服务器并发送消息
    time.Sleep(100 * time.Millisecond) // 确保服务器已启动并监听
    conn, err := net.DialUnix("unix", nil, &net.UnixAddr{socketPath, "unix"})
    if err != nil {
        panic(err)
    }
    defer conn.Close() // 确保客户端连接关闭

    writer := bufio.NewWriter(conn)
    n, err := writer.WriteString("hello world\n") // 写入数据到缓冲区
    if err != nil {
        panic(err)
    }
    fmt.Printf("客户端：已写入 %d 字节到缓冲区\n", n)

    // 客户端等待，给服务器处理时间
    time.Sleep(1 * time.Second)
}

客户端：已写入 13 字节到缓冲区
服务器：已接受连接

// ... 客户端连接和写入部分 ...
writer := bufio.NewWriter(conn)
n, err := writer.WriteString("hello world\n")
if err != nil {
    panic(err)
}
fmt.Printf("客户端：已写入 %d 字节到缓冲区\n", n)

// 关键步骤：显式刷新缓冲区，将数据发送出去
err = writer.Flush()
if err != nil {
    panic(err)
}
fmt.Println("客户端：缓冲区已刷新，数据已发送")
// ... 客户端等待 ...

客户端：已写入 13 字节到缓冲区
客户端：缓冲区已刷新，数据已发送
服务器：已接受连接
服务器：收到消息: hello world