Автоматическое переподключение асинхронного сокетного клиента - PullRequest
Новая
       23

Автоматическое переподключение асинхронного сокетного клиента

2 голосов
/ 28 марта 2012

Я работаю с приложением Windows Form в C #. Я использую сокет-клиент, который асинхронно подключается к серверу. Я хотел бы, чтобы сокет попытался немедленно восстановить соединение с сервером, если соединение разорвано по какой-либо причине. Моя процедура приема выглядит следующим образом 

        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)
        {

        }
    }

Когда вызывается NotifyClientStatusSubscribeers (false), выполняется функция StopClient: 

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)
        {

        }
    }

Теперь я пытаюсь восстановить соединение, вызывая следующие функции: 

    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();
        }
    }

Сокет переподключается, когда соединение доступно, но через пару секунд я получаю следующее необработанное исключение: «Был сделан запрос на соединение с уже подключенным сокетом.»

Как это возможно?

1 Ответ

2 голосов
/ 28 марта 2012

Это возможно, если вы получили исключение в ConnectCallback, и вы на самом деле успешно подключились. Установите точку останова в операторе catch для ConnectCallback и посмотрите, возникает ли там исключение - в настоящее время нет ничего, что сообщило бы вам, что вы получили исключение.

...