Асинхронный сервер\клиент

@Palich · Регистрация: 07.04.2016

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

Здравствуйте.

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

Имеем:
1. Win 10 x64;
2. Boost 1.88;
3. Компилятор msys2 mingw64;

Что непонятно:
Не понимаю как создать сервер и как создать сессию. Как связывать\привязывать\перевязывать\завяз ывать\распутывать\передавать\отдавать\от нимать "io_context" и сокеты(актив и пассив). В каких-то статьях(и в неактуальном по версии библиотеки учебнике тоже) используют "acceptor.bind (...)", где-то сразу в конструкторе инициализируют, естественно без толкового описания. Добавим сюда(в "объясняющие" статьи) факт использования лямбда-функций совместно с максимально укороченным кодом в ущерб понятности, которые не делают код более простым для понимания.

Не по теме:

Когда я вижу статью "объяснятора" с лямбда-функцией, то сразу хочется попросить его переписать через обычную функцию, посмотреть, что и как он будет передавать. Если в большинстве лямбд всё ясно, то вот с boost::asio нет. Правда на момент "сейчас" уже есть понимание, я так думаю.

Что делал:
1. То же, что тут(Boost::asio - ошибка использования сокета) и где-то еще задавал вопросы, связанные с этой темой;
2. Оставил код, который хотя бы компилируется но сама прога не рабочая. Код прикреплю ниже.

Какая нужна помощь:
Наверное, это нагло будет, но всё же:
Нужен готовый код в котором:
1. используется boost c++(укажите версию, т.к. чать методов и переменных не актуальны от версии к версии);
2. для windows;
3. лямбды заменены на "std::bind ()"(потому, что мне проще понять через такой способ);
4. без "сложных" сжатооднострочных выражений, в которых создаётся объек, сразу вызывается метод с передачей и это всё применяется в каком-нибудь "std::move" для какого-то другого объекта, который есть "общий" указатель в векторе, который входит в матрицу указателей и т.д.;
5. Отдельно класс "сервер" и класс "сессия", допустим, сейчас у меня один клиент, а потом может быть 100500+;
6. В общем максимально просто для такого как я: тупенького начинающего.

Код:

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
#include <iostream>
#include <memory> // Для std::shared_ptr
#include <boost/asio.hpp>
#include <boost/system/error_code.hpp>
 
#include <thread>
 
 
class Session {
    public:
 
    public:
        Session () {}
 
    public:
};
 
 
 
 
 
 
class Server {
    public:
        boost::asio::ip::tcp::endpoint m_endpoint;
        boost::asio::io_context m_ioContext;
        boost::asio::ip::tcp::acceptor m_acceptor;
 
    public:
        Server (boost::asio::ip::address_v4 aIpAddressV4, unsigned short aPort)
                : m_endpoint (aIpAddressV4, aPort),
                    m_acceptor (m_ioContext, m_endpoint.protocol() ) {
        }
 
        ~Server () {
/* Был необходим для понимания когда и в каких
случаюях этот объект успевал "умереть" пока
выполнялись асинхронные операции. */
std::cout << "thread [" << std::this_thread::get_id() << "]:: ";
std::cout << "~Server" << std::endl;
        }
 
    public:
        void processTheConnection (std::shared_ptr <Server> aSharedPtrToServer,
                                    const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
                // ...
            }
            else {
                // ...
            }
 
            // Продолжаем принимать новые запросы на соединение.
            this->startAccept ();
        }
 
 
 
 
        void startAccept() {
            m_acceptor.listen();
 
            std::shared_ptr <Server> sharedPtrToThisObject (this); // Нужен для продления "жизни" этого объекта.
            boost::system::error_code errorCode1;
            auto bindedProcessTheConnection = std::bind (&Server::processTheConnection, this,
                                            sharedPtrToThisObject,
                                            errorCode1);
 
            m_acceptor.async_accept (/* так и не определился что сюда передавать, ведь есть 8 вариантов перегрузок */);
 
            m_ioContext.run();
        }
};
 
 
 
 
 
 
 
int main() {
    SetConsoleCP (1251);
    SetConsoleOutputCP (1251);
 
    boost::asio::ip::address_v4 ipAddressV4;
    unsigned short port = 3333;
 
    try {
        Server Server1 (ipAddressV4, port);
        Server1.startAccept ();
    }
    catch (std::exception& e) {
std::cerr << "main:: Исключение: " << e.what() << std::endl;
    }
 
 
    system ("pause");
    return 0;
}

