Signed-off-by: arraykeys@gmail.com <arraykeys@gmail.com>

services/mux_bridge.go

@@ -128,6 +128,9 @@ func (s *MuxBridge) handler(inConn net.Conn) {
 		}
 		_group, _ := s.clientControlConns.Get(groupKey)
 		group := _group.(*utils.ConcurrentMap)
+		if v, ok := group.Get(index); ok {
+			v.(*smux.Session).Close()
+		}
 		group.Set(index, session)
 		// s.clientControlConns.Set(key, session)
 		go func() {

services/mux_server.go

@@ -164,7 +164,6 @@ func (s *MuxServer) Start(args interface{}) (err error) {
 					log.Printf("connection handler crashed with err : %s \nstack: %s", err, string(debug.Stack()))
 				}
 			}()
-			inConnRemoteAddr := inConn.RemoteAddr().String()
 			var outConn net.Conn
 			var ID string
 			for {
@@ -178,8 +177,6 @@ func (s *MuxServer) Start(args interface{}) (err error) {
 					break
 				}
 			}
-			outConnRemoteAddr := outConn.RemoteAddr().String()
-
 			log.Printf("%s stream %s created", *s.cfg.Key, ID)
 			if *s.cfg.IsCompress {
 				die1 := make(chan bool, 1)