Передача видео с камеры клиенту OPENCV с++ tcp ip

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

#include <unistd.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <string>
#include <vector>
#include <opencv2/opencv.hpp>
#include <fcntl.h>
#include <opencv2/highgui/highgui.hpp>
#include <opencv2/core/core.hpp>
using namespace std;
using namespace cv;
int c,new_socket;
std::vector<uchar> buffer;
std::vector<uchar> arrak;
int i=0,k=0;
int bbytee;
Mat image;
int main() {
int sock,listener;
std::vector<uchar> buf;
std::vector<int> params(2);
params[0] = cv::IMWRITE_PNG_COMPRESSION;
params[1] = 10;
struct sockaddr_in addr,client;
sock = socket(AF_INET, SOCK_STREAM, 0); // создание сокета
if(sock < 0) {
perror("socket");
exit(1);
}
fcntl(sock, F_SETFL, O_NONBLOCK); // установка н****кирующего режима
memset(&addr, 0, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_port = htons(3425);
addr.sin_addr.s_addr = htonl(INADDR_ANY); // подключение к любому IP-адресу
VideoCapture cap(2); // захват видеокамеры
if(!cap.isOpened()) { // проверка условий подключения
cout<< "Could not open the camera" << endl;
close(sock);
return -1;
}
if(bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) { // связывание сокетов
perror("[server] binding failed!");
exit(2);
}
Mat frame = Mat::zeros(1080, 1920, CV_8UC3); // создание матрицы изображения
int imgSize = frame.cols*frame.rows*3; // узнаем размер изображения на три канала
listen(sock, 1); // прослушивание подключений
c = sizeof(struct sockaddr_in); // размер структуры
while (true) {
puts("Waiting for incoming connections...");
new_socket = accept(sock, (struct sockaddr *)&client, (socklen_t*)&c);// прием сокета
cout << "New_socket: " << new_socket << endl;
cap >> frame;//чтение с cap в frame
imencode(".jpg", frame, buffer,params); //перекодирование в буфер buffer
if(frame.empty()) {
cerr<<"[client] VideoCapture(0) error!"<<endl;
}
cout<< ++i << ":"<< frame.isContinuous()<<"," <<frame.size()<<endl;
if(new_socket == -1) {//если подключения клиента нет, то...
puts("Connection not accepted");
cout << "new_socket = " << new_socket << "\n";
} else {//если подключился клиент, то ..
int size = buffer.size()*sizeof buffer[0];//определяем размер буфера
send(new_socket, &size, sizeof(size), 0);// передаем размер буфера клиенту
cout << "Razmer" << size << endl;
cout << "Transmission started" << endl;
sleep(5);
if(buffer.size())
{
cout <<"PEREDASHA POSHLA"<<endl;
send(new_socket,buffer.data(), buffer.size()*sizeof buffer[0], 0);//передача данных(буфера) клиенту
}
cout << "Transmission ended"<<endl;
break;
}
}
cout << "END" << endl;
close(sock); // закрытие сокета
return 0;
}

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

#include <unistd.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <string>
#include <vector>
#include <opencv2/opencv.hpp>
 
using namespace std;
using namespace cv;
 
int recv_size;
Mat frame;
std::vector<uchar> buffer;
uint32_t size = 0;
 
int main() {
    int sock;
    struct sockaddr_in addr;
 
    sock = socket(AF_INET, SOCK_STREAM, 0);// создание нового сокета
    if (sock < 0) {
        perror("socket");
        exit(1);
    }
 
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(3425);
    addr.sin_addr.s_addr = htonl(INADDR_ANY);
    addr.sin_addr.s_addr = inet_addr("192.168.3.11");// IP камеры
 
    if (connect(sock, (struct sockaddr*)&addr, sizeof(addr)) < 0) { // подключение к серверу
        perror("connect");
        exit(2);
    }
 
    if ((recv_size = recv(sock, (char*)&size, sizeof(uint32_t), 0)) != sizeof(uint32_t)) { //прием размера буфера
        perror("recv");
        exit(3);
    }
 
    cout << "SIZE FRAME: " << recv_size << endl;
    
 
    int num_of_recv_bytes;
    VideoWriter outputVideo;
    Size S = Size((int)1920, (int)1080);//размер изображения
    outputVideo.open("receive.avi", VideoWriter::fourcc('H', '2', '6', '4'), 25, S, true);//открытие файла receive.avi для записи
 
    int imgSize = 1920 * 1080 * 3;
    buffer.resize(recv_size);//изменение буфера клиента под размер буфера сервера
    recv(sock, buffer.data(), recv_size, 0);//прием буфера с камеры
    cout << "IDET DO IMDECODE " << recv_size << endl;
 
    frame = imdecode(buffer, IMREAD_COLOR);//конвертирование данных в формат Mat
    outputVideo << frame;//запись буфера в файл receive.avi с указанными параметрами
    close(sock);
    outputVideo.release();//освобождение outputVideo
 
    return 0;
}