Потеря пакетов при передаче клиент->сервер - Boost C++

@Mastering · Регистрация: 20.04.2018

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

Написал простенькую реализацию сервера и клиента.
Клиент:

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
#include "stdafx.h"
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
 
int main()
{
        boost::asio::io_service io_service;
        boost::asio::ip::tcp::socket socket(io_service);
        boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address::from_string("127.0.0.1"), 8002);
        socket.connect(ep);
        boost::asio::streambuf request;
        std::ostream stream(&request);
        std::string mail;
 
        std::ifstream file("2photo.jpg", std::ios::binary);
        std::vector<unsigned char> buffer((std::istreambuf_iterator<char>(file)), (std::istreambuf_iterator<char>()));
        std::cout << buffer.size();
        for (int i = 0; i < buffer.size(); i++)
        {
            stream << buffer[i];
        }
        boost::asio::write(socket, request);
 
        boost::system::error_code ec;
        boost::asio::read(socket, request, boost::asio::transfer_at_least(1), ec);
        std::cout << &request << std::endl;
    system("pause");
    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
#include "stdafx.h"
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
 
int main()
{
    boost::asio::io_service io_service;
    boost::asio::ip::tcp::acceptor acceptor(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 8002));
    boost::asio::streambuf buf;
    while (true)
    {
        boost::asio::ip::tcp::socket socket(io_service);
        acceptor.accept(socket);
        boost::system::error_code ec;
        std::ofstream file;
        file.open("photo.jpg", std::ios::binary);
        while (boost::asio::read(socket, buf, boost::asio::transfer_at_least(1), ec))
        {
            file << &buf;
        }
        std::string mail = { "OK" };
        socket.write_some(boost::asio::buffer(mail));
        socket.close();
    }
    return 0;
}

Картинка почти успешно передается на сервер. Почти, т.к. после передачи последние пиксели битые.
Скрин как это выглядит: https://drive.google.com/open?... 6zuag8Ehuf
И файл получается чуть больше или меньше чем исходный, в следствии чего тут происходит зацикливание

C++
1
while (boost::asio::read(socket, buf, boost::asio::transfer_at_least(1), ec))

На сколько я понимаю потому что сервер ждет конкретное значение байт, ни более и не менее.

Подскажите пожалуйста почему происходит такая жесть?)

PS Если передаю картинку размером 4Кб то она тупо не передается, если размером 30Кб, то передается примерно на 2/3, при размере 2Мб это последние пиксели (тут разница в 353 бита).

@igorrr37 · 11.06.2018, 20:05

у меня вот так работает:

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
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
#include <cstdlib>
 
int main()
{
    std::cout << "server" << std::endl;
    boost::asio::io_service io_service;
    boost::asio::ip::tcp::acceptor acceptor(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 8002));
    boost::asio::streambuf buf;
    boost::asio::ip::tcp::socket socket(io_service);
    acceptor.accept(socket);
    boost::system::error_code ec = boost::system::errc::make_error_code(boost::system::errc::success);
    std::ofstream ofs("out.jpg", std::ios::binary);
    int totalTransferred = 0;
    while (ec == boost::system::errc::success)
    {
        totalTransferred += boost::asio::read(socket, buf, boost::asio::transfer_at_least(1), ec);
        ofs << &buf;
    }
    std::cout << "totalTransferred: " << totalTransferred << std::endl;
    socket.close();
    ofs.close();
    system("pause");
}

Добавлено через 18 секунд

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
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
#include <cstdlib>
#include <vector>
 
 
int main()
{
    try
    {
        std::cout << "client" << std::endl;
        system("chcp 1251");
        boost::asio::io_service io_service;
        boost::asio::ip::tcp::socket socket(io_service);
        boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address::from_string("127.0.0.1"), 8002);
        socket.connect(ep);
        boost::asio::streambuf request;
        std::ostream stream(&request);
        std::string mail;
 
        std::ifstream ifs("in.jpg", std::ios::binary);
        if (!ifs.is_open())
        {
            throw std::runtime_error{ "Unable to open input file\n" };
        }
        std::vector<char> vct((std::istreambuf_iterator<char>(ifs.rdbuf())), (std::istreambuf_iterator<char>()));
        std::cout << "vct.size(): " << vct.size() << std::endl;
        stream.write(vct.data(), vct.size());
        int wc = boost::asio::write(socket, request);
        std::cout << "write count: " << wc << std::endl;
    }
    catch (std::exception const& exc)
    {
        std::cerr << exc.what() << std::endl;
    }
    system("pause");
}

@Mastering · 12.06.2018, 21:30 **[ТС]**

igorrr37 большое спасибо, но наткнулся на проблему, если у клиента убрать try и catch, или добавить ожидание ответа сервера то все равно происходит зависание на:

C++
1
totalTransferred += boost::asio::read(socket, buf, boost::asio::transfer_at_least(1), ec);

@igorrr37 · 13.06.2018, 10:28

добавил возможность подключения множества клиентов и ответ от сервера клиентам

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
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
#include <cstdlib>
 
