Go语言网络编程：构建自定义二进制协议的客户端与服务器

type packet struct {
    // 字段名必须大写，以便encoding/binary包能够访问和编解码。
    // 使用显式指定大小的类型（如int32而非int），确保跨平台和架构的一致性。
    Type int32
    Id   int32
    // 数据载荷必须是固定大小的数组，而非切片，
    // 因为encoding/binary需要知道确切的内存布局来读写。
    Data [100]byte
}

package main

import (
    "encoding/binary"
    "fmt"
    "net"
    "log" // 引入log包进行更专业的错误处理
)

// packet 结构体定义同上

func main() {
    // 设置一个在2000端口的TCP监听器
    l, err := net.Listen("tcp", ":2000")
    if err != nil {
        log.Fatalf("监听失败: %v", err) // 使用log.Fatalf替代panic
    }
    defer l.Close() // 确保监听器在main函数退出时关闭

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

    for {
        // 开始监听新的连接
        conn, err := l.Accept()
        if err != nil {
            log.Printf("接受连接失败: %v", err) // 记录错误并继续监听
            continue
        }
        // 对于每个新连接，启动一个goroutine来处理，实现并发
        go handleClient(conn)
    }
}

func handleClient(conn net.Conn) {
    defer func() {
        conn.Close() // 确保连接在函数退出时关闭
        log.Printf("客户端连接 %s 已关闭。", conn.RemoteAddr())
    }()

    log.Printf("新客户端连接来自: %s", conn.RemoteAddr())

    // 等待客户端发送数据包
    var msg packet
    // 使用binary.Read从连接中读取二进制数据到msg结构体，使用大端字节序
    err := binary.Read(conn, binary.BigEndian, &msg)
    if err != nil {
        log.Printf("从 %s 读取数据包失败: %v", conn.RemoteAddr(), err)
        return
    }
    // 将收到的数据转换为字符串并打印，注意Data是[100]byte，可能包含空字节
    // 这里简单地将其作为字符串打印，实际应用中可能需要更复杂的处理，如查找第一个空字节
    fmt.Printf("收到来自 %s 的数据包 (类型: %d, ID: %d): %s\n",
        conn.RemoteAddr(), msg.Type, msg.Id, string(msg.Data[:]))

    // 准备并发送响应
    response := packet{Type: 1, Id: 1}
    // 将字符串复制到固定大小的字节数组中
    copy(response.Data[:], "Hello, client from Go server!")
    // 使用binary.Write将响应结构体写入连接
    err = binary.Write(conn, binary.BigEndian, &response)
    if err != nil {
        log.Printf("向 %s 发送响应失败: %v", conn.RemoteAddr(), err)
        return
    }
    log.Printf("已向 %s 发送响应。", conn.RemoteAddr())
}

package main

import (
    "encoding/binary"
    "fmt"
    "net"
    "log" // 引入log包
)

// packet 结构体定义同上

func main() {
    // 连接到本地主机的2000端口
    conn, err := net.Dial("tcp", "localhost:2000")
    if err != nil {
        log.Fatalf("连接服务器失败: %v", err)
    }
    defer conn.Close() // 确保连接在main函数退出时关闭

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

    // 准备并发送一个数据包
    msg := packet{Type: 0, Id: 0}
    copy(msg.Data[:], "Hello, server from Go client!") // 复制数据到Data字段
    err = binary.Write(conn, binary.BigEndian, &msg)
    if err != nil {
        log.Fatalf("发送数据包失败: %v", err)
    }
    log.Println("已发送数据包。")

    // 接收服务器的响应
    var response packet
    err = binary.Read(conn, binary.BigEndian, &response)
    if err != nil {
        log.Fatalf("接收响应失败: %v", err)
    }
    // 打印收到的响应
    fmt.Printf("收到响应 (类型: %d, ID: %d): %s\n",
        response.Type, response.Id, string(response.Data[:]))

    log.Println("客户端操作完成。")
}