@andrey_f · 01.07.2025, 12:24

пример попроще

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
#include <iostream>
#include <memory>
#include <boost/asio.hpp>
#include <thread>
 
using boost::asio::ip::tcp;
 
// Класс сессии — управляет одним соединением
class Session : public std::enable_shared_from_this<Session> {
public:
    explicit Session(tcp::socket socket)
        : socket_(std::move(socket)) {}
 
    void start() {
        do_read();
    }
 
private:
    tcp::socket socket_;
    enum { max_length = 1024 };
    char data_[max_length];
 
    void do_read() {
        auto self(shared_from_this());
        socket_.async_read_some(
            boost::asio::buffer(data_, max_length),
            [this, self](boost::system::error_code ec, std::size_t length) {
                if (!ec) {
                    // Просто выводим полученные данные
                    std::cout << "Received: " << std::string(data_, length) << std::endl;
                    do_read(); // читаем дальше
                }
            });
    }
};
 
// Класс сервера — принимает соединения
class Server {
public:
    Server(boost::asio::io_context& io_context, const tcp::endpoint& endpoint)
        : acceptor_(io_context, endpoint) {
        start_accept();
    }
 
private:
    tcp::acceptor acceptor_;
 
    void start_accept() {
        // Создаём сокет для нового клиента
        auto socket = std::make_shared<tcp::socket>(acceptor_.get_executor().context());
 
        // Передаём обработчик через std::bind
        acceptor_.async_accept(
            *socket,
            std::bind(&Server::handle_accept, this,
                      socket,
                      std::placeholders::_1));
    }
 
    void handle_accept(std::shared_ptr<tcp::socket> socket,
                       const boost::system::error_code& ec) {
        if (!ec) {
            // Создаём новую сессию для клиента
            auto session = std::make_shared<Session>(std::move(*socket));
            session->start();
        }
        // Ждём следующего клиента
        start_accept();
    }
};
 
int main() {
    try {
        boost::asio::io_context io_context;
 
        // Указываем IP и порт (например 127.0.0.1:3333)
        tcp::endpoint endpoint(boost::asio::ip::make_address("127.0.0.1"), 3333);
 
        Server server(io_context, endpoint);
 
        // Запускаем цикл обработки событий
        io_context.run();
    } catch (std::exception& e) {
        std::cerr << "Exception: " << e.what() << "\n";
    }
 
    return 0;
}

@Palich · 10.07.2025, 22: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
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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
class Session : public std::enable_shared_from_this <Session> {
    public:
        boost::asio::ip::tcp::socket m_socket;
        unsigned int m_sizeMessages = 1024;
        char m_cString [1024];
 
    public:
        explicit Session (boost::asio::ip::tcp::socket aSocket)
                    : m_socket (std::move (aSocket) ) {}
 
        ~Session () {
            std::cout << "~Session" << std::endl;
        }
 
    public:
        void processTheClientMessage (std::shared_ptr <Session> aSharedPtrToSession,
                                    Session* aSessionObject,
                                    const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
                // ...
            }
            else {
                std::cout << "client message = " << std::string(m_cString, m_sizeMessages) << std::endl;
            }
 
            this->readFromSocket();
        }
 
        void readFromSocket () {
            std::shared_ptr <Session> sharedPtrToThisObject (this);
            boost::system::error_code errorCode1;
            auto bindedProcessTheClientMessage = std::bind (&Session::processTheClientMessage,
                                            this,
                                            sharedPtrToThisObject,
                                            this,
                                            errorCode1);
 
            m_socket.async_read_some (boost::asio::buffer (m_cString, m_sizeMessages),
                                                    bindedProcessTheClientMessage);
        }
};
 
 
 
 
 
 
class Server {
    public:
        boost::asio::ip::tcp::endpoint m_endpoint;
        boost::asio::ip::tcp::acceptor m_acceptor;
        std::vector <Session*> m_Sessions;
        int m_sessionCounter;
 
    public:
        Server (boost::asio::io_context& aIoContext,
                    boost::asio::ip::address_v4 aIpAddressV4,
                    unsigned short aPort)
                : m_endpoint (aIpAddressV4, aPort),
                m_acceptor (aIoContext, m_endpoint) {
            // ...
            m_sessionCounter = 0;
        }
 
