0

我正在编写一个基于 UDP 的流媒体服务器，遇到了一个奇怪的问题，我确信这只是一个简单的错误，但我找不到解决方案。服务器执行以下操作：

FILE* infile = fopen(inf, "rb");
register int sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
int16_t buffer[LENGTH+HEADER];
struct header header;
int16_t data[LENGTH];
uint32_t number = 0;

/*set socket options etc. */

while(!feof(infile)){
    fread(data, 1, LENGTH, infile);
    /* if i write the contents of data to a file here, the error below occurs*/
    fwrite(data, 1, LENGTH, testfile);
    /*create a header, encode everything with htons/htonl*/


    if(sendto(sock, buffer, LENGTH+HEADER, 0, (struct sockaddr*) &to,
                    sizeof to) < 0)
         /*die*/            
}

这似乎有效。我可以解码它并且数据没有损坏。但是，我编写了一个可以工作（或者更确切地说：不工作）的测试客户端，如下所示：

struct sockaddr_in si_other, si_me;
register int s;
unsigned int slen = sizeof(si_other);
int16_t buf[LENGTH+HEADER];
int16_t data[LENGTH];
FILE* file = fopen(of, "wb");

/*open socket, set options, etc. */

while(1){
    if(recvfrom(s, (char *)buf, LENGTH+HEADER, 0, (struct sockaddr*) &si_other,
                 &slen) < 0)
        /*die*/    
    decode(buf, data);
    /* If I write the decoded data to a file here, the error below occurs */
    fwrite(data, 1, LENGTH, testfile);
    if(is_empty(data) == 0){
        printf("End signal received.\n");
        break;
    }
}

现在到我的问题。当我用 以十六进制检查测试文件时diff <(xxd test_before) <(xxd test_after)，我得到了这个（示例差异行）：

< 03d5ff0: f3fd f3fd 99fe 99fe 40ff 40ff e7ff e7ff  ........@.@.....
---
> 03d5ff0: f3fd f3fd 0000 0000 0000 0000 0000 0000  ................

这意味着数据包数据的最后 12 个字节丢失了。其他一切都很好。

这只是测试代码，所以它并不重要（我猜），但它很奇怪，我想知道为什么。

有任何想法吗？

编辑：

我现在已经从答案中尝试了一些方法，到目前为止还没有得到任何结果。我会继续努力。

编辑2：

该代码适用于不同的机器。我不确定问题是什么，但它似乎对除我以外的任何人都有效。很抱歉占用了您的时间，并感谢您对如何改进代码等提出的所有友好建议！

在此先感谢，卡森

4

3 回答 3

2

您正在将2 个字节的buf 转换为char并读取其中包含的一半。

recvfrom(s, (char *)buf, LENGTH+HEADER, 0, (struct sockaddr*) &si_other,
             &slen)

buf数组有字节，(LENGTH+HEADER) * 2你读了一半

对send和receive使用char数组。

编辑

这是读取文件的方式：

unsigned char data[LENGTH];

fseek(inf, 0, SEEK_END);
int file_Size = ftell(inf);
fseek(inf, 0, SEEK_SET);
if(file_Size  > LENGTH){
    //file larger than data
}
fread(data, sizeof(unsigned char), file_Size, inf);
于 2014-10-01T13:39:35.957 回答
2

您的代码非常不完整，因此很难确定。数据在int16_t buffer[LENGTH+HEADER]发送端是如何放入的？解码和编码功能是什么样的？

我可以看到一个明显的危险是您的缓冲区是 type uint16_t，即两个字节。函数sendto()和recvfrom()期望的缓冲区长度（以字节为单位）。换句话说，您的 buf 是您实际告诉的长度（以字节为单位）的两倍sendto()。因此，您的编码功能可能会使一些数据从发送/接收的 pov 中消失。

大胆猜测，丢失 12 个字节可能是一个合适的 4 字节值或其他数据htonl()处理然后在发送中丢失。

发布更完整的代码，以便更好地猜测。

于 2014-10-01T13:57:56.763 回答
0

如编辑 2 中所述，该代码适用于我测试代码的所有机器，但我的机器。我不确定问题是什么，但它似乎对我以外的任何人都有效。很抱歉占用了您的时间，并感谢您对如何改进代码等提出的所有友好建议！

于 2014-10-02T16:49:50.303 回答