使用 C++ 中的套接字传输文件应用程序到Java应用程序

Question

我正在尝试使用套接字将文件从 C++ 应用程序传输到 Java 应用程序。我用 C++ 编写了这个简单的代码来发送文件：

int main() {
    int sock;
    struct sockaddr_in sa;
    char* memblock;

    /* Create socket on which to send. */
    sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
    if (sock < 0) {
        printf("opening datagram socket");
        exit(1);
    }

    /* Construct name of socket to send to. */
    sa.sin_family = AF_INET;
    sa.sin_addr.s_addr = htonl(0x7F000001);
    sa.sin_port = htons(4444);

    /* Send messages. */
    FILE *file;
    unsigned long fileLength = 0;

    file = fopen(FILE_PATH, "rb");
    if (!file) {
        printf("Error opening the file.\n");
        return 1;
    }

    // Get file length.
    fseek(file, 0, SEEK_END);
    fileLength = ftell(file);
    printf("File length is: %d.\n", fileLength);
    fseek(file, 0, SEEK_SET);

    memblock = (char*)malloc(sizeof(char)*fileLength);
    if (memblock == NULL) {fputs ("Memory error",stderr); exit(2);}

    // copy the file into the buffer:
    int result = fread(memblock, 1, fileLength, file);
    if (result != fileLength) {fputs ("Reading error", stderr); exit(3);}

    int pos = 0;
    char* pMemblock = memblock;
    while (pos < fileLength) {
        int sent = sendto(sock, pMemblock, 80, 0, (struct sockaddr*)&sa, sizeof sa);
        if (sent < 0)
            printf("Error sending datagram message.\n");
        else printf("Sent %d.\n", sent);
        pos += 80;
        pMemblock += 80;
    }

    delete memblock;
    fclose(file);

    close(sock);
    return 0;
}

在 Java 端，我是这样写下收到的数据的：

while (true) {
                receiveData = new byte[300];
                receivedPacket = new DatagramPacket(receiveData, receiveData.length);
                serverSocket.receive(receivedPacket);
                try {
                    fou = new FileOutputStream(<filename>, true);
                } catch (FileNotFoundException e1) {
                    e1.printStackTrace();
                }
                fou.write(receivedPacket.getData(), 0, 80);
                fou.close();
            }

结果是我收到的文件在某种程度上是正确的，但并不完整。我的代码中 Java 或 C++ 部分有什么问题吗？ 谢谢！

Answer 1

• UDP 不保证所有数据报都会到达。
• UDP 不保证所有数据报只会到达一次。
• UDP 不保证到达的数据报将按照您发送的顺序排列。

请参阅此处。

如果您仅仅因为发送者和接收者位于同一台计算机上就认为这些规则不适用，那么您就错误地认为这些规则不适用。

没有任何形式的额外可靠性和排序的 UDP 对于您想要做的事情来说根本就是错误的选择。

您应该使用 TCP（或其他可靠的传输）而不是 UDP。

Answer 2

只需查看您的代码，问题可能是，您编写的语句是错误的：

fou.write(receivedPacket.getData(), 0, 80);

应该是：

fou.write(receivedPacket.getData(), 0, receivedPacket.getLength());

另一个注意事项：您是否在 while 循环中有意关闭 FileOutputStream （因此每次执行循环时？（这是并不是真的错，但速度较慢）