        ~Server () {
            std::cout << "~Server" << std::endl;
        }
 
    public:
        void processTheConnection (std::shared_ptr <Server> aSharedPtrToServer,
                                    std::shared_ptr <boost::asio::ip::tcp::socket> aSharedPtrSocket,
                                    const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
                // ...
            }
            else {
                m_Sessions.push_back (new Session (std::move (*aSharedPtrSocket)) );
                m_Sessions [m_sessionCounter] ->readFromSocket();
                ++m_sessionCounter;
            }
 
            this->startAccept ();
        }
 
 
 
 
        void startAccept() {
            std::shared_ptr <boost::asio::ip::tcp::socket> sharedPtrSocket1 (new boost::asio::ip::tcp::socket (m_acceptor.get_executor()) ); // Видимо, возвращает "io_context".
            std::shared_ptr <Server> sharedPtrToThisObject (this);
            boost::system::error_code errorCode1;
            auto bindedProcessTheConnection = std::bind (&Server::processTheConnection, this,
                                            sharedPtrToThisObject,
                                            sharedPtrSocket1,
                                            errorCode1);
 
            m_acceptor.async_accept (*sharedPtrSocket1, bindedProcessTheConnection);
        }
};
 
 
 
 
 
 
 
int main() {
    boost::asio::ip::address_v4 ipAddressV4;
    unsigned short port = 3333;
 
        try {
            boost::asio::io_context ioContext1;
 
            Server Server1 (ioContext1, ipAddressV4, port);
            Server1.startAccept (); // Начать принимать новые соединения.
 
            ioContext1.run();
        }
        catch (std::exception& e) {
std::cerr << "Exception: " << e.what() << std::endl;
        }
 
    system ("pause");
    return 0;
}

@SmallEvil · 11.07.2025, 03:26

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

std::shared_ptr <Session> sharedPtrToThisObject (this);

Как минимум ошибка тут.

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

std::enable_shared_from_this

Призван именно для корректного создания shared_ptr from this.
Посредством вызова shared_from_this()

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

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

std::vector <Session*> m_Sessions;

Плюс, почему вектор указателей а не shared_ptr ???
Зачем тогда были нужны все эти манипуляции с std::enable_shared_from_this ?

@Palich · 11.07.2025, 18:48 **[ТС]**

Исправил по твоим комментариям, всё равно не работает )

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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
#include <iostream>
#include <string>
#include <vector>
#include <memory> // Для std::shared_ptr
#include <array> // Для std::array
#include <boost/asio.hpp>
#include <boost/system/error_code.hpp>
 
#include <thread>
 
 
class Session : public std::enable_shared_from_this <Session> {
    public:
        boost::asio::ip::tcp::socket m_socket;
        unsigned int m_sizeMessages = 1024;
        char m_cString [1024];
 
    public:
        explicit Session (boost::asio::ip::tcp::socket aSocket)
                    : m_socket (std::move (aSocket) ) {}
 
        ~Session () {
            std::cout << "~Session" << std::endl;
        }
 
    public:
        void processTheClientMessage (std::shared_ptr <Session> aSharedPtrToSession,
                                    Session* aSessionObject,
                                    const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
                // ...
            }
            else {
std::cout << "client message = " << std::string (m_cString, m_sizeMessages) << std::endl;
            }
 
            this->readFromSocket();
        }
 
        void readFromSocket () {
            auto self (shared_from_this());
            boost::system::error_code errorCode1;
            auto bindedProcessTheClientMessage = std::bind (&Session::processTheClientMessage,
                                            this,
                                            self,
                                            this,
                                            errorCode1);
 
            m_socket.async_read_some (boost::asio::buffer (m_cString, m_sizeMessages),
                                                    bindedProcessTheClientMessage);
        }
};
 
 
 
 
 
 
class Server {
    public:
        boost::asio::ip::tcp::endpoint m_endpoint;
        boost::asio::ip::tcp::acceptor m_acceptor;
        std::vector <std::shared_ptr <Session>> m_sharedPtrSessions;
        int m_sessionCounter;
 
    public:
        Server (boost::asio::io_context& aIoContext,
                    boost::asio::ip::address_v4 aIpAddressV4,
                    unsigned short aPort)
                : m_endpoint (aIpAddressV4, aPort),
                m_acceptor (aIoContext, m_endpoint) {
            // ...
            m_sessionCounter = 0;
        }
 
