From 1c62ece5b48728079823c3963c51317a9c2f5635 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期六, 01 六月 2019 11:41:04 +0800
Subject: [PATCH] Errorln to Infoln

---
 server.go |   41 ++++++++++++++++++++++++-----------------
 1 files changed, 24 insertions(+), 17 deletions(-)

diff --git a/server.go b/server.go
index 0caff95..ce7a671 100644
--- a/server.go
+++ b/server.go
@@ -18,8 +18,12 @@
 var port = flag.Int("port", 6000, "The port to listen on; ")
 var sec = flag.Int("sec", 10, "the second for query data. ")
 
+var Level = flag.String("level","ErrorLevel","log level")
+
 func main() {
 	flag.Parse()
+
+	log.SetLogLevel(*Level)
 
 	fmt.Println(*port)
 	src := *addr + ":" + strconv.Itoa(*port)
@@ -39,7 +43,7 @@
 		conn, err := listener.Accept()//
 		connArr = append(connArr,conn)
 		if err != nil {
-			log.Log.Errorf("some connecion error: %s\n", err)
+			log.Log.Infoln("some connecion error: ", err)
 		}
 		go handleConnection(conn,connArr)
 	}
@@ -52,9 +56,14 @@
 	ech := make(chan error)
 	go func(conn net.Conn, ech chan error) {
 		buf := make([]byte, 10)
-		_, err := conn.Read(buf)
-		if err != nil {
-			ech <- err
+		for {
+			_, err := conn.Read(buf)
+			log.Log.Infoln("Read completed!")
+			if err != nil {
+				ech <- err
+				log.Log.Infoln("Read Error!conn.Close")
+				break
+			}
 		}
 	}(conn, ech)
 	tick := time.NewTicker(10 * time.Second)
@@ -64,7 +73,7 @@
 		case <-tick.C:
 			handleMessage(conn, connArr)
 		case err := <-ech:
-			log.Log.Errorln(err, "remoteAddr ", remoteAddr, " close")
+			log.Log.Infoln(err, "remoteAddr ", remoteAddr, " close")
 			conn.Close()
 			break
 		}
@@ -83,17 +92,15 @@
 	log.Log.Infoln("jsonstring len: ", len(jsonstring), "\000 data: ", len("\000"))
 	_, err := conn.Write(jsonstring)
 	if err !=nil{
-		fmt.Println("conn: ",conn)
-		log.Log.Errorln(err)
-		conn.Close()
-		index :=0
-		for ;index < len(connArr); {
-			if connArr[index] == conn{
-				connArr = append(connArr[:index],connArr[index+1:]...)
-				continue
-			}
-			index++
-		}
-		fmt.Println("connArr: ",connArr)
+		log.Log.Infoln("conn.WriteErr:",err)
+
+		//index :=0
+		//for ;index < len(connArr); {
+		//	if connArr[index] == conn{
+		//		connArr = append(connArr[:index],connArr[index+1:]...)
+		//		continue
+		//	}
+		//	index++
+		//}
 	}
 }

--
Gitblit v1.8.0