C++ 发送带有套接字丢失数据的向量<uchar>

Question

我正在尝试将带有套接字的图像从服务器发送到客户端，但由于某种原因我丢失了很多数据。

这是我的服务器：

#include <opencv2/imgcodecs.hpp>
#include <iostream>
#include <unistd.h>
#include <stdio.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <netinet/in.h>
#include <string.h>
#include <string>

#define PORT 8080

using namespace cv;
using namespace std;

int main(int argc, char const *argv[])
{
    int server_fd, new_socket, valread;
    struct sockaddr_in address;
    int opt = 1;
    int addrlen = sizeof(address);
    char buffer[1024] = {0};

    // Creating socket file descriptor
    if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0)
    {
        perror("socket failed");
        exit(EXIT_FAILURE);
    }

    // Forcefully attaching socket to the port 8080
    if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT,
                                                &opt, sizeof(opt)))
    {
        perror("setsockopt");
        exit(EXIT_FAILURE);
    }
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons( PORT );

    // Forcefully attaching socket to the port 8080
    if (bind(server_fd, (struct sockaddr *)&address,
                                sizeof(address))<0)
    {
        perror("bind failed");
        exit(EXIT_FAILURE);
    }
    if (listen(server_fd, 3) < 0)
    {
        perror("listen");
        exit(EXIT_FAILURE);
    }
    if ((new_socket = accept(server_fd, (struct sockaddr *)&address,
                    (socklen_t*)&addrlen))<0)
    {
        perror("accept");
        exit(EXIT_FAILURE);
    }

  Mat image = cv::imread("Rio.jpg",IMREAD_COLOR); //BGR
  std::vector< uchar > buf;
  cv::imencode(".jpg",image,buf);

  cerr << send(new_socket , buf.data() , buf.size(),0);
  cerr << buf.data();

  return 0;
}

这个文件的输出是： 562763����

562763 应该是发送到客户端的数据大小，而 ���� 应该是数据。

这是我的客户：

#include <opencv2/imgcodecs.hpp>
#include <stdio.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <string>
#include <stdlib.h>
#include <netinet/in.h>
#include <iostream>
#define PORT 8080
using namespace std;
using namespace cv;
int main(int argc, char const *argv[])
{
    int sock = 0, valread;
    struct sockaddr_in serv_addr;

    char buffer[1024] = {0};
    if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        printf("\n Socket creation error \n");
        return -1;
    }

    serv_addr.sin_family = AF_INET;
    serv_addr.sin_port = htons(PORT);

    // Convert IPv4 and IPv6 addresses from text to binary form
    if(inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr)<=0)
    {
        printf("\nInvalid address/ Address not supported \n");
        return -1;
    }

    if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
    {
        printf("\nConnection Failed \n");
        return -1;
    }

    int l = 0;
    std::string data = "";
    do{
        data += buffer;
            l += strlen(buffer);
        valread = read( sock , buffer, 1024);

    }while(valread != 0);

    cerr << l;
    char* c = const_cast<char*>(data.c_str());
    std::vector<uchar> vec(c,c+l);


    Mat image2 = cv::imdecode(vec, 1);


    // cv::imwrite("test22.jpg",image2);

    return 0;
}

我得到的输出是： 87567损坏的 JPEG 数据：标记 0xec 之前的 175 个无关字节

87567应该是接收到的数据的大小，因为有数据丢失jpeg无法创建

当我发送“这是一个测试”之类的消息时，客户端会收到全文。

Answer 1

您有两个主要缺陷，一个可能导致无限循环，另一个导致您遇到的问题：

1. 如果read 在客户端失败并返回-1，则会发生无限循环问题。 -1 != 0，然后read 将继续读取-1。

2. 第二个也是主要的问题是您将在程序之间发送的数据视为 字符串，而事实并非如此。 “字符串”是 null-terminated（即零终止）字符序列，您的图像不是这样。事实上，它甚至可能在数据中包含嵌入的零，这也会在中间为您提供无效数据。

为了解决这两个问题，我建议您将读取循环（以及使用的变量）更改为如下内容：

uchar buffer[1024];
ssize_t read_result;
std::vector<uchar> data;

// While there's no error (read returns -1) or the connection isn't
// closed (read returns 0), continue to append the received data
// into the vector
while ((read_result = read(sock, buffer, sizeof buffer)) > 0)
{
    // No errors, no closed connection
    // Append the new data (and only the new data) at the end of the vector
    data.insert(end(data), buffer, buffer + read_result);
}

在这个循环之后，如果read_result == 0，那么data 应该只包含发送的数据。以及所有这些。

Answer 2

在您阅读任何内容之前，您正在使用buffer。您还假设它是空终止的。

这样的东西看起来更好

std::string data = "";
for (;;)
{
    valread = read( sock , buffer, 1024);
    if (valread <= 0)
        break;
    data.append(buffer,valread);
}