如何从网络流中同步读取数据？

Question

我想用C#从网络流中读取数据。

我有一个定期轮询的客户端列表，但是当我开始从一个客户端读取数据时，我必须读取整个 xml 消息，然后继续读取下一个客户端。 如果接收数据有一些延迟，我不应该去下一个客户端。 我应该等待一段时间并获取数据。 而且，我不应该无限期地等待。 只需超时并在 x 秒后继续处理下一个客户端...

if(s.Available > 0)
{
//read data till i get the whole message.
//timeout and continue with other clients if I dont recieve the whole message 
//within x seconds.
}

有没有办法在 C# 中优雅地执行此操作？

Answer 1

据我所知，没有办法做到这一点，所以你很可能最终会使用多个线程。 恕我直言，每个客户端使用一个线程首先是一个更干净的解决方案，然后您只需在流上调用 Read() 即可，并且可以根据需要花费多长时间，而其他线程正在为其他客户端执行相同的操作。

线程一开始可能有点可怕，特别是如果您使用 Windows 窗体（到处都是代理！）而不是控制台应用程序，但它们非常有用。 如果使用得当，它们可以提供很大帮助，尤其是在网络领域。

Answer 2

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

public class SynchronousSocketClient {

    public static void StartClient() {
        // Data buffer for incoming data.
        byte[] bytes = new byte[1024];

        // Connect to a remote device.
        try {
            // Establish the remote endpoint for the socket.
            // This example uses port 11000 on the local computer.
            IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName())
            IPAddress ipAddress = ipHostInfo.AddressList[0];
            IPEndPoint remoteEP = new IPEndPoint(ipAddress,11000);

            // Create a TCP/IP  socket.
            Socket sender = new Socket(AddressFamily.InterNetwork, 
                SocketType.Stream, ProtocolType.Tcp );

            // Connect the socket to the remote endpoint. Catch any errors.
            try {
                sender.Connect(remoteEP);

                Console.WriteLine("Socket connected to {0}",
                    sender.RemoteEndPoint.ToString());

                // Encode the data string into a byte array.
                byte[] msg = Encoding.ASCII.GetBytes("This is a test<EOF>");

                // Send the data through the socket.
                int bytesSent = sender.Send(msg);

                // Receive the response from the remote device.
                int bytesRec = sender.Receive(bytes);
                Console.WriteLine("Echoed test = {0}",
                    Encoding.ASCII.GetString(bytes,0,bytesRec));

                // Release the socket.
                sender.Shutdown(SocketShutdown.Both);
                sender.Close();

            } catch (ArgumentNullException ane) {
                Console.WriteLine("ArgumentNullException : {0}",ane.ToString());
            } catch (SocketException se) {
                Console.WriteLine("SocketException : {0}",se.ToString());
            } catch (Exception e) {
                Console.WriteLine("Unexpected exception : {0}", e.ToString());
            }

        } catch (Exception e) {
            Console.WriteLine( e.ToString());
        }
    }

    public static int Main(String[] args) {
        StartClient();
        return 0;
    }
}

（摘自msdn上的“同步客户端套接字示例”）

Answer 3

不，没有办法做到这一点。 TCP 不保证所有内容立即到达，因此您需要知道 XML 的大小才能知道所有内容是否都已到达。 而你不知道这一点。 正确的？

使用异步方法是可行的方法（并使用 XML 构建字符串）