Попробуйте отправить данные из C ++ в Python и обратить их, используя сокеты C ++, C ++ sendto () и python recvfrom (), работающие, но не обращенные

Question

TLDR; Я пытаюсь отправить данные из программы C ++ в Python программу и в обратном порядке, мне удалось отправить данные из C ++ и получить в python, но не отправлять из python в C ++

Хорошо, прежде чем идти в код , я объясню, что я пытаюсь сделать (надеюсь, это облегчит понимание моего кода): я хотел создать сервер, который будет прослушивать и читать изображение из клиента C ++ и возвращать другое изображение

(сторона сервера - Python) Сначала я создал сокет и связал его с localhost на порту 5001

(Client Side-C ++). Я создал сокет, прочитал изображение (здесь я использую OpenCV), сначала отправил размер изображения, а затем отправил само изображение и дождитесь ответа сервера

(сторона сервера - Python). Считайте размер и прочитайте изображение, используя полученный размер.

- На этом этапе все работает как положено -

(на стороне сервера- Python). Сервер читает и передает изображение и отправляет его обратно

(на стороне клиента-C ++). Клиент завис, поскольку ничего не получает?

Это заняло у меня 4 часа без lt :( это мой код:

Сервер 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 ++ никогда не привязывает свой сокет к порту. Без сокета, связанного с портом, сокет никогда не будет принимать никаких пакетов UDP, потому что (как вы говорите) как бы он узнал, на какой порт (порт) он должен принимать пакеты? . Без явного вызова bind() первый клиентский вызов sendto() автоматически свяжет сокет UDP вашего клиента с доступным портом UDP, что достаточно в этом случае. (Дополнительные аргументы для recvfrom() предназначены для указания , откуда поступил входящий пакет на удаленной машине , а не , куда он поступил на локальной машине ).

Проблема № 2 в том, что вы, похоже, намереваетесь использовать один номер порта (5001) для клиента и сервера. Было бы лучше, если бы ваш клиент привязывался к другому номеру порта (в идеале к произвольному номеру порта, который ОС выбирает для вас во время выполнения, если вы хотите иметь возможность поддерживать несколько клиентов одновременно на одном компьютере - вы можно сделать это, передав 0 в качестве номера порта bind()).

Затем, когда ваш сервер вызывает recvfrom() и получает пакет UDP, IP-адрес и номер порта, возвращаемые recvfrom(), представляют собой значения, которые сервер может передать обратно sendto(), когда он хочет отправить обратно ответный пакет тому же клиенту, который отправил входящий UDP-пакет на сервер.