从 NetworkStream 调用 BeginRead

Question

好的，我想连接到 Socket 并使用 System.Net.Sockets.NetworkStream 类读取网络流。这是我目前所拥有的：

NetworkStream myNetworkStream;
Socket socket;

socket = new Socket(AddressFamily.InterNetwork, SocketType.Raw, 
    ProtocolType.IPv4);
socket.Connect(IPAddress.Parse("8.8.8.8"), 8888);

myNetworkStream = new NetworkStream(socket);

byte[] buffer = new byte[1024];
int offset = 0;
int count = 1024;

myNetworkStream.BeginRead(buffer, offset, count, ??, ??);

现在我需要一个AsyncCallback 和一个Object state 来完成我的BeginRead 方法，但我什至不确定这是否可行。在这一点上我有点迷路了！我需要从这里去哪里？

Answer 1

基本上，当您在异步操作上调用Begin* 方法时，需要调用相应的End* 语句（有关更多详细信息，请参阅Asynchronous Programming Overview on MSDN，特别是标题为“结束一个异步操作”）。

也就是说，您通常希望传递一个方法/匿名方法/lambda 表达式，它会做一两件事：

1) 调用对应的End* 方法，在本例中为Stream.EndRead。此调用在调用时不会阻塞，因为在操作完成之前不会调用callback（请注意，如果在异步调用期间发生异常，则在调用End* 方法时会抛出此异常）。

2) 可能开始一个新的异步调用。在这种情况下，假设您想要读取更多数据，因此您应该开始对 Stream.BeginRead 的新调用

假设您要执行 #2，您可以执行以下操作：

// Declare the callback.  Need to do that so that
// the closure captures it.
AsyncCallback callback = null;

// Assign the callback.
callback = ar => { 
    // Call EndRead.
    int bytesRead = myNetworkStream.EndRead(ar);

    // Process the bytes here.


    // Determine if you want to read again.  If not, return.
    if (!notMoreToRead) return;

    // Read again.  This callback will be called again.
    myNetworkStream.BeginRead(buffer, offset, count, callback, null);
};

// Trigger the initial read.
myNetworkStream.BeginRead(buffer, offset, count, callback, null);

但是，如果您使用的是 .NET 4.0，则使用 TaskFactory class 上的 FromAsync method 会变得更加容易。