Unix Datagram Server/Client

udgsend.go

package main

import (
        "flag"
        "io"
        "log"
        "net"
        "os"
)

var sock = flag.String("sock", "/tmp/test-udg", "Socket to connect to")

func main() {
        flag.Parse()

        addr, err := net.ResolveUnixAddr("unixgram", *sock)
        if err != nil {
                log.Fatalf("ResolveUnix: %v", err)
        }
        laddr, err := net.ResolveUnixAddr("unixgram", *sock + ".local")
        if err != nil {
                log.Fatalf("ResolveUnix: %v", err)
        }

        c, err := net.DialUnix("unixgram", laddr, addr)
        if err != nil {
                log.Fatalf("DialUnix: %v", err)
        }
        defer os.Remove(*sock + ".local")

        if _, err = io.WriteString(c, "test"); err != nil {
                log.Printf("Write: %v", err)
        }
}

udgserv.go

package main

import (
        "flag"
        "log"
        "net"
        "os"
)

var sock = flag.String("sock", "/tmp/test-udg", "Socket on which to listen")

func main() {
        flag.Parse()

        c, err := net.ListenPacket("unixgram", *sock)
        if err != nil {
                log.Fatalf("ListenPacket: %s", err)
        }
        defer os.Remove(*sock)

        buf := make([]byte, 512)
        for {
                length, raddr, err := c.ReadFrom(buf)
                if err != nil {
                        log.Printf("ReadFrom: %v", err)
                        break
                }
                log.Printf("<%s> %q", raddr, buf[:length])
        }
}