Потеря пакетов при передаче клиент->сервер - 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 огромнейшее спасибо!

Новые блоги и статьи Все статьи Все блоги /
Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Programma_Boinc 26.12.2025 Нашел на реддите интересную статью под названием Anyone know where to get a free Desktop or Laptop? Ниже её машинный перевод. После долгих разбирательств я наконец-то вернула себе. . .	Thinkpad X220 Tablet — это лучший бюджетный ноутбук для учёбы, точка. Programma_Boinc 23.12.2025 Рецензия / Мнение/ Перевод Нашел на реддите интересную статью под названием The Thinkpad X220 Tablet is the best budget school laptop period . Ниже её машинный перевод. Thinkpad X220 Tablet —. . .	PhpStorm 2025.3: WSL Terminal всегда стартует в ~ and_y87 14.12.2025 PhpStorm 2025. 3: WSL Terminal всегда стартует в ~ (home), игнорируя директорию проекта Симптом: После обновления до PhpStorm 2025. 3 встроенный терминал WSL открывается в домашней директории. . .	Как объединить две одинаковые БД Access с разными данными VikBal 11.12.2025 Помогите пожалуйста !! Как объединить 2 одинаковые БД Access с разными данными.	Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro
Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .	От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .	Поиск "дружественных имён" СОМ портов Argus19 22.11.2025 Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .	Сколько Государство потратило денег на меня, обеспечивая инсулином. Programma_Boinc 20.11.2025 Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .	Ломающие изменения в C#.NStar Alpha Etyuhibosecyu 20.11.2025 Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .

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

Решение

Решение

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