当每个端口接受多个连接时如何监听多个 TCP 端口

Question

我需要使用 TcpListener 监听多个端口，并且我需要 TcpListener 接受多个连接并单独处理每个端口，这是我编写的代码，但正如您所看到的，它只监听第一个端口，然后转到 while(true) 和侦听到达该端口的所有连接。知道我如何才能监听多个端口的多个连接吗？

   private static async Task TcpServerAsync()
    {
        try
        {

            IPAddress ip;
            if (!IPAddress.TryParse(ConfigurationManager.AppSettings["ipAddress"], out ip))
            {
                Console.WriteLine("Failed to get IP address, service will listen for client activity on all network interfaces.");
                ip = IPAddress.Any;
            }


            foreach (Ports port in Ports.GetValues(typeof(Ports)))
            {

                Log.Info("Starting listener...");
                var tcpListener = new TcpListener(ip, (int)port);

                tcpListener.Start();
                Log.Info("Listening...");

                var startTimeSpan = TimeSpan.Zero;
                var periodTimeSpan = TimeSpan.FromSeconds(10000000);


                while (true)
                {
                    TcpClient client = await tcpListener.AcceptTcpClientAsync();
                    client.Client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionNam‌​e.KeepAlive, 1);
                    HandleByPortNumber(client, (int)port);
                }
            }
        }
        catch (Exception ex)
        {
            Log.Info("Error Happened : " + ex + ex.InnerException);
        }
}

和

   public static void HandleByPortNumber(TcpClient client , int portNumber)
    {
        switch (portNumber)
        {
            case (int)Ports.Teltonica:
                var cw = new Teltonika.TcpClientService(client);
                ThreadPool.UnsafeQueueUserWorkItem(x =>  ( (Teltonika.TcpClientService)x).Run(), cw);
                break;

            case (int)Ports.OBDTracker:
                break;
        }
    }

和

 public enum Ports
{
    Teltonica = 3000,
    OBDTracker = 3001
}

Answer 1

这是一个删除了额外内容（日志记录等）的实现。测试和工作。这里要解决的问题是如何从一个任务映射回它的监听器和端口号。显然，我的端口号列表对您不起作用，但除此之外它应该起作用。您还希望将 Tuple 替换为自定义类，以获得更好的可读性。

IDictionary<Task<TcpClient>, Tuple<int, TcpListener>> tcpListeners = new Dictionary<Task<TcpClient>, Tuple<int, TcpListener>>();

foreach (var port in Enumerable.Range(20000, 5))
{
    var tcpListener = new TcpListener(IPAddress.Any, port);

    tcpListener.Start();

    var task = tcpListener.AcceptTcpClientAsync();
    var tcpListenerPortPair = new Tuple<int, TcpListener>(port, tcpListener);

    tcpListeners.Add(task, tcpListenerPortPair);
}

Task<TcpClient> tcpClientTask;

while ((tcpClientTask = await Task.WhenAny(tcpListeners.Keys)) != null)
{
    var tcpListenerPortPair = tcpListeners[tcpClientTask];
    var port = tcpListenerPortPair.Item1;
    var tcpListener = tcpListenerPortPair.Item2;

    tcpListeners.Remove(tcpClientTask);

    // This needs to be async. What to do with its Task?
    // It cannot be awaited here.
    var handlerTask = HandleByPortNumber(tcpClientTask.Result, port);

    var task = tcpListener.AcceptTcpClientAsync();

    tcpListeners.Add(task, tcpListenerPortPair);
}