如何在 Golang 中解析 DNS 数据包：使用第三方库 miekg/dns

go get github.com/miekg/dns

package main

import (
    "fmt"
    "log"
    "net"

    "github.com/miekg/dns"
)

func main() {
    // 假设 data 是一个包含 DNS 数据包的字节切片
    // 例如，从 UDP 连接读取的数据
    conn, err := net.ListenUDP("udp", &net.UDPAddr{Port: 5353})
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    buffer := make([]byte, 512) // 足够大的缓冲区来容纳 DNS 数据包

    n, addr, err := conn.ReadFromUDP(buffer)
    if err != nil {
        log.Fatal(err)
    }

    data := buffer[:n]

    // 创建一个空的 DNS 消息
    msg := new(dns.Msg)

    // 解析 DNS 数据包
    err = msg.Unpack(data)
    if err != nil {
        log.Fatalf("Failed to unpack DNS message: %v", err)
    }

    // 打印解析后的 DNS 消息
    fmt.Printf("DNS Message: %+v\n", msg)
    fmt.Printf("Received from: %v\n", addr)

    // 遍历 Questions 部分
    fmt.Println("Questions:")
    for _, question := range msg.Question {
        fmt.Printf("  Name: %s, Type: %s, Class: %s\n", question.Name, dns.TypeToString[question.Qtype], dns.ClassToString[question.Qclass])
    }

    // 遍历 Answers 部分
    fmt.Println("Answers:")
    for _, answer := range msg.Answer {
        fmt.Printf("  Name: %s, Type: %s, TTL: %d, Data: %v\n", answer.Header().Name, dns.TypeToString[answer.Header().Rrtype], answer.Header().Ttl, answer)
    }
}

package main

import (
    "fmt"
    "github.com/miekg/dns"
)

func main() {
    // 创建一个新的 DNS 消息
    m := new(dns.Msg)
    m.Id = dns.Id()
    m.RecursionDesired = true
    m.Question = make([]dns.Question, 1)
    m.Question[0] = dns.Question{"example.com.", dns.TypeA, dns.ClassINET}

    // 将 DNS 消息打包成字节切片
    packed, err := m.Pack()
    if err != nil {
        fmt.Println("Error packing DNS message:", err)
        return
    }

    // 打印打包后的字节切片
    fmt.Printf("Packed DNS message: %v\n", packed)

    // 你可以将 packed 字节切片发送到 DNS 服务器
}

package main

import (
    "fmt"
    "log"
    "net"

    "github.com/miekg/dns"
)

func main() {
    // 创建一个 DNS 客户端
    c := new(dns.Client)

    // 创建一个 DNS 消息
    m := new(dns.Msg)
    m.Id = dns.Id()
    m.RecursionDesired = true
    m.Question = make([]dns.Question, 1)
    m.Question[0] = dns.Question{"example.com.", dns.TypeA, dns.ClassINET}

    // 发送 DNS 查询到 DNS 服务器
    r, _, err := c.Exchange(m, net.JoinHostPort("8.8.8.8", "53")) // Google Public DNS
    if err != nil {
        log.Fatalf("Failed to exchange DNS message: %v", err)
    }

    // 检查响应是否为空
    if r == nil {
        log.Fatalf("Received nil DNS response")
    }

    // 打印响应
    fmt.Printf("Response: %+v\n", r)

    // 遍历 Answers 部分
    fmt.Println("Answers:")
    for _, answer := range r.Answer {
        fmt.Printf("  Name: %s, Type: %s, TTL: %d, Data: %v\n", answer.Header().Name, dns.TypeToString[answer.Header().Rrtype], answer.Header().Ttl, answer)
    }
}