python - 尝试将数据从 C++ 发送到 Python 并使用套接字 C++、C++ sendto() 和 python recvfrom() 工作但不是反向

Question

TLDR；我尝试将数据从 C++ 程序发送到 Python 程序并反转，我设法从 C++ 发送数据并在 python 上接收，但没有从 python 发送到 C++

好的，在进入代码之前，我将解释我正在尝试做什么(希望它能让我更容易理解我的代码): 我想创建一个服务器，它将监听和读取来自 C++ 客户端的图像并返回另一个图像

(服务器端-Python) 首先，我创建了一个套接字并将其与本地主机的端口 5001 绑定(bind)

(客户端-C++) 我创建了一个套接字，读取图像(这里我使用 OpenCV)先发送图像大小然后发送图像本身，并等待服务器响应

(服务器端-Python) 读取尺寸并使用接收到的尺寸读取图像

-- 此时一切都按预期工作 --

(服务器端-Python) 服务器读取图像并发回

(客户端-C++) 客户端因为没有收到任何东西而卡住？

我花了 4 个小时没有结果 :( 这是我的代码:

服务器Python

import socket
import cv2
import numpy
import time


UDP_IP = '127.0.0.1'
UDP_PORT = 5001

#Create socet here
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind((UDP_IP, UDP_PORT))

#Get image size here
length, addr = s.recvfrom(16)

#read image data here
stringData,addr = s.recvfrom(int(length))

#Convert to opencv image format
data = numpy.fromstring(stringData, dtype='uint8')
decimg=cv2.imdecode(data,0)

############################################################################

#Read an image
sendBackImg = cv2.imread("cat.jpeg",0)

#Encode file
encode_param=[int(cv2.IMWRITE_JPEG_QUALITY),90]
result, imgencode = cv2.imencode('.jpg', sendBackImg, encode_param)
data = numpy.array(imgencode)
stringData = data.tostring()

#Send image size
s.sendto(str(len(stringData)).zfill(16), (UDP_IP, UDP_PORT))
# s.sendto(stringData, (UDP_IP, UDP_PORT))

#Show image to check if it work correctly
cv2.imshow('SERVER-SEND',sendBackImg)
cv2.imshow('SERVER-SEND',decimg)

cv2.waitKey(3000)

s.close()

cv2.destroyAllWindows()

客户端 C++

#undef UNICODE

#define WIN32_LEAN_AND_MEAN
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>

#include <iostream>
#include <string.h>
#include <sys/socket.h> 
#include <arpa/inet.h> 
#include <opencv2/objdetect/objdetect.hpp>
#include <opencv2/highgui/highgui.hpp>
#include <opencv2/imgproc/imgproc.hpp>

#define PORT 5001

using namespace std;
using namespace cv;

int main(void)
{
    int sock = 0, valread;
    struct sockaddr_in serv_addr;

    // read an image and show it so later and can compare with result on server side
    Mat frame = imread("dog.jpg",0);
    imshow("CLIENT",frame);

    // Encode image
    vector<uchar> buf;
    imencode(".jpg",frame,buf);

    const char *data = reinterpret_cast<char*>(buf.data());

    int strLength = buf.size();

    std::string strSizeTmp = std::to_string(strLength);
    strSizeTmp = string(16-strSizeTmp.length(),'0')+strSizeTmp ;
    char strSize[strSizeTmp.length()+1];
    strcpy(strSize, strSizeTmp.c_str());

    // Create socket
    memset(&serv_addr, 0, sizeof(serv_addr)); 
    serv_addr.sin_family = AF_INET; 
    serv_addr.sin_port = htons(PORT); 
    serv_addr.sin_addr.s_addr = inet_addr("127.0.0.1");

    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) < 0) 
    { 
        printf("\n Socket creation error \n"); 
        return -1; 
    } 

    //Send image size and image data
    sendto(sock, (const char *)strSize, 16, 
        MSG_CONFIRM, (const struct sockaddr *) &serv_addr,  
            sizeof(serv_addr));
    sendto(sock, (const char *)data, strLength, 
        MSG_CONFIRM, (const struct sockaddr *) &serv_addr,  
            sizeof(serv_addr));

    //////////////////////////////////////////////////////////

    //Wait for respond
    char bufferTmp[16] ; 
    cout << "Wait" << endl;
    recvfrom(sock, (char *)bufferTmp, 16,  
                MSG_WAITALL, (struct sockaddr *) NULL, 
                NULL);
    // The program just nerver reach here
    cout << bufferTmp << endl;


    close(sock);

    waitKey(3000);
}

有一件事我注意到 c++ recvfrom 不需要 ip 和端口，它怎么知道要监听哪个端口？

Answer 1

问题 #1 是您的 C++ 客户端从不将其套接字绑定(bind)到端口。 如果没有将套接字绑定(bind)到端口，套接字将永远不会接收任何 UDP 数据包，因为(如您所说)它如何知道应该在哪个端口上接收数据包？。没有显式调用 bind()，客户端第一次调用 sendto() 会自动将客户端的 UDP 套接字绑定(bind)到可用的 UDP 端口，这在这种情况下就足够了. (recvfrom() 的额外参数是为了告诉您传入数据包是从远程机器上的何处发送，而不是它到达本地机器的何处机)。

问题 #2 是您似乎打算为客户端和服务器使用单个端口号 (5001)。你最好让你的客户端绑定(bind)到不同的端口号(理想情况下绑定(bind)到操作系统在运行时为你选择的任意端口号，如果你希望能够在一台机器上同时支持多个客户端 - 你可以通过将 0 作为端口号传递给 bind() 来实现。

那么当你的服务器调用recvfrom()并收到一个UDP数据包时，recvfrom()返回的IP地址和端口号就是服务器可以传回的值sendto() 当它想要将一个回复数据包发送回将传入的 UDP 数据包发送到服务器的同一客户端时。