Асинхронность в boost asio

@Invader_Zim · Регистрация: 21.07.2011

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

Доброго времени суток!
Хотелось мне сделать обертку вокруг асио. Чтобы обьект класса в одно время был сервером, в другое клиентом. Чтобы все быстро бегало, захотелось асинхронностью занятся. В итоге, как сервер он не фурычит, следовательно его клиентскую работоспособность проверить нет возможности. Помогите разобраться (в частности найти ошибки, которые не дают сделать асинхронный сервер(может ошибка во мне, может неправильно доку понял.))

Вот сам класс

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
class NetworkManager{
    std::string IP;
    unsigned short Port;
    static boost::asio::io_service io;
    boost::asio::ip::tcp::acceptor *acc;
    data(*analys)(data);
    void server_handler(const boost::system::error_code& error,boost::asio::ip::tcp::socket* s){
        if(!error){
            data A;
            std::stringstream file;
            Read(s,&file);
            boost::archive::binary_iarchive(file) >> A;
            A=analys(A);
            boost::archive::binary_oarchive(file) << A;
            Write(s,&file);
        }
    }
    void io_handler(const boost::system::error_code& error){
        ;
    }
    void connect_handler(const boost::system::error_code& error,boost::asio::ip::tcp::socket *s,data* M){
        if(!error){
            std::stringstream file;
            boost::archive::binary_oarchive(file) << (*M);
            Write(s,&file);
            while(!s->available());
                Read(s,&file);
            s->close();
            boost::archive::binary_iarchive(file) >> (*M);
            Servered();
        }
    }
    void Write(boost::asio::ip::tcp::socket *s,char *a,size_t size){
        boost::asio::async_write(*s, boost::asio::buffer(&size,sizeof(size_t)),boost::bind(&NetworkManager::io_handler,*this,boost::asio::placeholders::error));        
        boost::asio::async_write(*s, boost::asio::buffer(a,size),boost::bind(&NetworkManager::io_handler,*this,boost::asio::placeholders::error));
    }
    void Write(boost::asio::ip::tcp::socket *s,std::stringstream *file){
        file->seekg(std::ios_base::end);
        size_t size=file->tellg();
        char *a;
        file->read(a, size);
        Write(s,a,size);
    }
    void Read(boost::asio::ip::tcp::socket *s,char *a,size_t *size){
        boost::asio::async_read(*s,boost::asio::buffer(size,sizeof(size_t)),boost::bind(&NetworkManager::io_handler,*this,boost::asio::placeholders::error));
        boost::asio::async_read(*s,boost::asio::buffer(a,*size),boost::bind(&NetworkManager::io_handler,*this,boost::asio::placeholders::error));
    }
    void Read(boost::asio::ip::tcp::socket *s,std::stringstream *file){
        file->str("");
        char *a;
        size_t size;
        Read(s,a,&size);
        file->write(a,size);
    }
 
public:
    NetworkManager(){
        acc=NULL;
    }
    boost::asio::ip::tcp::socket* NewSocket(){return new boost::asio::ip::tcp::socket(io);}
    void SetIP(std::string s){IP=s;}
    void SetPort(unsigned short p){Port=p;}
 
    void Session(data *A){
        boost::asio::ip::tcp::socket* S=NewSocket();
        S->async_connect(boost::asio::ip::tcp::endpoint(boost::asio::ip::address::from_string(IP), Port),boost::bind(&NetworkManager::connect_handler,*this,boost::asio::placeholders::error,S,A));
    }
    void Servered(){
        if(acc!=NULL)
            acc=new boost::asio::ip::tcp::acceptor(io, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 26000));
        auto S=NewSocket();
        acc->async_accept(*S,boost::bind(&NetworkManager::server_handler,*this,boost::asio::placeholders::error,S));
    }
    void Disconnected(boost::asio::ip::tcp::socket *sock){sock->close();}
    void SetAnalyser(data(*a)(data)){analys=a;}
    static void Run(){io.run();}
};

Мейн

C++
1
2
3
4
5
6
7
data F(ata A){return data("QWERTYUI");}
int main()
{
    NetworkManager N;
    N.SetAnalyser(F);
    NetworkManager::Run();
}

@ForEveR · 13.11.2012, 15:55

Invader_Zim, Что есть не фурычит?

Добавлено через 38 минут
накропал на коленке.

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
#include <boost/asio.hpp>
#include <boost/scoped_ptr.hpp>
#include <boost/noncopyable.hpp>
#include <boost/bind.hpp>
#include <iostream>
 
