Linux. Передача объектов через сокеты. Как?

@Q-gecHuK · Регистрация: 30.03.2012

Студворк — интернет-сервис помощи студентам

День добрый, господа! Мое первое сообщение на форуме, прошу любить и жаловать)

Написал небольшой сервер и клиент, клиент отправляет строку, сервер получает и отсылает обратно. Ну в общем классический пример для таких новичков как я

Все отлично работает, все счастливы...
Решил усложнить задачу и отправлять объект IplImage из openCV.
IplImage* image = 0;
А теперь, собственно, вопрос к знатокам, как это сделать?
Вроде как нужна сериализация?
Пожалуйста, подправьте мой код для передачи строк, чтобы я понял, как правильно передавать объект!

Собственно, сервер:

C++
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <netdb.h>
#include <stdio.h>
#include <strings.h>
#include <stdlib.h>
#include <unistd.h>
 
// Порт сервера
#define PORTUM 1500
 
int main()
{
    int s;      // Идентификатор основного сокета
    int ns;     // Идентификатор дочернего сокета
    int pid;    // ID процесса
    int nport;  // Номер порта
    struct sockaddr_in serv_addr;
    struct sockaddr_in clnt_addr;
    char buf[80];
    char hname[80];
    /* Преобразуем порядок следования байтов к сетевому формату*/
    nport = PORTUM;
    nport = htons((u_short)nport);
    /* Создаем сокет TCP*/
    if ((s = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
        perror("Ошибка вызова socket()\n"); 
        return -1;
    }else {
        printf ("Сокет с идентификатором %i успешно создан.\n", s);
    }
    /*Задаем адрес коммуникационного узла*/
    bzero(&serv_addr, sizeof(serv_addr));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = INADDR_ANY;
    serv_addr.sin_port = nport;
    /*Свяжем сокет с этим адресом*/
    if (bind(s, (struct sockaddr *)&serv_addr, 
        sizeof(serv_addr)) == -1) {
        perror("Ошибка вызова bind()\n"); 
        return -1;
    }else {
        printf ("bind() успешно отработал.\n");
    }
 
    /*Сообщение с указанием адреса сервера*/
    fprintf(stderr, "Сервер готов: %s\n", inet_ntoa(serv_addr.sin_addr));
 
    /*Начинаем слушать с очередью до 5ти запросов*/
    if (listen(s, 5) == -1) {
        perror("Ошибка вызова listen()\n"); 
        return -1;
    }else {
        printf ("listen() успешно запущен, слушаем...\n");
    }
 
    /*Бесконечный цикл получения и обработки запросов*/
    while(1)
    {
        socklen_t addrlen; 
        bzero(&clnt_addr, sizeof(clnt_addr));
        addrlen = sizeof(clnt_addr);
        /*Принимаем входящий запрос*/
        if ((ns = accept(s, (struct sockaddr *)&clnt_addr,
            &addrlen)) == -1) {
            perror("Ошибка вызова accept()\n"); 
            return -1;
        }else {
            printf ("Запрос на connet принят. Обработка...\n");
        }
        /*Информация о клиенте*/
        fprintf(stderr, "Клиент = %s\n", inet_ntoa(clnt_addr.sin_addr));
        
        /*Создаем процесс для работы с клиентом*/
        if ((pid = fork()) == -1) {
            perror("Ошибка вызова fork()\n"); 
            return -1;
        } else {
            printf ("Процесс для обработки успешно создан.\n");
        }
        if (pid == 0) {
            int nbytes;
            int fout;
            /*Мы в дочернем процессе, закрываем родительский сокет*/
            close(s);
            /*Получаем сообщение и передаем его обратно*/
            while ((nbytes = recv(ns, buf, sizeof(buf), 0)) != 0)
            {
                printf("Получено сообщение: %s,\nпосылаем обратно...\n", buf);
                send(ns, buf, sizeof(buf), 0);
            }
            close(ns);
            printf("Обработка закончена, дочерний процесс закрываем.\n");
            exit(0);
        }
        /*Мы в родительском процессе, сокет ns не нужен*/
        close(ns);
    }
    return 0;
}

Клиент:

C++
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
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <netdb.h>
#include <stdio.h>
#include <strings.h>
#include <stdlib.h>
#include <unistd.h>
 
// Порт сервера
#define PORTUM 1500
 
int main(int argc, char* argv[])
{
    int s;      // Идентификатор основного сокета
    int pid;    // ID процесса
 
    struct sockaddr_in serv_addr;
 
    struct hostent *hp;
    char buf[80] = "Как много нам открытий чудных...";
    
    /*Обрабатываем доменное имя хоста, полученное в качестве аргумента*/
    if ((hp = gethostbyname(argv[1])) == 0) {
        perror("Ошибка вызова gethostbyname()\n"); 
        return -1;
    }
 
    bzero(&serv_addr, sizeof(serv_addr));
    serv_addr.sin_family = hp->h_addrtype;
    bcopy(hp->h_addr, &serv_addr.sin_addr, hp->h_length);
    serv_addr.sin_port = htons(PORTUM);
 
    /* Создаем сокет TCP*/
    if ((s = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
        perror("Ошибка вызова socket()\n"); 
        return -1;
    }else {
        printf ("Сокет с идентификатором %i успешно создан.\n", s);
    }
 
    /*Сообщение с указанием адреса сервера*/
    fprintf(stderr, "Адрес сервера: %s\n", inet_ntoa(serv_addr.sin_addr));
 
    /*Создаем канал*/
    if (connect(s, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) == -1) {
        perror("Ошибка вызова connect()\n"); 
        return -1;
    }else {
        printf ("Соединение с сервером открыто, передача сообщения...\n", s);
    }   
 
    /*Отправим серверу сообщение*/
    send(s, buf, sizeof(buf), 0);
    if(recv(s, buf, sizeof(buf), 0) < 0) {
        perror("Ошибка вызова recv()\n"); 
        return -1;
    }else {
        printf("Получено сообщение от сервера: %s\n", buf);
    }
 
    close(s);
    printf("Клиент завершил работу");
 
    return 0;
}

@Dmitriy_M · 23.11.2014, 14:48

буфер с JPEG/PNG. О форматах и параметрах imwrite

@Avazart · 23.11.2014, 15:37

Сообщение от Dmitriy_M

буфер с JPEG/PNG.

Ну так в каком виде, как я понял там сырые данные без заголовков итп, и вообще в неведомом формате.

@Dmitriy_M · 23.11.2014, 16:49

Сообщение от Avazart

Ну так в каком виде, как я понял там сырые данные без заголовков итп, и вообще в неведомом формате.

Формат и вид JPEG'а известен. Получаешь то же, что при обычном чтения JPEG файла в буфер.

@Avazart · 23.11.2014, 17:11

Сообщение от Dmitriy_M

Формат и вид JPEG'а известен. Получаешь то же, что при обычном чтения JPEG файла в буфер.

Тогда значит я что-то не так делаю.

Добавлено через 10 минут

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
#include <fstream>
 
IplImage* img = cvLoadImage("1.jpg", CV_LOAD_IMAGE_UNCHANGED);
CvMat* mat = cvEncodeImage(".jpg", img);
 
if(mat)
{
    std::ofstream ofs("2.jpg",std::ios::binary);
    if(ofs)
    {
      ofs.write(mat->data.ptr,mat->width* mat->height);
      ofs.close();
    }
}
 
cvReleaseImage(&img);

Да действительно работает, ошибка видимо в другой части кода была.

@Dmitriy_M · 23.11.2014, 17:31

для кого придумали API на C++?

C++
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
#include <vector>
#include <fstream>
 
#include <boost/lexical_cast.hpp>
 
#include "opencv2/opencv.hpp"
 
using namespace cv;
 
int main(int, char**)
{
    VideoCapture cap(0); // open the default camera
    if(!cap.isOpened())  // check if we succeeded
        return -1;
 
    Mat edges;
    namedWindow("edges",1);
    std::vector<unsigned char> buff;
    buff.reserve(1024*1024*4); //4 mb
    
    int i = 0;
    for(;;)
    {
        Mat frame;
        cap >> frame; // get a new frame from camera
        if(imencode(".jpeg", frame, buff))
        {
            ++i;
            std::string name = "img"+boost::lexical_cast<std::string>(i)+".jpeg";
            std::cout<<"write"<<" "<< name <<std::endl;
            std::ofstream ofs (name.c_str(), std::ios::binary);
            ofs.write(reinterpret_cast<char*>(&buff[0]), buff.size());
            ofs.close();
 
        }
        imshow("edges", frame);
        if(waitKey(30) >= 0) break;
    }
    // the camera will be deinitialized automatically in VideoCapture destructor
    return 0;
}

@Avazart · 23.11.2014, 17:35

Не по теме:

Сообщение от Dmitriy_M

для кого придумали API на C++?

В C++Builder плюсовый интерфейс не работает (не компилиться c плюсовыми *.hpp)
По этому пробую пока так, если нет то уже в Qt перейду и там уже на ++

Да и забыл в коде:

C++
1
cvReleaseMat(&mat);

Новые блоги и статьи Все статьи Все блоги /
Hyper-V: Компьютер должен поддерживать доверенный платформенный модуль 2.0. Maks 31.08.2026 При установке Windows 11 на виртуальную машину Hyper-V 2-го поколения вылезла такая ошибка: Решение: в параметрах виртуальной машины, в разделе "Безопасность" (Security) активировать флаг. . .	Архитектура биовида Стива в Майнкрафте: Зачем бонобо кубический каннибализм anaschu 30.08.2026 Кубический Вагинокапитализм в Minecraft: Математический инвариант ОДУ и рок Стивов-бонобо Главная задача разработанной «Модели Всего» — наглядно продемонстрировать наличие системной «судьбы». . .	Оттачиваю умение писать js программы. russiannick 30.08.2026 Проектом выходного дня стало написание Книги шифров Виженера. Итогом стала версия 200, синий туман. Синий туман назван так, потому что замораживает текст под собой. Нажатие синих кнопок управляют. . .	мат медиц модель 30. презентация проекта anaschu 27.08.2026 хоп хоп хоп хидахоп, а я кладую))
Как у меня протекала болезнь zorxor 27.08.2026 Здравствуйте, друзья! Эта запись блога предназначена именно для вас - для моих дорогих друзей, которые знали меня лично. Чтобы ответить на вопрос - а что же со мной произошло на самом деле? Я учился. . .	Нашел вот забавное видео о измерениях. Лучшее что я видел на эту тему kumehtar 26.08.2026 ILETXiw9bMQ Основная суть и тезисы по измерениям: 0D (Нулевое измерение): точка, не имеющая длины, ширины, высоты или объема. Объект не может перемещаться в 0D. 1D (Первое измерение):. . .	[EasyBuilder Pro] Памятка по разработке для панелей Weintek ФедосеевПавел 26.08.2026 Памятка по разработке для панелей Weintek ВВЕДЕНИЕ Ранее, при реализации проектов основное внимание уделял разработке управляющей программы для контроллера, а панели оператора доставалось время. . .	Модель по догадкам anaschu 25.08.2026 Прошло две недели. Я уже рассказывал, как разговаривал с сотрудниками у сортировки и как понял, что главная ветка — не про приёмку, а про отбор. Но тогда я думал, что понял механику. На этой неделе я. . .

@Dmitriy_M 1443 / 1326 / 131 Регистрация: 20.03.2009 Сообщений: 4,689 Записей в блоге: 11
	23.11.2014, 14:48
	буфер с JPEG/PNG. О форматах и параметрах imwrite 1

Опции темы