我正在编写一个新的Windows服务应用程序，该应用程序接受长时间运行的TCP/IP连接（即不像HTTP协议那样存在许多短连接，而是客户端连接并保持连接数小时、天甚至数周）。
我正在寻找最佳设计网络架构的思路。我将需要为此服务启动至少一个线程。我正在考虑使用异步API（如BeginRecieve等），因为我不知道在任何给定时间将有多少个客户端连接（可能达到数百个）。我绝对不希望为每个连接启动一个线程。
数据主要会从服务器向客户端流出，但偶尔也会有一些来自客户端的命令发送过来。这主要是一个监控应用程序，在其中我的服务器会定期向客户端发送状态数据。
最好的方法使其尽可能具有可扩展性是什么？基本工作流程是什么？
需要明确的是，我正在寻找基于.NET的解决方案（如果可能的话，是C＃，但任何.NET语言都可以）。
我需要一个工作示例，可以是指向可下载内容的指针或内置的简短示例。它必须是基于.NET和Windows的（任何.NET语言均可接受）。
private void acceptCallback(IAsyncResult result)
{
xConnection conn = new xConnection();
try
{
//Finish accepting the connection
System.Net.Sockets.Socket s = (System.Net.Sockets.Socket)result.AsyncState;
conn = new xConnection();
conn.socket = s.EndAccept(result);
conn.buffer = new byte[_bufferSize];
lock (_sockets)
{
_sockets.Add(conn);
}
//Queue recieving of data from the connection
conn.socket.BeginReceive(conn.buffer, 0, conn.buffer.Length, SocketFlags.None, new AsyncCallback(ReceiveCallback), conn);
}
catch (SocketException e)
{
if (conn.socket != null)
{
conn.socket.Close();
lock (_sockets)
{
_sockets.Remove(conn);
}
}
}
catch (Exception e)
{
if (conn.socket != null)
{
conn.socket.Close();
lock (_sockets)
{
_sockets.Remove(conn);
}
}
}
finally
{
//Queue the next accept, think this should be here, stop attacks based on killing the waiting listeners
_serverSocket.BeginAccept(new AsyncCallback(acceptCallback), _serverSocket);
}
}
你甚至可以删除第一个catch，因为它的内容是相同的，但这是一个模板方法，你应该使用类型化异常来更好地处理异常并理解引起错误的原因，所以只需使用一些有用的代码实现这些catch。
你可以尝试使用一个叫做自适应通信环境（ACE）的框架，它是一个用于网络服务器的通用C++框架。这是一个非常稳定、成熟的产品，旨在支持高可靠性、高容量的电信级应用。
该框架处理了相当广泛的并发模型，可能已经为您的应用程序提供了适合的模型。这应该使系统更容易调试，因为大多数恶劣的并发问题已经得到解决。这里的权衡是，该框架是用C++编写的，不是最温暖、最舒适的代码库。另一方面，您将获得经过测试的工业级网络基础设施和高度可扩展的架构。
我会使用SEDA或轻量级线程库（Erlang或更新的Linux。请参见服务器端NTPL可扩展性）。如果您的通信不是异步编码非常麻烦：）
嗯，.NET套接字似乎提供了select() - 这是处理输入的最佳方法。对于输出，我会有一个套接字写入线程池监听工作队列，将套接字描述符/对象作为工作项的一部分接受，这样你就不需要为每个套接字创建一个线程。
您可以使用Push Framework开源框架进行高性能服务器开发。它基于IOCP构建，适用于推送场景和消息广播。