2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
1

Boost asio завершить работу асинхронного TCP сервера

27.08.2023, 13:47. Показов 2670. Ответов 12
Метки нет (Все метки)

Author24 — интернет-сервис помощи студентам
Здравствуйте друзья.
Столкнулся с проблемой завершения работы TCP сервера по команде "stop". Взял код с github, чуток поправил, все работает без проблем, но как закрывать соединения ума не приложу?? В tutorial написано"io_context.stop()", вроде все понятно, а куда засунуть не знаю.

Подскажите пожалуйста, как реализовывается алгоритм остановки программы?

Исходник где взял: https://github.com/ru-cpp-tuto... tcp-сервер

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
#include <iostream>
#include <optional>
#include <boost/asio.hpp>
 
class session : public std::enable_shared_from_this<session>
{
public:
    session(boost::asio::ip::tcp::socket &&socket) : socket(std::move(socket)) {}
 
    void start()
    {
        boost::asio::async_read_until(
            socket,
            streambuf,
            '\n',
            [self = shared_from_this()](
                boost::system::error_code error,
                std::size_t bytes_transferred)
            {
                std::istream is(&self->streambuf);
                std::string line;
                std::getline(is, line);
                std::cout << "line: " << line << std::endl;
            });
    }
 
private:
    boost::asio::ip::tcp::socket socket;
    boost::asio::streambuf streambuf;
};
 
class server
{
public:
    server(boost::asio::io_context &io_context, std::uint16_t port) : io_context(io_context),
                                                                      acceptor(
                                                                          io_context,
                                                                          boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), port)) {}
 
    void async_accept()
    {
        socket.emplace(io_context);
 
        acceptor.async_accept(*socket, [&](boost::system::error_code error)
                              {
            std::make_shared<session>(std::move(*socket))->start();
            async_accept(); });
    }
 
private:
    boost::asio::io_context &io_context;
    boost::asio::ip::tcp::acceptor acceptor;
    std::optional<boost::asio::ip::tcp::socket> socket;
};
 
int main()
{
    boost::asio::io_context io_context;
    server srv(io_context, 2014);
    srv.async_accept();
    io_context.run();
    return 0;
}
Спасибо.
0
Лучшие ответы (1)
Programming
Эксперт
94731 / 64177 / 26122
Регистрация: 12.04.2006
Сообщений: 116,782
27.08.2023, 13:47
Ответы с готовыми решениями:

Boost.asio io_service.run не дожидается выполнения асинхронного чтения
Добрый день! Имеется такая задача: - нужно отправялться HTTP запрос и получать ответ. все...

boost::asio::ip::tcp::resolver::close() - проблемы
Есть код клиента. Выложу только значащие моменты. Проблема заключается в следующем - при...

