Android 是否为 DatagramSocket 排队 UDP 数据包



我最近在我的Android(特别是2.3.3和4.0.4)应用程序中实现了UDP数据包排序支持,该应用程序在设备之间广播UDP数据包。排序支持基本上采用任何字节[]并将其分成UDP友好的大小,并将它们作为UDP数据包发送出去。我包含一个标头,有助于UDP序列识别。现在看来,似乎通过它广播大型数据集是有效的。任何侦听它的对等方都可以很好地重新组装序列,然后相应地处理数据。(我正在播放用相机和语音剪辑拍摄的图像)

我发现偶尔(通常)序列中的数据包会被丢弃。在有人说UDP不可靠之前,不要打扰。我很清楚。这里发生的事情不一定是不可靠的。

首先,UDP 数据包排序将每 2 秒发送 1 个分段 UDP 数据包,例如,如果数据为 128K,则将有 3 个数据包,在 6 秒内发送出去。2秒数字是为了帮助测试。

其次,我的隔离测试环境中只有 2 台设备。他们是测试wifi网络上唯一的。

第三,这些设备除了测试发送和接收这些UDP数据包外什么都不做。

第四,我的日志记录跟踪每个数据包的唯一基于序列的 ID。它有助于确定发送方按顺序发送哪个数据包,以及接收方接收了哪个数据包。

我无法向您展示日志,这无济于事,但发送方会注意到每个数据包都已广播,而接收方可能会在任何时候丢弃一个数据包。有时接收者得到一切,有时它缺少一个。

现在我已经解释了所有这些,Android 队列是否收到了处理套接字的 UDP 数据包?

我不认为接收方太忙而无法接受UDP数据包。(每 2 秒发送一次)

目前我的服务启动了一个 Runnable,它基本上在 DatagramSocket.receive() 上循环,然后相应地处理收到的数据包。

public class MulticastListenerRunnable implements Runnable {
    ...
    public void run() {
        try {
            multicastServer = new DatagramSocket(port, null);
            byte[] buffer = new byte[DatagramSession.DATAGRAM_MAX_SIZE];
            DatagramPacket packet = null;
            byte[] data;
            while(run) {
                try {
                    packet = new DatagramPacket(buffer, buffer.length);
                    packet.setLength(buffer.length);
                    multicastServer.receive(packet);
if(packet.getAddress().getHostAddress().equals("127.0.0.1") || packet.getAddress().getHostAddress().equals(ipAddress)) {
                        continue;
                    }
                    Log.d(TAG, "START PACKET RECEIVE!");
                    processPacket(packet);
            }
        } catch (IOException e) {
            Log.e(TAG, e.getMessage());
        } catch (Exception e) {             
            Log.e(TAG, e.getMessage());
        }
    }
}

在我的日志中,我将从字面上看到:(这是志中的剪辑,而不是直接来自上述代码剪辑的输出)

03-21 01:26:35.453: D/CommService(6446): START PACKET RECEIVE!
03-21 01:26:35.507: D/CommService(6446): RECEIVED PACKET:  19 of 28 -> 64977(65000 max)
03-21 01:26:35.515: D/CommService(6446): RECEIVED PACKET: This packet isn't alone. More to come!
03-21 01:26:35.515: D/CommService(6446): END PACKET RECEIVE!

03-21 01:26:39.460: D/CommService(6446): START PACKET RECEIVE!
03-21 01:26:39.468: W/DatagramSession(6446): Warning, this packet's sequence isn't in order, last -> 18, new -> 20
03-21 01:26:39.476: D/CommService(6446): RECEIVED PACKET: This packet isn't alone. More to come!
03-21 01:26:39.476: D/CommService(6446): END PACKET RECEIVE!

请注意,数据包 20 丢失。如果我查看发送方设备的日志,我会看到他每 2 秒发送一次所有数据包。您可以在时间码中看到数据包 19 在 1:26:35 接收,数据包 21 在 1:26:39 接收。(中间4秒)

我有点茫然。安卓和UDP丢包是否存在已知问题?Android/Java UDP 堆栈队列是否在一段时间内接收到数据包,服务是否忙于处理其他数据包?

除了切换到TCP之外的任何建议都会有所帮助。提前感谢!

好的,我解决了我的问题。

我将应用程序服务中的单个 ScheduledExecutorService + Runnable 线程切换到 Runnable,它将生成新的 ExecutorService Runnables 来处理收到的 DatagramPacket。我想我的接收器中有一点 I/O 延迟/阻塞,并将其拆分为单独的线程来处理数据包数据似乎有效。我使用新方法在设备之间传输了 1.8MB 大小的数据测试。

最新更新