TcpListener.AcceptSocket 产生 InvalidOperationException

Question

我不熟悉 TcpListener 和 sockets，但我的 App_Code 的初始化程序 class 中有以下代码有时可以正确执行我的 Wcf 项目，但是第一次正确执行它有时会向我显示错误，然后正确执行其他没有模式的错误。

错误停止在这行代码：

Socket soc = listener.AcceptSocket();

然后显示此附加信息：

Additional Information: Not in Listening. Call the Start () method before calling this method.

但是你可以看到我在 listener.AcceptSocket() 之前调用了 start 方法…

我怀疑这是为了尝试在 WCF 项目中启动 init 守护进程。

public static void AppInitialize()
{
    // This will get called on startup
    new Initializer().StartListener();
}

static TcpListener listener;
const int LIMIT = 5; //5 concurrent clients
private void StartListener()
{
    List<int> puertos = new List<int>();

    puertos.Add(5494);
    puertos.Add(5495);
    puertos.Add(5496);
    puertos.Add(5497);

    foreach (int puerto in puertos)
    {
        IPAddress localAddr = IPAddress.Parse(ConfigurationManager.AppSettings["ServerIP"]);
        listener = new TcpListener(localAddr, puerto);
        listener.Start();

        for (int i = 0; i < LIMIT; i++)
        {
            Thread t = new Thread(new ThreadStart(Service));
            t.Start();
        }
    }

}

private void Service()
{
    while (true)
    {
        //Error happen hear, but listener.Start execute before... .
        Socket soc = listener.AcceptSocket();

        try
        {

            byte[] resp = new byte[2000];
            var memStream = new MemoryStream();
            var bytes = 0;

            NetworkStream s = new NetworkStream(soc);
            StreamReader sr = new StreamReader(s);

            while (true)
            {
                string trama = "";
                if (s.CanRead)
                {
                    do
                    {
                        bytes = s.Read(resp, 0, resp.Length);
                        trama = Util.Util.ByteArrayToHexString(resp);
                    }
                    while (s.DataAvailable);
                }

                if (trama == "" || trama == null) break;

            }
            s.Close();
        }
        catch (Exception e)
        {
        }
        finally
        {
            soc.Close();
        }
    }

}

Answer 1

嗯，不清楚为什么如果这是一个 WCF 程序，您直接使用 Socket 或 TcpListener。 WCF 的意义在于让它为您处理网络I/O。

也就是说……

您收到异常是因为 listener 字段在您的所有线程之间共享，并且您的一个或多个线程已设法到达 AcceptSocket() 就在第一个线程创建了一个新的 TcpListener 对象之后，但在它被调用之前 Start().

你得到例外确实很好。你的代码很容易有运行没有那个例外，如果你足够不幸，然后你会遇到更难调试的问题，因为唯一的症状是，神秘的是，并不是所有的听众都接受任何客户。

恕我直言，最好设计代码，以便您有单独的对象实例来处理每个侦听套接字（并使用 non-static 成员作为值）。这样，您就可以确保每个侦听器都正确且独立地运行。

但是，至少在异常方面，通过将正确的 TcpListener 对象传递给每个线程，您可以修复此处的代码：

private void StartListener()
{
    List<int> puertos = new List<int>();

    puertos.Add(5494);
    puertos.Add(5495);
    puertos.Add(5496);
    puertos.Add(5497);

    foreach (int puerto in puertos)
    {
        IPAddress localAddr = IPAddress.Parse(ConfigurationManager.AppSettings["ServerIP"]);
        TcpListener listener = new TcpListener(localAddr, puerto);
        listener.Start();

        for (int i = 0; i < LIMIT; i++)
        {
            Thread t = new Thread(() => Service(listener));
            t.Start();
        }
    }

}

private void Service(TcpListener listener)
{
    while (true)
    {
        Socket soc = listener.AcceptSocket();

        try
        {

            byte[] resp = new byte[2000];
            var memStream = new MemoryStream();
            var bytes = 0;

            NetworkStream s = new NetworkStream(soc);
            StreamReader sr = new StreamReader(s);

            while (true)
            {
                string trama = "";
                if (s.CanRead)
                {
                    do
                    {
                        bytes = s.Read(resp, 0, resp.Length);
                        trama = Util.Util.ByteArrayToHexString(resp);
                    }
                    while (s.DataAvailable);
                }

                if (trama == "" || trama == null) break;    
            }
            s.Close();
        }
        catch (Exception e) { }
        finally
        {
            soc.Close();
        }
    }
}

一定要删除 static TcpListener listener; 字段。

最后一点：你应该从不捕获Exception，除了在代码的一部分，所有将发生的是，可选地记录异常，进程终止。

TcpListener.AcceptSocket 产生 InvalidOperationException

TcpListener.AcceptSocket produce InvalidOperationException

c#

wcf

tcpclient

tcplistener