Skip to content

Instantly share code, notes, and snippets.

@nelsonjchen
Created October 21, 2014 21:26
Show Gist options
  • Star 2 You must be signed in to star a gist
  • Fork 3 You must be signed in to fork a gist
  • Save nelsonjchen/510ab59caa85251c4709 to your computer and use it in GitHub Desktop.
Save nelsonjchen/510ab59caa85251c4709 to your computer and use it in GitHub Desktop.
package main
import "net"
func echoServer(c net.Conn) {
for {
buf := make([]byte, 512)
nr, err := c.Read(buf)
if err != nil {
return
}
data := buf[0:nr]
println("Server got:", string(data))
_, err = c.Write(data)
if err != nil {
panic("Write: " + err.Error())
}
}
}
func main() {
l, err := net.Listen("unix", "/tmp/echo.sock")
if err != nil {
println("listen error", err.Error())
return
}
for {
fd, err := l.Accept()
if err != nil {
println("accept error", err.Error())
return
}
go echoServer(fd)
}
}
Client
package main
import (
"io"
"net"
"time"
)
func reader(r io.Reader) {
buf := make([]byte, 1024)
for {
n, err := r.Read(buf[:])
if err != nil {
return
}
println("Client got:", string(buf[0:n]))
}
}
func main() {
c, err := net.Dial("unix", "/tmp/echo.sock")
if err != nil {
panic(err.Error())
}
defer c.Close()
go reader(c)
for {
_, err := c.Write([]byte("hi"))
if err != nil {
println(err.Error())
break
}
time.Sleep(1e9)
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment