帮助事件驱动的TCP服务器

Question

我正在开发一个"应用程序系统",我还需要创建一个服务器应用程序.我在C#(.NET 4.0)工作.服务器将主要收集来自不同POS应用程序/客户端的数据(应该是大约50-100,但服务器应该能够处理大约200-300个客户端).从单个客户端,服务器可能每天大约100x次接收大约1KB.服务器主要需要接受数据,解密并将其存储到磁盘.它还应该检查特定目录中的更改,以便向客户端发送新配置,这不应该经常发生.

我对C#和服务器编程很陌生,所以请耐心等待.我考虑过使用线程池和异步方法(在一本书中简单地使用了一个很好的例子"C#").但我花了很多时间寻找最佳解决方案,我发现了这一点.但在我的情况下,多线程带来的问题多于好处.因此我想到了甚至驱动服务器."一个进程,在回调中处理每个事件(接受的连接,可读取的数据,可以写入客户端,......)." 来自" 什么是事件驱动的Web服务器 ".我发现这是我问题的最佳解决方案.

但我不知道如何编码,我找不到任何关于事件驱动服务器的例子.据我所知,我应该创建一个线程(GUI为+ 1),然后创建一个TCP侦听器然后以某种方式创建事件,以便当TCP侦听器可以接受客户端时,事件将触发并唤醒服务器,同样在数据时从客户端读取将可用它将唤醒服务器.

请帮我编代码,我完全迷失了.我知道如何使用它

while(true)
{
   check if client wants to connect
        accept client and add it to client list
   iterate through client list and check if anyone is sending data ...
        accept data and store it
   ...
  }

但这不是事件驱动的,而是在浪费CPU.服务器不会非常活跃,所以我想让它尽可能高效.

一些例子真的会有所帮助.

谢谢你的时间和答案.

ps我可以只为所有客户端使用一个端口吗？

编辑:为了澄清,我想编写一个事件驱动的服务器,但我不知道如何,因此我只是做了一个我知道的例子(客户端轮询).

Answer 1

这是您可能需要的服务器框架。不处理任何异常。

class Program
{
    public static ManualResetEvent connected = new ManualResetEvent(false);

    static void Main(string[] args)
    {
        string ip = "127.0.0.1";
        int port = 14500;

        TcpListener server = new TcpListener(IPAddress.Parse(ip), port);
        server.Start();

        Console.WriteLine("Server started...");

        while (true)
        {
            connected.Reset();
            server.BeginAcceptTcpClient(new AsyncCallback(AcceptCallback), server);
            connected.WaitOne();
        }
    }

    public static void AcceptCallback(IAsyncResult ar)
    {
        TcpListener listener = (TcpListener)ar.AsyncState;
        TcpClient client = listener.EndAcceptTcpClient(ar);

        byte[] buffer = new byte[1024];
        NetworkStream ns = client.GetStream();
        if (ns.CanRead)
        {
            ns.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(ReadCallback), new object[] { ns, buffer });
        }

        connected.Set();
    }

    public static void ReadCallback(IAsyncResult ar)
    {
        NetworkStream ns = (NetworkStream)((ar.AsyncState as object[])[0]);
        byte[] buffer = (byte[])((ar.AsyncState as object[])[1]);
        int n = ns.EndRead(ar);
        if (n > 0)
        {
            Console.WriteLine(Encoding.ASCII.GetString(buffer, 0, n));
        }
        ns.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(ReadCallback), new object[] { ns, buffer });
    }
}