        ~Server () {
std::cout << "~Server" << std::endl;
        }
 
    public:
        void processTheConnection (std::shared_ptr <Server> aSharedPtrToServer,
                                    std::shared_ptr <boost::asio::ip::tcp::socket> aSharedPtrSocket,
                                    const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
                // ...
            }
            else {
                m_sharedPtrSessions.push_back (std::make_shared <Session> (std::move (*aSharedPtrSocket)) );
                m_sharedPtrSessions [m_sessionCounter] ->readFromSocket();
                ++m_sessionCounter;
            }
 
            this->startAccept ();
        }
 
 
 
 
        void startAccept() {
            std::shared_ptr <boost::asio::ip::tcp::socket> sharedPtrSocket1 (new boost::asio::ip::tcp::socket (m_acceptor.get_executor()) ); // Видимо, возвращает "io_context".
            std::shared_ptr <Server> sharedPtrToThisObject (this);
            boost::system::error_code errorCode1;
            auto bindedProcessTheConnection = std::bind (&Server::processTheConnection, this,
                                            sharedPtrToThisObject,
                                            sharedPtrSocket1,
                                            errorCode1);
 
            m_acceptor.async_accept (*sharedPtrSocket1, bindedProcessTheConnection);
        }
};
 
 
 
 
 
 
 
int main() {
    boost::asio::ip::address_v4 ipAddressV4;
    unsigned short port = 3333;
 
        try {
            boost::asio::io_context ioContext1;
 
            Server Server1 (ioContext1, ipAddressV4, port);
            Server1.startAccept (); // Начать принимать новые соединения.
 
            ioContext1.run();
        }
        catch (std::exception& e) {
std::cerr << "Exception: " << e.what() << std::endl;
        }
 
    system ("pause");
    return 0;
}

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

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

Плюс, почему вектор указателей а не shared_ptr ???

потому, что нет понимания изза неработающего кода выше.

Добавлено через 5 минут
прочитал не одну статью про "shared_ptr" но для полного понимания нужна практика, её у меня нет, единственное где оно потребовалось это тут, но тут код не работает.

@SmallEvil · 11.07.2025, 22:10

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

std::shared_ptr <Server> sharedPtrToThisObject (this);

Ещё тут, навскидку.

А вообще, вам бы потренироваться с умными указателями на более простых примерах.
Что бы избежать одновременных ошибок и от работы с boost-ом и стандартными умными указателями.

Добавлено через 1 минуту
Я вот почти не работал с boost.
Поэтому могу смотреть только с одной стороны.

@Palich · 18.08.2025, 12:22 **[ТС]**

в общем так и не понял как написать клиент-сервер

@SmallEvil · 18.08.2025, 13:12

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

в общем так и не понял как написать клиент-сервер

Например, походу не очень старое : boost-tcp-server-client [github]

@Palich · 19.08.2025, 10:26 **[ТС]**

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

: boost-tcp-server-client [github]

не открывается, с впн тоже не открывается, если открыть код страницы, то перейдя по ссылке(которую таковой сложно назвать) пишет "запрош. страна не существует".

по поводу предыдущих ссылок:

I. эта: https://www.codingwiththomas.c... nt-example
все те же самые вопросы:
1. почему используют лямбду функцию, а не std::bind, потому что в оф. документации указан "токен" ?
2. каким образом в методе "void do_accept()" у класса сервера в этой чудо лямбде инициализируется "socket" ?
3. в методе "void wait_for_request()" у класса сессии в чудо лямбде захватывается 2 объекта: "shared_from_this()" и непосредственно сам объект "this", тогда вопрос: зачем захватывать "this" если и так захватывается "shared_from_this()" ? для доступа к своим членам ? разве через "shared_from_this()" это нельзя сделать ?

II. была ссылка на гит:
1. вопрос такой же как и вопрос 1 выше.

@SmallEvil · 19.08.2025, 11:41

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

не открывается

Сломалось : https://github.com/alejandrofsevilla/boost-tcp-server-client

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

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

1. почему используют лямбду функцию

Может потому что это естественно? Тут я очень сильно затрудняюсь ответить, так как не понимаю вопроса.

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

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

2. каким образом в методе "void do_accept()" у класса сервера в этой чудо лямбде инициализируется "socket" ?

Нужно грызть tcp::acceptor.
Вот там использовали async_accept acceptor-а.
Идем и смотрим что это и для чего.

