package main
<p>import (
"net"
"fmt"
"time"
)</p><p>func main() {
// 创建UDP地址
addr, err := net.ResolveUDPAddr("udp", "192.168.1.255:30000")
if err != nil {
fmt.Println("解析地址失败:", err)
return
}</p><pre class='brush:php;toolbar:false;'>// 建立UDP连接
conn, err := net.DialUDP("udp", nil, addr)
if err != nil {
    fmt.Println("建立连接失败:", err)
    return
}
defer conn.Close()

// 允许广播
err = conn.SetWriteBuffer(1024)
if err != nil {
    fmt.Println("设置写缓冲区失败:", err)
}

for {
    msg := "Hello from broadcaster @ " + time.Now().Format("15:04:05")
    _, err = conn.Write([]byte(msg))
    if err != nil {
        fmt.Println("发送失败:", err)
    } else {
        fmt.Println("已广播:", msg)
    }
    time.Sleep(2 * time.Second)
}

}

package main
<p>import (
"net"
"fmt"
)</p><p>func main() {
// 监听本机所有IP的30000端口
addr, err := net.ResolveUDPAddr("udp", ":30000")
if err != nil {
fmt.Println("解析地址失败:", err)
return
}</p><pre class='brush:php;toolbar:false;'>conn, err := net.ListenUDP("udp", addr)
if err != nil {
    fmt.Println("监听失败:", err)
    return
}
defer conn.Close()

fmt.Println("等待接收广播...")
buffer := make([]byte, 1024)
for {
    n, clientAddr, err := conn.ReadFromUDP(buffer)
    if err != nil {
        fmt.Println("读取失败:", err)
        continue
    }
    fmt.Printf("收到来自 %s 的消息: %s\n", clientAddr, string(buffer[:n]))
}

}