代码之家 › 专栏 › 技术社区 › Juan Ruiz de Castilla

TcpListener。AcceptSocket生成InvalidOperationException

tcplistener tcpclient wcf c#

Juan Ruiz de Castilla · 技术社区 · 7 年前

我不太熟悉 TcpListener sockets ,但我有以下代码,它们有时在我的初始化器类中正确执行,这些代码来自我的Wcf项目的App_代码,但第一个正确执行的代码有时会显示错误,然后在没有模式的情况下正确执行其他代码。

错误在此行代码中停止:

Socket soc = listener.AcceptSocket();

然后显示这些传统信息:

附加信息:不在听力中。在调用此方法之前,先调用Start()方法。

但正如你们所看到的,我在侦听器之前调用start方法。AcceptSocket()…

我怀疑这是为了尝试在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();
        }
    }

}

1 回复 | 直到 7 年前

Peter Duniho 7 年前

嗯,不清楚为什么如果这是一个WCF程序,您正在使用 Socket 或 TcpListener 直接地WCF的重点是让它为您处理网络输入/输出。

您将获得异常,因为 listener AcceptSocket() 就在第一个线程创建了一个新的 TcpListener公司 对象,但在调用之前 Start() .

你有例外真的很好。如果你运气不好的话,你的代码可以很容易地毫无例外地运行,然后你就会有一个更难调试的问题,因为唯一的症状是,神秘的是,不是所有的侦听器都接受任何客户端。

不

但是,通过传递正确的 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