Ну вот вы нашли эту перегрузку.
И копаете дальше и дальше. Пока весь буст не будет понятен )

Вот пример на фнкции, как вы и хотели, на том же справке из офф. буста.

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
void accept_handler(const boost::system::error_code& error,
    boost::asio::ip::tcp::socket peer)
{
  if (!error)
  {
    // Accept succeeded.
  }
}
 
...
 
boost::asio::ip::tcp::acceptor acceptor(my_context);
...
acceptor.async_accept(accept_handler);

Да это не легкое, изучать буст.

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

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

в этой чудо лямбде инициализируется "socket" ?

Ну так он передается.
А как у вас он инициализируется?
Вероятно он приходит уже готовый. Этим занимается внутренняя реализация acceptor.
Не то что бы я прям горю желанием сейчас во всём этом разбираться.
Но лучше документации чем из офф. буста, найти будет затруднительно.

@Palich · 19.08.2025, 12:24 **[ТС]**

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

Может потому что это естественно?

когда-то давно читал, что лямбду лучше использовать для коротких функций типа а+б, тут же нужно обработать код ошибки, потом если нужно, что-то сделать(передать в друг. функцию или тут же обработать) с сообщением. Т.е. это не простая функция уже. А если её заменить на std::bind, то вот как быть с soket'ом, который инициализируется acceptor'ом я не понял. На данный момент нашел другой способ, и вроде бы близок к рабочему коду, но не с помощью лямбды ) Я не против её, но когда её тыкают везде.... ну такое себе, конкретно в сетевом программир. конкретно в бусте у меня от лямбды ж.... подгорать начала.

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

Ну вот вы нашли эту перегрузку.

я её видел ) но не понимал что с ней делать т.к. описание непонятное.

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

Вероятно он приходит уже готовый. Этим занимается внутренняя реализация acceptor.

теперь чуть стало легче с пониманием этой перегрузки )

@SmallEvil · 19.08.2025, 14:41

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

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

Потому что для примера этого достаточно, и лямбду быстренько раз два и состряпал "на месте".
Особенно если это относится к реализации именно этого метода, тогда даже плохо её выносить куда то.

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

огда-то давно читал, что лямбду лучше использовать для коротких функций типа а+б

Первый раз такое слышу.

@Palich · 21.08.2025, 12:27 **[ТС]**

Как говорится "если долго мучиться, то что-нибудь получится".

В итоге у меня получился рабочий(т.е. программа запускается) код простого сервера и самое интересное, для меня, без "enable_shared_from_this<>" / "make_shared<>" / "shared_ptr<>" и чудо лямбдофункций.

В этом коде не реализовано отслеживание сессий.

Из того, что у меня получилось я вижу то, что:
1. "enable_shared_from_this<>" / "make_shared<>" / "shared_ptr<>" не нужно если указатель на объект где-то хранится и еще используется, в коде он хранится в векторе у сервера.
2. можно обойтись без лямбдофункций.

код:

Кликните здесь для просмотра всего текста

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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
#include <iostream>
#include <string>
#include <vector>
#include <memory> // Для std::shared_ptr
#include <array> // Для std::array
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/system/error_code.hpp>
 
#include <thread>
 
 
class Session {
    public:
        boost::asio::ip::tcp::socket m_socket;
        char m_cString [256];
 
    public:
        Session (boost::asio::ip::tcp::socket aSocket)
                    : m_socket (std::move (aSocket) ) {
        }
 
        ~Session () {
            std::cout << "~Session" << std::endl;
        }
 
    public:
        boost::asio::ip::tcp::socket& getSocket () {
            return m_socket;
        }
 
 
 
        void processTheClientMessage (const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
 
                if (aErrorCode.value() == boost::asio::error::eof) {
                    this->closeTheSession();
                }
                else {
                    std::cout << aErrorCode.message() << std::endl;
                    this->closeTheSession();
                }
            }
            else {
                std::string string2 (m_cString);
                std::cout << "client message = " << string2 << std::endl;
                this->readFromSocket();
            }
        }
 
 
 
        void readFromSocket () {
            auto bindedProcessTheClientMessage = std::bind (&Session::processTheClientMessage,
                                            this,
                                            boost::asio::placeholders::error);
 
            m_socket.async_read_some (boost::asio::buffer (m_cString, 256),
                                                bindedProcessTheClientMessage);
        }
 
 
        void closeTheSession () {
            m_socket.shutdown (boost::asio::ip::tcp::socket::shutdown_both);
            m_socket.cancel ();
            m_socket.close ();
 
            this->~Session();
        }
};
 
 
 
 
 
 
class Server {
    public:
        boost::asio::ip::tcp::endpoint m_endpoint;
        boost::asio::ip::tcp::acceptor m_acceptor;
        std::vector <Session*> m_Sessions;
        int m_sessionCounter;
 