int main()
{
    std::cout << "server" << std::endl;
    system("chcp 1251");
    boost::asio::io_service io_service;
    boost::asio::ip::tcp::acceptor acceptor(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 8002));
    boost::asio::streambuf buf;
    try
    {
        while (true)
        {
            boost::asio::ip::tcp::socket socket(io_service);
            acceptor.accept(socket);
            std::cout << "\naccept() succeeded" << std::endl;
            boost::system::error_code ec = boost::system::errc::make_error_code(boost::system::errc::success);
            std::ofstream ofs("out.jpg", std::ios::binary);
            int totalRead = 0;
            while (true)
            {
                int curRead = boost::asio::read(socket, buf, boost::asio::transfer_at_least(1), ec);
                if (ec != boost::system::errc::success)
                {
                    break;
                }
                //std::cout << "curRead: " << curRead << std::endl;
                //std::cout << "ec.message(): " << ec.message() << std::endl;
                totalRead += curRead;
                ofs << &buf;
            }
            std::cout << "totalRead: " << totalRead << std::endl;
            std::string mail = { "OK" };
            int curWrite = 0;
            do
            {
                curWrite += socket.write_some(boost::asio::buffer(mail));
            } while (curWrite != mail.size());
 
            socket.close();
            ofs.close();
        }
    }
    catch (std::exception const& exc)
    {
        std::cerr << "Exception: " << exc.what() << std::endl;
    }
    acceptor.close();
    system("pause");
}

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
#include <boost/asio.hpp>
#include <iostream>
#include <fstream>
#include <cstdlib>
#include <vector>
 
 
int main()
{
    try
    {
        std::cout << "client" << std::endl;
        system("chcp 1251");
        boost::asio::io_service io_service;
        boost::asio::ip::tcp::socket socket(io_service);
        boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address::from_string("127.0.0.1"), 8002);
        socket.connect(ep);
        boost::asio::streambuf buf;
        std::ostream stream(&buf);
        std::string mail;
 
        std::ifstream ifs("in.jpg", std::ios::binary);
        if (!ifs.is_open())
        {
            throw std::runtime_error{ "Unable to open input file\n" };
        }
        std::vector<char> vct((std::istreambuf_iterator<char>(ifs.rdbuf())), (std::istreambuf_iterator<char>()));
        std::cout << "vct.size(): " << vct.size() << std::endl;
        stream.write(vct.data(), vct.size());
        int totalWrite = boost::asio::write(socket, buf);
        std::cout << "totalWrite: " << totalWrite << std::endl;
 
        socket.shutdown(boost::asio::socket_base::shutdown_send);
        int totalRead = 0;
        boost::system::error_code ec = boost::system::errc::make_error_code(boost::system::errc::success);
        while (true)
        {
            totalRead += boost::asio::read(socket, buf, boost::asio::transfer_at_least(1), ec);
            if (ec != boost::system::errc::success)
            {
                break;
            }
 
        }
        //std::cout << "totalRead: " << totalRead << std::endl;
        std::cout << "server sent: " << &buf << std::endl;
 
 
        ifs.close();
        socket.close();
    }
    catch (std::exception const& exc)
    {
        std::cerr << "Exception: " << exc.what() << std::endl;
    }
    system("pause");
}

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

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

все равно происходит зависание на

Чтобы не было зависания клиент должен дать понять серверу что читать из сокета больше не нужно вот такой строкой

C++
1
socket.shutdown(boost::asio::socket_base::shutdown_send);

Но после шатдауна клиент больше не сможет ничего писать в сокет.

@Mastering · 13.06.2018, 18:59 **[ТС]**

igorrr37 огромнейшее спасибо!

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .	Конвертировать закладки radiotray-ng в m3u-плейлист damix 19.02.2026 Это можно сделать скриптом для PowerShell. Использование . \СonvertRadiotrayToM3U. ps1 <path_to_bookmarks. json> Рядом с файлом bookmarks. json появится файл bookmarks. m3u с результатом. # Check if. . .	Семь CDC на одном интерфейсе: 5 U[S]ARTов, 1 CAN и 1 SSI Eddy_Em 18.02.2026 Постепенно допиливаю свою "многоинтерфейсную плату". Выглядит вот так: https:/ / www. cyberforum. ru/ blog_attachment. php?attachmentid=11617&stc=1&d=1771445347 Основана на STM32F303RBT6. На борту пять. . .	Камера Toupcam IUA500KMA Eddy_Em 12.02.2026 Т. к. у всяких "хикроботов" слишком уж мелкий пиксель, для подсмотра в ESPriF они вообще плохо годятся: уже 14 величину можно рассмотреть еле-еле лишь на экспозициях под 3 секунды (а то и больше),. . .
И ясному Солнцу zbw 12.02.2026 И ясному Солнцу, и светлой Луне. В мире покоя нет и люди не могут жить в тишине. А жить им немного лет.	«Знание-Сила» zbw 12.02.2026 «Знание-Сила» «Время-Деньги» «Деньги -Пуля»	SDL3 для Web (WebAssembly): Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 12.02.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами и вызывать обработчики событий столкновения. . . .	SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 11.02.2026 Содержание блога Библиотека SDL3 содержит встроенные инструменты для базовой работы с изображениями - без использования библиотеки SDL3_image. Пошагово создадим проект для загрузки изображения. . .

Потеря пакетов при передаче клиент->сервер - Boost C++

Решение

Решение

@Mastering 1 / 1 / 0 Регистрация: 20.04.2018 Сообщений: 58
	13.06.2018, 18:59 [ТС]
	igorrr37 огромнейшее спасибо! 0