0

我有一个程序，它通过监听连接开始。我想实现一种模式，其中服务器将接受一个连接，将该单独的连接传递给用户类进行处理：未来的数据包接收和数据处理。

Socket在我发现类的异步使用并不可怕之前，我遇到了同步模式的麻烦。但后来我遇到了更多的麻烦。看起来，在一个while (true)循环中，由于BeginAccept()是异步的，程序会不断地通过这个循环并最终运行到一个OutOfMemoryException. 我需要一些东西来监听连接，并立即将该连接的责任移交给其他班级。

因此，我阅读了 Microsoft 的示例并了解了ManualResetEvent. 我实际上可以指定何时准备好让循环再次开始收听！但是在阅读了有关 Stack Overflow 的一些问题后，我变得困惑。

我担心的是，即使我已经异步接受了一个连接，整个程序在重新进入循环时尝试侦听新连接时也会阻塞。如果我要处理多个用户，这并不理想。

我对异步 I/O 的世界很陌生，所以即使是对我的词汇或短语滥用的最愤怒的评论，我也会很感激。

代码：

static void Main(string[] args)
{
    MainSocket = new Socket(SocketType.Stream, ProtocolType.Tcp);
    MainSocket.Bind(new IPEndPoint(IPAddress.Parse("192.168.1.74"), 1626));
    MainSocket.Listen(10);

    while (true)
    {
        Ready.Reset();
        AcceptCallback = new AsyncCallback(ConnectionAccepted);
        MainSocket.BeginAccept(AcceptCallback, MainSocket);
        Ready.WaitOne();
    }
}

static void ConnectionAccepted(IAsyncResult IAr)
{
    Ready.Set();
    Connection UserConnection = new Connection(MainSocket.EndAccept(IAr));
}
4

1 回答 1

1

Microsoft 的示例中，他们使用了基于旧样式WaitHandle的事件，这将起作用，但坦率地说，这是实现异步代码的一种非常奇怪和尴尬的方式。我觉得示例中的事件主要是作为人为同步主线程的一种方式，因此它有事可做。但这并不是真正正确的方法。

一种选择是甚至不异步接受套接字。相反，在连接套接字时使用异步 I/O，并在主线程中使用同步循环来接受套接字。这最终几乎完全是 Microsoft 示例所做的，但将所有接受逻辑保留在主线程中，而不是在主线程（启动接受操作）和一些处理完成的 IOCP 线程之间来回切换.

另一种选择是只让主线程做其他事情。举个简单的例子，这可能只是等待一些用户输入来发出程序应该关闭的信号。当然，在实际程序中，主线程可能是有用的（例如，在 GUI 程序中处理消息循环）。

如果主线程有其他事情要做，那么您可以按照BeginAccept()预期的方式使用异步：您调用该方法来启动接受操作，然后在该操作完成之前不要再次调用它。初始调用发生在您初始化服务器时，但所有后续调用都发生在完成回调中。

在这种情况下，您的完成回调方法看起来更像这样：

static void ConnectionAccepted(IAsyncResult IAr)
{
    Connection UserConnection = new Connection(MainSocket.EndAccept(IAr));
    MainSocket.BeginAccept(ConnectionAccepted, MainSocket);
}

也就是说，您只需BeginAccept()在完成回调本身中调用该方法。（请注意，无需AsyncCallback显式创建对象；编译器将代表您将方法名称隐式转换为正确的委托类型实例）。

于 2015-05-16T05:05:27.600 回答