0

我在开头有一个序列号的音频数据包,它是 4 个字节。

ByteArrayOutputStream baos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(baos);
dos.writeInt(sequenceNumber);

我以随机顺序接收数据包,然后将其放入缓冲区,即数组数组。

我想知道按序列号排序数据包的最佳方法是什么。

我检索序列号,如:

 ByteArrayInputStream bos = new ByteArrayInputStream(udpPacketBytes);
 DataInputStream ds = new DataInputStream(bos);
 int receivedValue = ds.readInt();

有没有一种不删除序列号的方法,我可以按所述序列号对整个字节数组进行排序?

4

1 回答 1

0

你可以做

byte[] bytes = new byte[ds.available()];
ds.readFully(bytes);

获取剩余的字节。

为确保数据包按照原始顺序,您需要检查序列号是否比前一个多1。如果没有,您需要按序列号保存数据包并重新排序。更具挑战性的问题是,当数据包被丢弃时,您需要再次请求。

你可以使用类似的东西

public class OrderManager {
    int nextSequence = 0;
    final SortedMap<Integer, byte[]> buffered = new TreeMap<>();
    final Consumer<byte[]> consumer;

    public OrderManager(Consumer<byte[]> consumer) {
        this.consumer = consumer;
    }

    public void accept(int num, byte[] bytes) {
        if (num == nextSequence) {
            consumer.accept(bytes);
            nextSequence++;
            while (buffered.firstKey() == nextSequence) {
                consumer.accept(buffered.remove(buffered.firstKey()));
                nextSequence++;
            }
        } else {
            buffered.put(num, bytes);
        }
    }
}

由于乱序数据包很少见,但丢失数据包相当普遍,您可以将乱序数据包视为已丢失,然后将数据包发送给生产者以再次发送。

于 2016-02-23T13:57:41.227 回答