    public:
        Server (boost::asio::io_context& aIoContext,
                        boost::asio::ip::address_v4 aIpAddressV4,
                        unsigned short aPort)
                : m_endpoint (aIpAddressV4, aPort), m_acceptor (aIoContext, m_endpoint) {
            m_sessionCounter = 0;
        }
 
        ~Server () {
            std::cout << "~Server" << std::endl;
        }
 
    public:
        void processTheConnection (const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
            }
            else {
                m_Sessions [m_sessionCounter] ->readFromSocket();
                ++m_sessionCounter;
            }
 
            this->startAccept ();
        }
 
 
 
 
        void startAccept() {
            boost::asio::ip::tcp::socket socket1 (m_acceptor.get_executor() );
            m_Sessions.push_back (new Session (std::move (socket1)) );
 
            auto bindedProcessTheConnection = std::bind (&Server::processTheConnection,
                                            this,
                                            boost::asio::placeholders::error);
            m_acceptor.async_accept (m_Sessions [m_sessionCounter]->getSocket (),
                                                bindedProcessTheConnection);
        }
};
 
 
 
 
 
 
 
int main() {
    SetConsoleCP (1251);
    SetConsoleOutputCP (1251);
 
    std::string ipString = "127.0.0.1";
    boost::asio::ip::address_v4 ipAddressV4;
    unsigned short port = 3333;
 
    try {
        std::cout << std::endl;
        std::cout << "------ server --- ";
        std::cout << ipString << ":" << std::to_string (port);
        std::cout << " ------" << std::endl;
        std::cout << std::endl;
 
        boost::asio::io_context ioContext1;
        Server Server1 (ioContext1, ipAddressV4, port);
        Server1.startAccept ();
        ioContext1.run();
    }
    catch (std::exception& e) {
        std::cerr << "Exception: " << e.what() << std::endl;
    }
 
    system ("pause");
    return 0;
}

Не по теме:

была мысль весь код "закатать" в бесконечную лямбдофункцию, что бы у людей, их любящих, вытекли глаза :)

@SmallEvil · 21.08.2025, 13:15

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

В итоге у меня получился рабочий(т.е. программа запускается) код простого сервера

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

Не по теме:

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

была мысль весь код "закатать" в бесконечную лямбдофункцию, что бы у людей, их любящих, вытекли глаза :)

Лямбдофобия - это что то новенькое)

@Palich · 23.08.2025, 22:59 **[ТС]**

И простой клиент тоже заработал. Так же без лямбдофункций и shared'подобных функций.

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

Из того, что у меня получилось я вижу то, что:
1. "enable_shared_from_this<>" / "make_shared<>" / "shared_ptr<>" не нужно если указатель на объект где-то хранится и еще используется, в коде он хранится в векторе у сервера.
2. можно обойтись без лямбдофункций.

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

код клиента:

Кликните здесь для просмотра всего текста

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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
#include <iostream>
#include <string>
#include <vector>
#include <memory>
#include <array>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
#include <boost/system/error_code.hpp>
 
 
class Session {
    public:
        boost::asio::ip::tcp::endpoint m_endpoint;
        boost::asio::ip::tcp::socket m_socket;
        char m_cString [256];
 
    public:
        Session (boost::asio::ip::tcp::endpoint aEndpoint,
                        boost::asio::io_context& aContext)
                : m_endpoint (std::move (aEndpoint) ),
                    m_socket (aContext, m_endpoint.protocol() ) {
        }
 
        ~Session () {
            std::cout << "~Session" << std::endl;
            m_socket.cancel ();
            m_socket.close ();
        }
 
