Automatisches erneutes Verbinden des asynchronen Socket-Clients

Question

Ich arbeite mit einer Windows-Formularanwendung in C#. Ich benutze einen Socket-Client, der sich asynchron mit einem Server verbindet. Ich möchte, dass der Socket versucht, sofort wieder mit dem Server zu verbinden, wenn die Verbindung aus irgendeinem Grund unterbrochen wird. meine Routine Aussehen erhalten wie diese

 public void StartReceiving() 
    { 
     StateObject state = new StateObject(); 
     state.workSocket = this.socketClient; 
     socketClient.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(OnDataReceived), state); 
    } 

    private void OnDataReceived(IAsyncResult ar) 
    { 
     try 
     { 
      StateObject state = (StateObject)ar.AsyncState; 
      Socket client = state.workSocket; 

      // Read data from the remote device. 
      int iReadBytes = client.EndReceive(ar); 
      if (iReadBytes > 0) 
      { 
       byte[] bytesReceived = new byte[iReadBytes]; 
       Buffer.BlockCopy(state.buffer, 0, bytesReceived, 0, iReadBytes); 
       this.responseList.Enqueue(bytesReceived); 
       StartReceiving(); 
       receiveDone.Set(); 
      } 
      else 
      { 
       NotifyClientStatusSubscribers(false); 
      } 
     } 
     catch (Exception e) 
     { 

     } 
    } 

Wenn NotifyClientStatusSubscribers (false) die Funktion StopClient ausgeführt wird aufgerufen:

public void StopClient() 
    { 
     this.canRun = false; 
     this.socketClient.Shutdown(SocketShutdown.Both); 
     socketClient.BeginDisconnect(true, new AsyncCallback(DisconnectCallback), this.socketClient); 
    } 

    private void DisconnectCallback(IAsyncResult ar) 
    { 
     try 
     { 
      // Retrieve the socket from the state object. 
      Socket client = (Socket)ar.AsyncState; 

      // Complete the disconnection. 
      client.EndDisconnect(ar); 

      this.socketClient.Close(); 
      this.socketClient = null; 
     } 
     catch (Exception e) 
     { 

     } 
    } 

Jetzt versuche ich durch Umstecken Aufruf der folgenden Funktionen:

public void StartClient() 
    { 
     this.canRun = true; 
     this.MessageProcessingThread = new Thread(this.MessageProcessingThreadStart); 
     this.MessageProcessingThread.Start(); 
     this.socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); 
     this.socketClient.LingerState.Enabled = false; 
    } 

    public void StartConnecting() 
    { 
     socketClient.BeginConnect(this.remoteEP, new AsyncCallback(ConnectCallback), this.socketClient); 
    } 

    private void ConnectCallback(IAsyncResult ar) 
    { 
     try 
     { 
      // Retrieve the socket from the state object. 
      Socket client = (Socket)ar.AsyncState; 

      // Complete the connection. 
      client.EndConnect(ar); 

      // Signal that the connection has been made. 
      connectDone.Set(); 

      StartReceiving(); 

      NotifyClientStatusSubscribers(true); 
     } 
     catch(Exception e) 
     { 
      StartConnecting(); 
     } 
    } 

Der Socket verbindet sich wieder, wenn die Verbindung verfügbar ist, aber nach ein paar Sekunden bekomme ich die folgende unbehandelte Ausnahme: "Eine Verbindungsanfrage wurde an einen bereits verbundenen Socket gestellt."

Wie ist das möglich?

Answer 1

Es ist möglich, wenn Sie eine Ausnahme in ConnectCallback erhalten und Sie tatsächlich erfolgreich verbunden haben. Legen Sie in der catch-Anweisung des ConnectCallback einen Haltepunkt fest und prüfen Sie, ob dort eine Ausnahme ausgelöst wird. Zurzeit gibt es nichts, was Ihnen sagen könnte, dass Sie eine Ausnahme erhalten haben.