通过 gprs 从设备读取消息

Question

我有一个 GPS 设备，将安装在许多卡车上。 我可以配置设备通过 gprs 将数据语句“gps 数据，设备 id”发送到 IP 和端口。 我正在使用 TcpListener 类读取服务器端的数据。

TcpListener server = null;
private void listen_data()
{
    Int32 port = controller_port;
    IPAddress localAddr = IPAddress.Parse(this_ip);
    server = new TcpListener(localAddr, port);
    server.Start();
    Byte[] bytes = new Byte[256];
    String data = null;
    while (true)
    {
        Console.Write("Waiting for a connection...-- ");
        TcpClient client = server.AcceptTcpClient();
        Console.Write("Connected!");
        data = null; int i;
        NetworkStream stream = client.GetStream();
        while ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
        {
            data = System.Text.Encoding.ASCII.GetString(bytes, 0, i);
        }
    }
}

该方法正在侦听服务器 IP 和端口上的情况。

1. 我想知道我是否将设备配置为在同一端口上发送到服务器。我是否能够监听所有设备，或者第一个连接的设备将是唯一的？

2. 此方法是从设备读取传入数据的最佳方法吗？

3. 我是否需要为每个设备配置不同的端口并为每个设备端口创建一个新的侦听线程？

4. 有时我会遇到异常“请求通道在等待回复时超时”

非常感谢您的帮助。

Answer 1

在您的代码中，您正在侦听所有设备，但只有在完成从第一个设备读取所有数据后，您才会收到“请求通道在等待答复时超时”。您应该有不同的线程，每个线程处理一个 tcpClient。

所以代码应该是这样的：

TcpListener server = null;
private void listen_data()
{
    Int32 port = controller_port;
    IPAddress localAddr = IPAddress.Parse(this_ip);
    server = new TcpListener(localAddr, port);
    server.Start();
    while (true)
    {
        Console.Write("Waiting for a connection...-- ");
        TcpClient client = server.AcceptTcpClient();
        Console.WriteLine("new client connected");
        ThreadPool.QueueUserWorkItem(new WaitCallback(HandleClient), client);//or use Task if 4.0 or new Thread...
    }
}

private void HandleClient(object tcpClient)
{
    TcpClient client = (TcpClient)tcpClient;
    Byte[] bytes = new Byte[256];
    String data = null;
    int i;

    NetworkStream stream = client.GetStream();
    while ((i = stream.Read(bytes, 0, bytes.Length)) != 0)
    {
        data = System.Text.Encoding.ASCII.GetString(bytes, 0, i);
    }

    Console.WriteLine(data);
}

Answer 2

1）两者。您应该能够侦听所有设备，但您的​​代码通常无法侦听，因为侦听器线程正在等待来自较早连接的设备的流。

2）可能不是。 IIRC，当对等设备关闭连接时，NetworkStream.Read 返回 0。这是你的协议吗？设备连接、发送一些数据然后断开连接？如果是这样，那就会起作用，尽管速度很慢。无论如何，还有一个问题。您应该将流上收到的字节连接到数据，而不仅仅是替换它们 - Read() 我多次返回一次通信，甚至可能每次只返回一个字节（不太可能，但 TCP 流允许）。您可以保留接收的字节数。到目前为止并使用“offset”参数来执行此操作。

3）你只需要一个监听线程，即。调用 AcceptTcpClient() 的那个。该线程不应进行阻塞调用以从 AcceptTcpClient() 返回的套接字接收数据。创建/分配/释放池/任何新的客户端-服务器线程来为 AcceptTcpClient() 返回的每个“客户端”套接字运行 Read() 循环，或者使用异步 IO。

4) 您的单个侦听器/读取线程在等待 NetworkStream 时将不会响应新连接 - 其他设备将无法连接。侦听器应该快速返回 AcceptTcpClient()，而不是等待慢速网络/设备发送数据。

平均值，
马丁