Go在Win10上接收UDP组播数据
- 第一步、绑定本机某张网卡的IP和端口，本代码选择IP为0.0.0.0，端口为8000；
- 第二步、加入组播，组播地址为“224.0.0.1”；
- 第三步、循环接收UDP组播数据；
代码
package mainimport ("fmt""golang.org/x/net/ipv4""log""net""os"
)// 组播地址和端口
var (multicastAddress = "224.0.0.1"port = 8000
)func main() {// 绑定IP和端口listener, err := net.ListenPacket("udp4", fmt.Sprintf("0.0.0.0:%d", port))if err != nil {log.Fatal(err)}// 关闭监听defer listener.Close()packConnector := ipv4.NewPacketConn(listener)// 加入组播if err := packConnector.JoinGroup(nil, &net.UDPAddr{IP: net.ParseIP(multicastAddress)}); err != nil {log.Fatal(err)}// 离开组播defer packConnector.LeaveGroup(nil, &net.UDPAddr{IP: net.ParseIP(multicastAddress)})// 创建一个缓冲区(切片)用于接收数据buffer := make([]byte, 1024*2)go func() {for {// 接收数据n, _, srcAddr, err := packConnector.ReadFrom(buffer)if err != nil {log.Println("Error reading:", err)continue}// 打印接收到的数据和源地址data := buffer[:n]senderAddr := srcAddr.String()// fmt.Printf("Received %d bytes from %s: %s\n", n, senderAddr, hex.Dump(data))fmt.Printf("Received %d bytes from [%s]:\n%s\n", n, senderAddr, string(data))}}()for {var input stringfmt.Scanln(&input)if input == "q" {fmt.Println("Program exit...")os.Exit(0)break}fmt.Println(input)}
}
效果演示
