golangで書くunix domain socketを使ったserver/clientのサンプルコード ref: http://qiita.com/ikeisuke/items/f5eccc178ed388aac92f

client

$ go run client.go /tmp/uds-sample-server.sock 0123456789abcdefghijklmnopqrstuvwxyz
# サーバーへの送信データ
client.go:28: send: 0123456789abcdefghijklmnopqrstuvwxyz
# サーバーからの受信データ
client.go:44: receive: 0123456789
client.go:44: receive: abcdefghij
client.go:44: receive: klmnopqrst
client.go:44: receive: uvwxyz0123
client.go:44: receive: 456789abcd
client.go:44: receive: efghijklmn
client.go:44: receive: opqrstuvwx
client.go:44: receive: yz
# 標準出力への表示
0123456789abcdefghijklmnopqrstuvwxyz0123456789abcdefghijklmnopqrstuvwxyz

client.go

package main

import (
    "fmt"
    "log"
    "net"
    "os"
)

func main() {
    log.SetFlags(log.Lshortfile)
    if len(os.Args) != 3 {
        return
    }
    file := os.Args[1]
    message := os.Args[2]
    conn, err := net.Dial("unix", file)
    if err != nil {
        log.Printf("error: %v\n", err)
        return
    }
    defer conn.Close()
    _, err = conn.Write([]byte(message))
    if err != nil {
        log.Printf("error: %v\n", err)
        return
    }
    log.Printf("send: %s\n", message)
    // これをしないとEOFが通知されずにレスポンスの処理まで進んでくれない
    err = conn.(*net.UnixConn).CloseWrite()
    if err != nil {
        log.Printf("error: %v\n", err)
        return
    }
    data := make([]byte, 0)
    for {
        // サンプルコードなのでバッファサイズを小さめに
        buf := make([]byte, 10)
        nr, err := conn.Read(buf)
        if err != nil {
            break
        }
        buf = buf[:nr]
        // 受信データのログ出力
        log.Printf("receive: %s\n", string(buf))
        data = append(data, buf...)
    }
    // 受信データの出力
    fmt.Printf("%s\n", string(data))
}

server

$ go run server.go
# 以下はクライアントからデータを受信しての出力
server.go:43: receive: 0123456789
server.go:43: receive: abcdefghij
server.go:43: receive: klmnopqrst
server.go:43: receive: uvwxyz
# 以下はクライアントがWriteClose()してからの出力
server.go:50: send: 0123456789abcdefghijklmnopqrstuvwxyz0123456789abcdefghijklmnopqrstuvwxyz

server.go

package main

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

func main() {
    log.SetFlags(log.Lshortfile)
    file := "/tmp/uds-sample-server.sock"
    // 削除はdeferで予約しておく
    // シグナルハンドラ定義しないと終了時に呼ばれない？
    defer os.Remove(file)
    listener, err := net.Listen("unix", file)
    if err != nil {
        log.Printf("error: %v\n", err)
        return
    }
    for {
        conn, err := listener.Accept()
        if err != nil {
            break
        }
        go func() {
            // Closeはdeferで予約しておく
            defer conn.Close()
            data := make([]byte, 0)
            for {
                // サンプルコードなのでバッファサイズを小さめに
                buf := make([]byte, 10)
                // 全データ受信後EOFがこない限りここで止まる
                nr, err := conn.Read(buf)
                if err != nil {
                    if err != io.EOF {
                        log.Printf("error: %v", err)
                    }
                    break
                }
                // 実際に読み込んだバイト以降のデータを除去したデータに変換
                buf = buf[:nr]
                log.Printf("receive: %s\n", string(buf))
                // slice同士の結合は二つ目のsliceの後ろに...をつける
                data = append(data, buf...)
                // レスポンスデータ送信
            }
            conn.Write(data)
            conn.Write(data)
            log.Printf("send: %s\n", string(append(data, data...)))
        }()
    }
}