go语言实现unix通讯

service端

package main

import (
  "bufio"
  "fmt"
  "net"
  "time"
)

func main() {
  var addr *net.UnixAddr

  addr, _ = net.ResolveUnixAddr("unix", "/tmp/unix_ss")

  unixListener, _ := net.ListenUnix("unix", addr)

  defer unixListener.Close()

  for {
    conn, err := unixListener.AcceptUnix()
    if err != nil {
      continue
    }

    fmt.Println("A client connected : " + conn.RemoteAddr().String())
    go unixPipe(conn)
  }

}

func unixPipe(conn *net.UnixConn) {
  ipStr := conn.RemoteAddr().String()
  defer func() {
    fmt.Println("disconnected :" + ipStr)
    conn.Close()
  }()
  reader := bufio.NewReader(conn)

  for {
    //读取客户端内容
    message, err := reader.ReadString('\n')
    if err != nil {
      return
    }

    fmt.Println(string(message))
    msg := time.Now().String() + "\n"
    b := []byte(msg)
    //将当前时间写回给客户端
    conn.Write([]byte("service : "))
    conn.Write(b)
  }
}

client端 

package main

import (
  "bufio"
  "fmt"
  "net"
  "time"
)

var quitSemaphore chan bool

func main() {
  var addr *net.UnixAddr
  addr, _ = net.ResolveUnixAddr("unix", "/tmp/unix_ss")

  conn, _ := net.DialUnix("unix", nil, addr)
  defer conn.Close()
  fmt.Println("connected!")

  go onMessageRecived(conn)

  b := []byte("time\n")
  conn.Write([]byte("client: "))
  conn.Write(b)

  <-quitSemaphore
}

func onMessageRecived(conn *net.UnixConn) {
  reader := bufio.NewReader(conn)
  for {
    msg, err := reader.ReadString('\n')
    fmt.Println(msg)
    if err != nil {
      quitSemaphore <- true
      break
    }
    time.Sleep(time.Second)
    b := []byte(msg)
    conn.Write([]byte("client: "))
    conn.Write(b)
  }
}