import (
        "io"
        "net"
        "os"
        "time"

        "golang.org/x/net/ipv4"
    )

    func main() {
        c1, err := net.ListenPacket("udp4", "224.0.0.0:1234")
        if err != nil {
            // error handling
        }
        en0, err := net.InterfaceByName("en0")
        if err != nil {
            // error handling
        }
        c2, err := net.ListenPacket("udp4", "224.0.0.0:1234")
        if err != nil {
            // error handling
        }
        p1 := ipv4.NewPacketConn(c1)
        if err := p1.JoinGroup(en0, &net.UDPAddr{IP: net.IPv4(238, 1, 2, 2)}); err != nil {
            // error handling
        }
        p2 := ipv4.NewPacketConn(c2)
        if err := p2.JoinGroup(en0, &net.UDPAddr{IP: net.IPv4(238, 1, 2, 1)}); err != nil {
            // error handling
        }
        fo1, err := os.Create("test1.ts")
        defer fo1.Close()
        if err != nil {
            return
        }
        go io.Copy(fo1, p1)
        fo2, err := os.Create("test2.ts")
        defer fo2.Close()
        if err != nil {
            return
        }
        go io.Copy(fo2, p2)
        time.Sleep(time.Second * 10)
        p1.LeaveGroup(en0, c1.LocalAddr())
        p1.Close()
        c1.Close()
        p2.LeaveGroup(en0, c2.LocalAddr())
        p2.Close()
        c2.Close()
    }