..

controllers/edb_monitor/edb_monitor_message.go

@@ -88,6 +88,7 @@ func (m *EdbMonitorMessageController) Connect() {
 				return
 			}
 			if isClose {
+				conn.Close()
 				return
 			}
 		}