C#同时监听两个tcp端口

Question

我打开两个 tcp 端口来监听我的服务器的客户端。下面是我打开端口的代码。我用一个线程：

            clientThreadTS = new Thread(ClientListenerTS);
            clientThreadTS.IsBackground = true;
            clientThreadTS.Name = "client listener TS";
            clientThreadTS.Start();

            clientThreadDis = new Thread(ClientListenerDis);
            clientThreadDis.IsBackground = true;
            clientThreadDis.Name = "client listener Dis";
            clientThreadDis.Start();

客户端监听函数：

        private void ClientListenerTS()
    {
        try
        {
            if (bRestartListener)
            {
                Debug.WriteImportant("Restart QS listener");
                bRestartListener = false;
                htTCPClientTS.Clear();

                if (theClientListener != null)
                {
                    try
                    {
                        theClientListener.Close();
                    }
                    catch (Exception ex2)
                    {
                    }
                }
                theClientListener = null;

            }

            if (theClientListener == null)
            {
                try
                {
                    Debug.WriteImportant("Creating listener for client TS at any local IPs - port " + nConstClientPortTS);

                    IPEndPoint localEP = new IPEndPoint(IPAddress.Any, nConstClientPortTS);
                    theClientListener = new Socket(localEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
                    theClientListener.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
                    theClientListener.Bind(localEP);
                    theClientListener.Listen(100);
                    theClientListener.BeginAccept(new AsyncCallback(AcceptConnectBackTS), theClientListener);

                }
                catch (Exception ex2)
                {
                    Debug.WriteLine(ex2.ToString());
                    System.Threading.Thread.Sleep(500);
                    theClientListener = null;
                }
            }

        }
        catch (Exception ex)
        {
            Debug.WriteLine(ex.ToString());
        }
    }

    private void ClientListenerDis()
    {
        try
        {
            if (bRestartListener)
            {
                Debug.WriteImportant("Restart QS listener");
                bRestartListener = false;
                htTCPClientDis.Clear();

                if (theClientListener != null)
                {
                    try
                    {
                        theClientListener.Close();
                    }
                    catch (Exception ex2)
                    {
                    }
                }
                theClientListener = null;

            }

            if (theClientListener == null)
            {
                try
                {
                    Debug.WriteImportant("Creating listener for client display at any local IPs - port " + nConstClientPortDis);


                    IPEndPoint localEP = new IPEndPoint(IPAddress.Any, nConstClientPortDis);
                    theClientListener = new Socket(localEP.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
                    theClientListener.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
                    theClientListener.Bind(localEP);
                    theClientListener.Listen(100);
                    theClientListener.BeginAccept(new AsyncCallback(AcceptConnectBackDis), theClientListener);

                }
                catch (Exception ex2)
                {
                    Debug.WriteLine(ex2.ToString());
                    System.Threading.Thread.Sleep(500);
                    theClientListener = null;
                }
            }

        }
        catch (Exception ex)
        {
            Debug.WriteLine(ex.ToString());
        }
    }

问题总是只是第一个端口成功打开。第二个端口没有打开。

代码是否正确编写？打开第一个端口后是否需要延迟再打开另一个端口？

知道为什么只打开第一个端口吗？

Answer 1

您可以按照答案中的示例进行操作。

https://social.msdn.microsoft.com/Forums/vstudio/en-US/09828be4-6ac4-45ec-a116-508314dab793/listen-on-multiple-ports?forum=csharpgeneral

监听类：

class ListenPorts
{
    Socket[] scon;
    IPEndPoint[] ipPoints;

   internal ListenPorts(IPEndPoint[] ipPoints)
    {
        this.ipPoints = ipPoints;

        scon = new Socket[ipPoints.Length];
    }

    public void beginListen()
    {
        for (int i = 0; i < ipPoints.Length; i++)
        {
            scon[i] = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            scon[i].Bind(ipPoints[i]);

            Thread thread = new Thread(threadListen);

            thread.Start(scon[i]);
        }
    }



    public void threadListen(object objs)
    {
        Socket scon = objs as Socket;
        byte[] data = new byte[1024];

        IPEndPoint sender = new IPEndPoint(IPAddress.Any, 0);

        EndPoint Remote = (EndPoint)(sender);

        try
        {
            scon.Listen(100);
            Socket newSocket = scon.Accept();
            newSocket.ReceiveFrom(data, ref Remote);
           // scon.ReceiveFrom(data, ref Remote);
        }

        catch (SocketException ex)
        {
            Console.WriteLine(ex.Message);
        }

       Console.WriteLine(scon.LocalEndPoint.ToString() + "IP {0}: ", Remote.ToString());
    }
}

调用类监听的方法：

    static void Main(string[] args)
    {
        IPEndPoint ipPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8080);
        IPEndPoint ipPoint1 = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 8081);

        IPEndPoint[] ipPoints = new IPEndPoint[2] { ipPoint, ipPoint1 };
        ListenPorts lp = new ListenPorts(ipPoints);

        Console.WriteLine("Begin Listen");

        lp.beginListen();
    }