namespace asio = boost::asio;
namespace ip = asio::ip;
 
const size_t message_length = 9;
 
std::ostream& operator << (std::ostream& stream, const boost::system::error_code& err)
{
   stream << "Category: " << err.category().name() << " message: " << err.message() << std::endl;
   return stream;
}
 
class NetworkManager : boost::noncopyable
{
public:
   NetworkManager() : write_sock_(ios_), read_sock_(ios_)
   { 
      memset(read_buf, message_length, 0);
      memset(write_buf, message_length, 0);
   }
   void start_server()
   {
      acc_.reset(new ip::tcp::acceptor(ios_, ip::tcp::endpoint(ip::tcp::v4(), 25000)));
      acc_->async_accept(read_sock_, boost::bind(&NetworkManager::handle_accept, this, asio::placeholders::error));
   }
   void start_client()
   {
      write_sock_.async_connect(ip::tcp::endpoint(ip::address::from_string("127.0.0.1"), 25000),
            boost::bind(&NetworkManager::handle_connect, this, asio::placeholders::error));
   }
   void run()
   {
      try
      {
         ios_.run();
      }
      catch (const std::exception& e)
      {
         std::cout << "Exception from run: " << e.what() << std::endl;
         ios_.reset();
      }
      ios_.reset();
   }
private:
   void handle_connect(const boost::system::error_code& err)
   {
      if (err)
      {
         std::cout << "Error in connect: " << err << std::endl;
         do_close();
      }
      do_write();
   }
   void do_write()
   {
      asio::async_write(write_sock_, asio::buffer("Hello, s"),
            boost::bind(&NetworkManager::handle_write, this, asio::placeholders::error));
   }
   void handle_write(const boost::system::error_code& err)
   {
      if (err)
      {
         std::cout << "Write error: " << err << std::endl;
         do_close();
      }
      do_read_answer();
   }
   void do_read_answer()
   {
      asio::async_read(write_sock_, asio::buffer(write_buf, message_length),
            boost::bind(&NetworkManager::handle_read_answer, this, asio::placeholders::error));
   }
   void handle_read_answer(const boost::system::error_code& err)
   {
      if (err)
      {
         std::cout << "Error in read answer: " << err << std::endl;
         do_close();
      }
      std::cout << "From server: " << std::string(write_buf, message_length) << std::endl;
   }
   void handle_accept(const boost::system::error_code& err)
   {
      if (err)
      {
         std::cout << "Error in accept: " << err << std::endl;
         do_close();
      }
      do_server_read();
   }
   void do_server_read()
   {
      asio::async_read(read_sock_, asio::buffer(read_buf, message_length),
            boost::bind(&NetworkManager::handle_read, this, asio::placeholders::error));
   }
   void handle_read(const boost::system::error_code& err)
   {
      if (err)
      {
         std::cout << "Error in read: " << err;
         do_close();
      }
      std::cout << "From client: " << std::string(read_buf, message_length) << std::endl;
      do_write_answer();
   }
   void do_write_answer()
   {
      asio::async_write(read_sock_, asio::buffer("Hello, c"),
            boost::bind(&NetworkManager::handle_write_answer, this, asio::placeholders::error, asio::placeholders::bytes_transferred));
   }
   void handle_write_answer(const boost::system::error_code& err, size_t bytes)
   {
      if (err)
      {
         std::cout << "Error in write: " << err << std::endl;
         do_close();
      }
   }
   void do_close()
   {
      std::cout << "Do close socket" << std::endl;
      if (write_sock_.is_open())
      {
         write_sock_.close();
      }
      if (read_sock_.is_open())
      {
         read_sock_.close();
      }
      if (acc_ && acc_->is_open())
      {
         acc_->close();
      }
      throw std::logic_error("timeout");
   }
   char read_buf[message_length];
   char write_buf[message_length];
   asio::io_service ios_;
   ip::tcp::socket write_sock_;
   ip::tcp::socket read_sock_;
   boost::scoped_ptr<ip::tcp::acceptor> acc_;
};
 
int main()
{
   NetworkManager nm;
   nm.start_server();
   nm.start_client();
   nm.run();
}

Вывод:

From client: Hello, s
From server: Hello, c

Новые блоги и статьи Все статьи Все блоги /
Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Programma_Boinc 26.12.2025 Кто-нибудь знает, где можно бесплатно получить настольный компьютер или ноутбук? США. Нашел на реддите интересную статью под названием «Кто-нибудь знает, где получить бесплатный компьютер или. . .	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 - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .