update

client/client.go

@@ -3,20 +3,39 @@ package main
 import (
 	"net"
 	"time"
+	"fmt"
 )
 
 var echoSocket = make(chan []byte)
 
 func startSocket() {
+	
+	var( 
+		err error
+		conn net.Conn
+	)
+	
 	for {
 		select {
 		case b := <-echoSocket:
-			conn, err := net.Dial("unix", "/tmp/echo.sock")
+			
-			if err == nil {
+			if conn == nil {
-				conn.Write(b)
+				conn, err = net.Dial("unix", "/tmp/echo.sock")
-				conn.Close()
+				if err != nil {
+					fmt.Println(err.Error())
+					continue
 				}
 			}
+			
+			if conn != nil {
+				if _, err = conn.Write(b); err != nil {
+					fmt.Println(err.Error())
+					conn.Close()
+					conn = nil
+				}
+			}
+			
+		}
 	}
 }
 
@@ -24,8 +43,8 @@ func main() {
 	go startSocket()
 
 	for {
-		echoSocket <- []byte(`{"chanel":"stripchat","room":"naughtyobsessions","donator":"tbone6893","amount":333}`)
+		echoSocket <- []byte(`{"chanel":"chaturbate","room":"naughtyobsessions","donator":"tbone6893","amount":333}`)
-		echoSocket <- []byte(`{"chanel":"stripchat","index":28}`)
+		echoSocket <- []byte(`{"chanel":"chaturbate","index":28}`)
 		time.Sleep(1e9)
 	}
 }

server/socket.go

@@ -1,9 +1,12 @@
 package main
 
 import (
+	"fmt"
 	"log"
 	"net"
 	"os"
+	"io"
+	jsoniter "github.com/json-iterator/go"
 )
 
 func removeSocket(s string) {
@@ -31,12 +34,17 @@ func startSocket() {
 
 func socketHandler(conn net.Conn) {
 	defer conn.Close()
-	buf := make([]byte, 512)
+	d := json.NewDecoder(conn)
 	for {
-		n, err := conn.Read(buf)
+		raw := jsoniter.RawMessage{}
-		if err != nil {
+		err := d.Decode(&raw)
-			return
+		if err == io.EOF {
+			fmt.Println("break:", err.Error())
+			break
+		} else if err != nil {
+			fmt.Println("json error:", err.Error())
+			continue
 		}
-		ws.Send <- wsMessage{Message: buf[0:n], Decode: true}
+		ws.Send <- wsMessage{Message: raw, Decode: true}
 	}
 }