添加测试tcp client断开后，关闭channle

conf/gateway.conf

@@ -92,7 +92,8 @@
 		]
 	},
 	"devices_list": [
-		["4E5D52DD-EB81-43C0-A2B6-04E432412EBA", "loraport", "yunhorn_kgl_l_v1", "1"]
+		["4E5D52DD-EB81-43C0-A2B6-04E432412EBA", "loraport", "yunhorn_kgl_l_v1", "1"],
+		["EB5B0798-9B7F-474E-AAB8-467FD5FE1293", "loraport", "yunhorn_kgl_l_v1", "2"]
 	],
 	"serialports_list": {
 		"loraport": {

do_send_data.go

@@ -41,6 +41,9 @@ func build_data(code int, data []Device) []byte {
 		R_data.GATEWAY_INFO = conf.GATEWAY_INFO
 		DEVICEDATAS.RLock()
 		for _, i := range DEVICEDATAS.DATA {
+			log.Println("=========================================")
+			log.Println(i)
+			log.Println("=========================================")
 			R_data.DEVICES = append(R_data.DEVICES, i)
 		}
 		DEVICEDATAS.RUnlock()

main.go

@@ -13,10 +13,15 @@ func main() {
 	go gw_router()
 	go serial_run()
 	c := cron.New()
-	send_data(1001)
+	// send_data(1001)
 	c.AddFunc("0, *, *, *, *, *", func() {
-		send_data(1001)
+		// send_data(1001)
 	})
+	// devices := []Device{}
+	c.AddFunc("*/10, *, *, *, *, *", func(){
+			// log.Println(string(build_data(1001,devices)))
+	})
+
 	c.AddFunc("0, */10, *, *, *, *", savedata_cron)
 	c.AddFunc("0, 0, 0, *, *, *", insertdata)
 	c.AddFunc("0, 0, *, *, *, *", get_weather)

tcpserver.go

@@ -22,6 +22,8 @@ func handleConn(conn net.Conn) {
 	go readConn(conn, readChan, stopChan)
 	// go writeConn(conn, writeChan, stopChan)
 
+	var heartbeat []byte = []byte{0x01}
+
 	for {
 		select {
 		case readStr := <-readChan:
@@ -33,6 +35,13 @@ func handleConn(conn net.Conn) {
 			if stop {
 				break
 			}
+		case <-time.After(5000 * time.Millisecond):
+			n,err := conn.Write(heartbeat)
+			if err != nil{
+				log.Println("write msg error!",err)
+			}else{
+				log.Println("write msg success!",n)
+			}
 		}
 	}
 }

worker.go

@@ -53,7 +53,7 @@ func yunhorn_ys_l_v1(data_buf []byte){
 	if conf.DEBUG {
       log.Println(device)
   }
-   send_data(1005, device)
+   // send_data(1005, device)
 
 }