增加重连

app/http/tcppool/single.go

@@ -144,6 +144,7 @@ func (t *TcpHelper) watch(conn net.Conn) {
 				} else {
 					atomic.StoreInt32(t.Full, 1)
 					utils.Log(nil, "连接关闭", err)
+					t.reconnect(config.GetConf().OrderPort)
 				}
 			}
 			time.Sleep(1 * time.Second)

app/utils/mq/kafka_v2.go

@@ -95,7 +95,7 @@ func (kk KafkaV2Mq) Consume(name string, hand interface{}, ci int) {
 		go func() {
 			for {
 				if atomic.LoadInt32(tcppool.TcpFactory.Full) == 1 {
-					utils.Log(nil, "对列阻塞")
+					//utils.Log(nil, "对列阻塞")
 					time.Sleep(100 * time.Millisecond)
 					continue
 				} else {

app/utils/util.go

@@ -9,7 +9,6 @@ import (
 
 func Log(c *gin.Context, name string, msg ...interface{}) {
 	_, file, line, _ := runtime.Caller(1)
-	timeLayout := "2006-01-01 03:04:05" //转化所需模板
-	var datetime = time.Unix(time.Now().Unix(), 0).Format(timeLayout)
+	var datetime = time.Now().Format(time.DateTime)
 	fmt.Println(name, msg, file, line, datetime)
 }