boost::asio::ip::tcp::socket::async_connect не вызывает handler
Пытаюсь подключиться к серверу: void CTcpClient::Connect( const std::string &amp; IpAddress_, int...

Ошибка в boost::asio::ip::tcp::iostream stream (&request);
Только приступаю к изучению boost::asio, не судите строго. Программа вычитывает картинку и...

12
6085 / 3445 / 1400
Регистрация: 07.02.2019
Сообщений: 8,755
27.08.2023, 13:52 2
Цитата Сообщение от Bodden Посмотреть сообщение
Столкнулся с проблемой завершения работы TCP сервера по команде "stop"
Откуда эта "команда" приходить должна?

Добавлено через 2 минуты
Кликните здесь для просмотра всего текста
Цитата Сообщение от Bodden Посмотреть сообщение
вроде все понятно, а куда засунуть не знаю
Например, в обработчик сигнала SIGTSTP
0
2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
27.08.2023, 13:53  [ТС] 3
Цитата Сообщение от zayats80888 Посмотреть сообщение
Откуда эта "команда" приходить должна?
Да, извините, забыл уточнить. Команда подается с другого приложения localhost на порт 2014. То приложение на С# написано, я его после первого запускаю и подаю команды.
0
6085 / 3445 / 1400
Регистрация: 07.02.2019
Сообщений: 8,755
27.08.2023, 13:54 4
Цитата Сообщение от Bodden Посмотреть сообщение
Команда подается с другого приложения localhost на порт 2014.
Ну вот и слушайте этот порт, когда придет команда, в колбэке останавливайте.
0
2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
27.08.2023, 14:04  [ТС] 5
Цитата Сообщение от zayats80888 Посмотреть сообщение
Ну вот и слушайте этот порт, когда придет команда, в колбэке останавливайте.
В том и вопрос: В каком месте?
0
6085 / 3445 / 1400
Регистрация: 07.02.2019
Сообщений: 8,755
27.08.2023, 14:11 6
Цитата Сообщение от Bodden Посмотреть сообщение
В каком месте?
Вопрос не понятен.
Я же написал, в колбэке.
0
2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
27.08.2023, 14:16  [ТС] 7
Цитата Сообщение от zayats80888 Посмотреть сообщение
Я же написал, в колбэке.
C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
    void start()
    {
        boost::asio::async_read_until(
            socket,
            streambuf,
            '\n',
            [self = shared_from_this()](
                boost::system::error_code error,
                std::size_t bytes_transferred)
            {
                std::istream is(&self->streambuf);
                std::string line;
                std::getline(is, line);
                std::cout << "line: " << line << std::endl;
                if (line.compare("stop") == 0)
                {
                    io_context.stop();
                }
            });
 
    }
Так не работает
0
6085 / 3445 / 1400
Регистрация: 07.02.2019
Сообщений: 8,755
27.08.2023, 14:24 8
Цитата Сообщение от Bodden Посмотреть сообщение
Так не работает
Что значит не работает? Команда не приходит или что?

Добавлено через 1 минуту
И где вы это написали? Класс session не знает об объекте io_context
0
2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
27.08.2023, 14:26  [ТС] 9
Цитата Сообщение от zayats80888 Посмотреть сообщение
Что значит не работает? Команда не приходит или что?
Boost asio завершить работу асинхронного TCP сервера
0
2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
27.08.2023, 14:27  [ТС] 10
Цитата Сообщение от zayats80888 Посмотреть сообщение
Класс session не знает об объекте io_context
Ну да, там и написал. Я если честно чуток запутался в этих колбеках boost
0
6085 / 3445 / 1400
Регистрация: 07.02.2019
Сообщений: 8,755
27.08.2023, 14:34 11
Лучший ответ Сообщение было отмечено Bodden как решение

Решение

Bodden, напр. так:
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 <iostream>
#include <optional>
#include <boost/asio.hpp>
 
class session : public std::enable_shared_from_this<session>
{
public:
    session(boost::asio::io_context &io_context, boost::asio::ip::tcp::socket &&socket) : io_context(io_context), socket(std::move(socket)) {}
 
    void start()
    {
        boost::asio::async_read_until(
            socket,
            streambuf,
            '\n',
            [self = shared_from_this()](
                boost::system::error_code error,
                std::size_t bytes_transferred)
            {
                std::istream is(&self->streambuf);
                std::string line;
                std::getline(is, line);
                std::cout << "line: " << line << std::endl;
                if (line.compare("stop") == 0)
                {
                    self->io_context.stop();
                }
            });
    }
 
private:
    boost::asio::io_context &io_context;
    boost::asio::ip::tcp::socket socket;
    boost::asio::streambuf streambuf;
};
 
class server
{
public:
    server(boost::asio::io_context &io_context, std::uint16_t port) : io_context(io_context),
                                                                      acceptor(
                                                                          io_context,
                                                                          boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), port)) {}
 
    void async_accept()
    {
        socket.emplace(io_context);
 
        acceptor.async_accept(*socket, [&](boost::system::error_code error)
                              {
            std::make_shared<session>(io_context, std::move(*socket))->start();
            async_accept(); });
    }
 
private:
    boost::asio::io_context &io_context;
    boost::asio::ip::tcp::acceptor acceptor;
    std::optional<boost::asio::ip::tcp::socket> socket;
};
 
int main()
{
    boost::asio::io_context io_context;
    server srv(io_context, 2014);
    srv.async_accept();
    io_context.run();
    return 0;
}
1
2 / 1 / 1
Регистрация: 22.11.2022
Сообщений: 108
27.08.2023, 15:19  [ТС] 12
Цитата Сообщение от zayats80888 Посмотреть сообщение
напр. так:
Спасибо, мне бы в жизнь да то кого самому не допереть.
0
zayats80888
27.08.2023, 15:22     Boost asio завершить работу асинхронного TCP сервера
  #13

Не по теме:

Цитата Сообщение от Bodden Посмотреть сообщение
мне бы в жизнь да то кого самому не допереть
Тогда рановато вы за буст взялись.
Самостоятельно ничего не напишите, а эксплуатировать примеры не вариант.
Вам бы сначала базу С++ освоить.

0
IT_Exp
Эксперт
87844 / 49110 / 22898
Регистрация: 17.06.2006
Сообщений: 92,604
27.08.2023, 15:22

Чат без сервера на Boost.Asio (broadcast и udp)
Здравствуйте! Передо мной стоит задача написать чат, не использующий сервер (для небольшой...

Boost.Asio. Как получить ответ от сервера в формате json или xml
Все привет, столкнулся с проблемой. Допустим, с помощью boost.asio и OpenSSL я делаю GET запрос...

Boost::Asio клиент - сервер: При вводе с телнета на стороне сервера появляется куча крякозябр
Раньше использовал Code::Blocks и winsock. Сейчас решил попробовать VS2013 и библиотеку boost::asio...

Является ли boost::asio::tcp::acceptor потоко-безопасным ?
Мне сложно понять смысл того что написано в документации:...

Как узнать число активных соединений в boost::asio::ip::tcp::acceptor ?
Можно конечно и самому завести счётчик, но хочется сделать более профессиональное решение, если...

Архитектура асинхронного tcp-сервера
Итак стоит задача. Есть 200 тыс клиентов, требуется постоянный мониторинг этих клиентов, клиенты...

Как нормально завершить работу сервера
Помогите пожалуйста нормально завершить работу сервера! Вообще задумка такая - вкл. сервер, потом...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
13
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2024, CyberForum.ru