如何在 C++ 中拆分和连接数组对于UDP？

Question

我有一个像这样的字节数组：

lzo_bytep out; // my byte array
size_t uncompressedImageSize = 921600;

out = (lzo_bytep) malloc((uncompressedImageSize + 
          uncompressedImageSize / 16 + 64 + 3));
wrkmem = (lzo_voidp) malloc(LZO1X_1_MEM_COMPRESS);

// Now the byte array has 802270 bytes
r = lzo1x_1_compress(imageData, uncompressedImageSize,
        out, &out_len, wrkmem);

如何将其分割成 65,535 字节以下的较小部分（字节数组是一个大图像，我想通过 UDP 发送，其上限为 65,535 字节），然后将这些小块重新连接成一个连续数组？

Answer 1

这样做的问题是 UDP 数据包可能会到达、排序或被丢弃。为此使用 TCP；这就是它的用途。

Answer 2

您不必“拆分”数组。你只需要指出它的不同部分。

假设您使用典型的 UDP write() 函数，它需要几个参数。其中之一是指向缓冲区的指针，另一个是长度。

如果您想获取前 65535 个字节，则缓冲区位于 wrkmem，长度为 65535。

对于第二个 65535 字节，缓冲区位于 wrkmem + 65535， 长度为 65535。长度是 65535。

第三个 65535 字节，您的缓冲区位于 wrkmem + 2 * 65535，您的长度是 65535。

明白了吗？

（也就是说，其他海报是正确的。您应该使用 TCP）。

另一方面，当您想要重新加入数组时，必须为整个数组分配足够的内存，然后使用像 memcpy() 这样的复制函数将到达的块复制到正确的位置。请记住，UDP 可能不会按顺序传送数据块，也可能不会传送所有数据块。

Answer 3

您可能希望尝试基于消息的中间件，例如 ØMQ 并将整个压缩图像作为一条消息提供并使用中间件异步运行并以尽可能最快的速度管理重新交付。它提供了 BSD 套接字兼容的 API，因此可以轻松迁移代码，并允许您根据需要轻松地在各种底层传输协议之间进行交换。

还可以使用其他消息系统。

void my_free (void *data, void *hint)
{
    free (data);
}

    /*  ...  */

size_t uncompressedImageSize = 921600, compressedImageSize = 0;
size_t out_len = (uncompressedImageSize + uncompressedImageSize / 16 + 64 + 3);
lzo_bytep out = (lzo_bytep)malloc (out_len);
lzo_voidp wkrmem = (lzo_voidp)malloc (LZO1X_1_MEM_COMPRESS);
zmq_msg_t msg;

rc = lzo1x_1_compress (imageData, uncompressedImageSize,
                       out, &compressedImageSize, wrkmem);
assert (compressedImageSize > 0);
rc = zmq_msg_init_data (&msg, out, compressedImageSize, my_free, NULL);
assert (rc == 0);
/* Send the message to the socket */
rc = zmq_send (socket, &msg, 0);
assert (rc == 0);