2

(AsyncCallbacks を使用して) 100 を超えるソケットと通信するシングル スレッド Windows アプリケーションを作成しました。

.NET IDE から起動すると、アプリケーションは正常に動作します。実行可能ファイルから起動すると、アプリケーションがハングするようです。さらに調査したところ、アプリケーションはソケット上で完全に正常に通信しており、UI のデータのみが更新されていないことがわかりました。アプリケーションがビジー状態で、UI を更新するよりもソケットから読み取ることができないようです。

アプリケーションは、AsyncCallback をソケットごとに個別のスレッドに置き換えることで正常に動作しますが、これは良いアプローチではないようです。

メッセージ キューを作成しようとしましたが、役に立ちませんでした。

UI を更新するよりも、アプリケーションがソケットでの読み取りにビジーであると言うのは正しいですか? この問題を解決するにはどうすればよいですか?

AsynCallBack に使用するコードを以下に示します。

    private void ConnectSocket()
    {
        IPEndPoint ipEnd = new IPEndPoint(_ip, _port);
        m_socket = new Socket(ipEnd.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
        m_socket.Blocking = false;
        m_socket.ReceiveBufferSize = RECEIVE_BUFFER_SIZE;
        m_socket.NoDelay = true;
        m_socket.LingerState = new LingerOption(false, 0);

        AsyncCallback onconnect = new AsyncCallback(OnConnect);
        m_socket.BeginConnect(ipEnd, onconnect, m_socket);
    }

    private void OnConnect(IAsyncResult ar)
    {
        Socket sock = (Socket)ar.AsyncState;
        try
        {
            sock.EndConnect(ar);
            if (sock.Connected)
            {
                SetupReceiveCallback(sock);
            }
        }
        catch (Exception ex)
        {
        }
    }

    private void SetupReceiveCallback(Socket sock)
    {
        try
        {
            AsyncCallback receiveData = new AsyncCallback(ReceiveData);
            sock.BeginReceive(receivedBuffer, 0, receivedBuffer.Length,
                SocketFlags.None, receiveData, sock);
        }
        catch (SocketException ex)
        {
        }
        catch (Exception ex)
        {
        }
    }

    private void ReceiveData(IAsyncResult ar)
    {
        Socket sock = (Socket)ar.AsyncState;
        try
        {
            int numBytesReceived = sock.EndReceive(ar);

            if (numBytesReceived > 0)
            {
                if (OnReceivedData != null)
                {
                    OnReceivedData(receivedBuffer);
                }
            }
            SetupReceiveCallback(sock);
        }
        catch (SocketException ex)
        {
            //If error code is 1054 then socket connection is terminated from the client.
        }
        catch (Exception ex)
        {
        }
    }
4

1 に答える 1

1

アプリケーションが忙しくてフリーズするのは非常に奇妙です。ConnectSocket()関数の呼び出しとは何ですか? これが UI イベント (ボタンが押されたときなど) で呼び出された場合、UI スレッドで実行され、終了するまで UI がロックされます。UI を引き続き動作させたい場合は、バックグラウンドで別のスレッドを起動して接続を処理する必要があります。

ThreadPoolクラスを使用してバックグラウンド スレッドを起動し、接続を処理できます。

于 2010-11-08T11:09:52.330 に答える