c# - 从 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，则使用 FromAsync method 会变得更加容易在 TaskFactory class 上.