    public:
        void processConnection (const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
                std::cout << "Session::processConnection:: "
                        << "error read to the socket: error code = " << aErrorCode.value()
                        << ", message = " << aErrorCode.message() << std::endl;
 
                throw "connection error";
            }
        }
 
 
 
 
        void connectToServer () {
            auto bindedProcessConnection = std::bind (&Session::processConnection,
                                            this,
                                            boost::asio::placeholders::error);
 
            m_socket.async_connect (m_endpoint, bindedProcessConnection);
        }
 
 
 
 
        boost::asio::ip::tcp::socket& getSocket () {
            return m_socket;
        }
 
 
 
        void processTheServerMessage (const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
 
                if (aErrorCode.value() == boost::asio::error::eof) {
                    this->closeTheSession();
                }
                else {
                    std::cout << "Session::processTheServerMessage:: "
                                << "error read to the socket: error code = " << aErrorCode.value()
                                << ", message = " << aErrorCode.message() << std::endl;
                    this->closeTheSession();
                }
            }
            else {
                std::string string2 (m_cString);
                std::cout << "Session::processTheServerMessage:: server message = "
                                << string2 << std::endl;
                this->readFromSocket();
            }
        }
 
 
 
        void readFromSocket () {
 
            auto bindedprocessTheServerMessage = std::bind (&Session::processTheServerMessage,
                                            this,
                                            boost::asio::placeholders::error);
 
            m_socket.async_read_some (boost::asio::buffer (m_cString, 256),
                                                bindedprocessTheServerMessage);
        }
 
 
 
 
        void processWriteToSocket (const boost::system::error_code& aErrorCode) {
 
            if (aErrorCode.value() != 0) {
 
                if (aErrorCode.value() == boost::asio::error::eof) {
                    this->closeTheSession();
                }
                else {
                    std::cout << "Session::processWriteToSocket:: "
                        << "error read to the socket: error code = " << aErrorCode.value()
                        << ", message = " << aErrorCode.message() << std::endl;
                    this->closeTheSession();
                }
            }
        }
 
 
 
 
        void writeToSocket () {
            std::string string1 = "hello, i am client";
 
            auto bindedProcessWriteToSocket = std::bind (&Session::processWriteToSocket,
                                            this,
                                            boost::asio::placeholders::error);
            m_socket.async_write_some (boost::asio::buffer (string1),
                                                        bindedProcessWriteToSocket);
        }
 
 
 
 
        void closeTheSession () {
            this->~Session();
        }
};
 
 
 
 
 
 
int main() {
    SetConsoleCP (1251);
    SetConsoleOutputCP (1251);
 
    std::string ipString = "127.0.0.1";
    unsigned short port = 3333;
 
    std::cout << "------ client --- ";
    std::cout << ipString << ":" << std::to_string (port);
    std::cout << " ------" << std::endl;
    std::cout << std::endl;
 
    boost::system::error_code errorCode1;
    boost::asio::ip::address ipAddress = boost::asio::ip::make_address (ipString, errorCode1);
 
    if (errorCode1.value() == 0) {
        boost::asio::ip::tcp::endpoint endpoint1 (ipAddress, port);
        boost::asio::io_context ioContext1;
        Session* Session1 =  new Session (endpoint1, ioContext1);
 
        try {
            Session1->connectToServer ();
            ioContext1.run();
            // ...
            Session1->writeToSocket ();
            // ...
            delete Session1;
        }
        catch (...) { // Ошибка соединения.
            delete Session1;
        }
    }
    else { // ipAddress = error.
        std::cout << "error ip address: error code = " << errorCode1.value()
                        << ", message = " << errorCode1.message() << std::endl;
    }
 
    system ("pause");
    return 0;
}

Добавлено через 5 минут
Думаю, тема считается закрытой. Цель достигнута ))

Спасение утопающего - дело рук самого утопающего )

Новые блоги и статьи Все статьи Все блоги /
[Owen Logic] Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ФедосеевПавел 14.03.2026 Поддержание уровня воды в резервуаре количеством включённых насосов: моделирование и выбор регулятора ВВЕДЕНИЕ Выполняя задание на управление насосной группой заполнения резервуара,. . .	делаю науч статью по влиянию грибов на сукцессию anaschu 13.03.2026 прикрепляю статью	SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++ 8Observer8 10.03.2026 Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:	Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE 8Observer8 10.03.2026 Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки Neotwalker 08.03.2026 Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .	Модульная разработка через nuget packages DevAlt 07.03.2026 Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .	Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .

@Palich 2 / 2 / 0 Регистрация: 07.04.2016 Сообщений: 298
	18.08.2025, 12:22 [ТС]
	в общем так и не понял как написать клиент-сервер 0