Go语言网络编程实战：构建基于TCP的简单通信协议

type packet struct {
    // 字段名必须大写，以便encoding/binary包能够访问。
    // 使用明确指定大小的类型（如int32而非int）是最佳实践，
    // 以确保跨平台和架构的数据一致性。
    Type int32
    Id   int32
    // Data字段必须是固定大小的数组（如[100]byte），
    // 而不是切片（[]byte），以便encoding/binary可以直接将其映射到内存。
    Data [100]byte
}

package main

import (
    "encoding/binary"
    "fmt"
    "net"
)

// packet结构体定义同上
type packet struct {
    Type int32
    Id   int32
    Data [100]byte
}

func main() {
    // 在端口2000上设置一个TCP监听器
    l, err := net.Listen("tcp", ":2000")
    if err != nil {
        // 生产环境中应避免使用panic，而是进行更健壮的错误处理和日志记录
        panic(err.Error())
    }
    defer l.Close() // 确保监听器在main函数退出时关闭，释放端口资源

    fmt.Println("服务器已启动，监听端口2000...")

    for {
        // 阻塞等待新的客户端连接。当有客户端尝试连接时，Accept会返回一个net.Conn对象
        conn, err := l.Accept()
        if err != nil {
            fmt.Printf("接受连接失败: %s\n", err.Error())
            continue // 继续等待下一个连接
        }
        // 使用goroutine并发处理客户端连接，避免阻塞主循环，从而支持多客户端连接
        go handleClient(conn)
    }
}

func handleClient(conn net.Conn) {
    defer conn.Close() // 确保连接在函数退出时关闭，释放资源

    fmt.Printf("客户端 %s 已连接\n", conn.RemoteAddr().String())

    // 等待并读取客户端发送的数据包
    var msg packet
    // 使用binary.Read从连接中读取二进制数据并反序列化到msg结构体中
    // binary.BigEndian指定字节序为大端序
    err := binary.Read(conn, binary.BigEndian, &msg)
    if err != nil {
        fmt.Printf("读取数据失败: %s\n", err.Error())
        return
    }
    // 将接收到的Data字段（字节数组）转换为字符串并打印。
    // 由于Data是固定大小数组，可能包含零值填充，需要注意截断或处理。
    receivedData := string(msg.Data[:])
    fmt.Printf("收到来自 %s 的数据包 (类型: %d, ID: %d): %s\n",
        conn.RemoteAddr().String(), msg.Type, msg.Id, receivedData)

    // 准备并发送响应数据包
    response := packet{Type: 1, Id: 1}
    // 将字符串复制到固定大小的字节数组中。如果字符串长度超过数组容量，会被截断。
    copy(response.Data[:], "Hello, client from server!")
    // 使用binary.Write将response结构体序列化为二进制数据并写入连接
    err = binary.Write(conn, binary.BigEndian, &response)
    if err != nil {
        fmt.Printf("发送响应失败: %s\n", err.Error())
        return
    }
    fmt.Printf("已向 %s 发送响应\n", conn.RemoteAddr().String())
}

package main

import (
    "encoding/binary"
    "fmt"
    "net"
    "strings" // 用于处理字符串截断
)

// packet结构体定义同上
type packet struct {
    Type int32
    Id   int32
    Data [100]byte
}

func main() {
    // 连接到本地服务器的2000端口
    conn, err := net.Dial("tcp", "localhost:2000")
    if err != nil {
        panic(err.Error()) // 生产环境中应避免使用panic
    }
    defer conn.Close() // 确保连接在main函数退出时关闭

    fmt.Println("已连接到服务器...")

    // 准备并发送一个数据包
    msg := packet{Type: 0, Id: 0}
    // 将字符串复制到数据载荷中。确保不超过Data数组的长度。
    messageToSend := "Hello, server from client!"
    copy(msg.Data[:], messageToSend)
    // 序列化并发送数据包
    err = binary.Write(conn, binary.BigEndian, &msg)
    if err != nil {
        panic(err.Error())
    }
    fmt.Printf("已发送数据包: \"%s\"\n", messageToSend)

    // 接收服务器的响应数据包
    var response packet
    // 反序列化接收到的数据
    err = binary.Read(conn, binary.BigEndian, &response)
    if err != nil {
        panic(err.Error())
    }
    // 将接收到的Data字段（字节数组）转换为字符串并打印。
    // 使用strings.TrimRight去除可能存在的零值填充，确保输出干净。
    receivedResponse := strings.TrimRight(string(response.Data[:]), "\x00")
    fmt.Printf("收到服务器响应 (类型: %d, ID: %d): \"%s\"\n",
        response.Type, response.Id, receivedResponse)
}