From 6f4867fde2e9c8aefe271bce251b42cae8fbc5c8 Mon Sep 17 00:00:00 2001
From: lyp <gcslyp@gmail.com>
Date: Thu, 14 Mar 2019 19:19:03 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E6=B7=BB=E5=8A=A0mq.go?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 mq.go | 3 +++
 1 file changed, 3 insertions(+)
 create mode 100644 mq.go

diff --git a/mq.go b/mq.go
new file mode 100644
index 0000000..1110061
--- /dev/null
+++ b/mq.go
@@ -0,0 +1,3 @@
+package main
+
+

From 1e3c58ec4ac6a4ad3b46cb3650ad1213b3e6e7c4 Mon Sep 17 00:00:00 2001
From: lyp <gcslyp@gmail.com>
Date: Mon, 18 Mar 2019 18:20:50 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=E6=B7=BB=E5=8A=A0tcp=E6=8E=A5=E6=94=B6?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.go      | 19 +++++++++-
 tcpserver.go | 97 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 115 insertions(+), 1 deletion(-)
 create mode 100644 tcpserver.go

diff --git a/main.go b/main.go
index c6319f4..ab35fa6 100644
--- a/main.go
+++ b/main.go
@@ -4,6 +4,7 @@ import (
 	"github.com/robfig/cron"
 	"log"
 	"os"
+	"net"
 )
 
 var err error
@@ -20,7 +21,23 @@ func main() {
 	c.AddFunc("0, 0, *, *, *, *", get_weather)
 	c.Start()
 
-	select {}
+	listener, err := net.Listen("tcp", "0.0.0.0:10090")
+    if err != nil {
+        log.Printf("listen fail, err: %v\n", err)
+        return
+    }
+ 
+    for {
+        conn, err := listener.Accept()
+        if err != nil {
+            log.Printf("accept fail, err: %v\n", err)
+            continue
+        }
+ //       go process(conn)
+	go handleConn(conn)   
+ }
+
+//	select {}
 
 }
 
diff --git a/tcpserver.go b/tcpserver.go
new file mode 100644
index 0000000..c0f275e
--- /dev/null
+++ b/tcpserver.go
@@ -0,0 +1,97 @@
+package main
+
+import (
+	"log"
+	"net"
+	//"os"
+	// "strconv"
+	// "log"
+	//"strings"
+	"time"
+	// "go-study/socket/config"
+)
+
+
+func handleConn(conn net.Conn) {
+	defer conn.Close()
+
+	readChan := make(chan []byte)
+	//writeChan := make(chan string)
+	stopChan := make(chan bool)
+
+	go readConn(conn, readChan, stopChan)
+	// go writeConn(conn, writeChan, stopChan)
+
+	for {
+		select {
+		case readStr := <-readChan:
+			//log.Println("readStr:",readStr)
+			//upper := strings.ToUpper(readStr)
+			//writeChan <- upper
+			go yunhorn_ys_l_v1(readStr)
+		case stop := <-stopChan:
+			if stop {
+				break
+			}
+		}
+	}
+}
+func readConn(conn net.Conn, readChan chan<- []byte, stopChan chan<- bool) {
+	data_buf := make(chan []byte)
+	Rdata := make([]byte, 0)
+	data := make([]byte, 256)
+
+	go func() {
+		for {
+			select {
+			case kkdata := <-data_buf: //如果有数据，下面打印。但是有可能ch一直没数据
+				Rdata = append(Rdata, kkdata...)
+				//log.Println("kkdata:",kkdata)
+			case <-time.After(50 * time.Millisecond): //上面的ch如果一直没数据会阻塞，那么select也会检测其他case条件，检测到后3秒超时
+				// log.Println("超时")
+				if len(Rdata) >3{
+					readChan <- Rdata
+				Rdata = make([]byte,0)
+				}
+				//strData := string(Rdata)
+				//Rdata = make([]byte,0)
+				//log.Println("Received:", strData)
+				
+				//readChan <- Rdata
+				//Rdata = make([]byte,0)
+			}
+		}
+	}()
+
+	for {
+		// data := make([]byte, config.SERVER_RECV_LEN)
+		//data2 := make([]byte,256)
+		_, err := conn.Read(data)
+		if err != nil {
+			log.Println(err)
+			break
+		}
+		log.Println(DEVICEDATAS)
+
+		log.Println("read.data:",Bytes2Bits(data[3:4]))
+
+		data_buf <- data
+	}
+
+	stopChan <- true
+}
+
+func writeConn(conn net.Conn, writeChan <-chan string, stopChan chan<- bool) {
+	for {
+		strData := <-writeChan
+		_, err := conn.Write([]byte(strData))
+		if err != nil {
+			log.Println(err)
+			break
+		}
+
+		log.Println("Send:", strData)
+	}
+
+	stopChan <- true
+}