modify main.go

example/main.go

@@ -1,26 +1,25 @@
 package main
 
 import (
+	"bufio"
 	"github.com/zhouhui8915/go-socket.io-client"
 	"log"
-	"bufio"
 	"os"
-	"time"
 )
 
 func main() {
 
 	opts := &socketio_client.Options{
-		Transport:"websocket",
-		Query:make(map[string]string),
+		Transport: "websocket",
+		Query:     make(map[string]string),
 	}
-	opts.Query["uid"] = "1"
-	opts.Query["cid"] = "conf_123"
+	opts.Query["user"] = "user"
+	opts.Query["pwd"] = "pass"
 	uri := "http://192.168.1.70:9090/socket.io/"
 
-	client,err := socketio_client.NewClient(uri,opts)
+	client, err := socketio_client.NewClient(uri, opts)
 	if err != nil {
-		log.Printf("NewClient error:%v\n",err)
+		log.Printf("NewClient error:%v\n", err)
 		return
 	}
 
@@ -37,19 +36,11 @@ func main() {
 		log.Printf("on disconnect\n")
 	})
 
-	go func() {
-		authStr := "{\"uid\":\"" + opts.Query["uid"] + "\",\"cid\":\"" + opts.Query["cid"] + "\"}"
-		for {
-			client.Emit("authenticate", authStr)
-			time.Sleep(10 * time.Second)
-		}
-	}()
-
 	reader := bufio.NewReader(os.Stdin)
-	for  {
+	for {
 		data, _, _ := reader.ReadLine()
 		command := string(data)
-		client.Emit("message",command)
-		log.Printf("send message:%v\n",command)
+		client.Emit("message", command)
+		log.Printf("send message:%v\n", command)
 	}
-}
+}

example/test.go

@@ -0,0 +1,55 @@
+package main
+
+import (
+	"github.com/zhouhui8915/go-socket.io-client"
+	"log"
+	"bufio"
+	"os"
+	"time"
+)
+
+func main() {
+
+	opts := &socketio_client.Options{
+		Transport:"websocket",
+		Query:make(map[string]string),
+	}
+	opts.Query["uid"] = "1"
+	opts.Query["cid"] = "conf_123"
+	uri := "http://192.168.1.70:9090/socket.io/"
+
+	client,err := socketio_client.NewClient(uri,opts)
+	if err != nil {
+		log.Printf("NewClient error:%v\n",err)
+		return
+	}
+
+	client.On("error", func() {
+		log.Printf("on error\n")
+	})
+	client.On("connection", func() {
+		log.Printf("on connect\n")
+	})
+	client.On("message", func(msg string) {
+		log.Printf("on message:%v\n", msg)
+	})
+	client.On("disconnection", func() {
+		log.Printf("on disconnect\n")
+	})
+
+	go func() {
+		authStr := "{\"uid\":\"" + opts.Query["uid"] + "\",\"cid\":\"" + opts.Query["cid"] + "\"}"
+		for {
+			client.Emit("authenticate", authStr)
+			time.Sleep(10 * time.Second)
+		}
+	}()
+
+	reader := bufio.NewReader(os.Stdin)
+	for  {
+		data, _, _ := reader.ReadLine()
+		command := string(data)
+		client.Emit("message",command)
+		log.Printf("send message:%v\n",command)
+	}
+}