Асинхронность в 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

Новые блоги и статьи Все статьи Все блоги /
Модель здравосоХранения 6. ESG-повестка и устойчивое развитие; углублённый анализ кадрового бренда anaschu 31.03.2026 В прикрепленном документе раздумья о том, как можно поменять модель в будущем	10 пpимет, которые всегда сбываются Maks 31.03.2026 1. Чтобы, наконец, пришла маршрутка, надо закурить. Если сигарета последняя, маршрутка придет еще до второй затяжки даже вопреки расписанию. 2. Нaдоели зима и снег? Не надо переезжать. Достаточно. . .	Перемещение выделенных строк ТЧ из одного документа в другой Maks 31.03.2026 Реализация из решения ниже выполнена на примере нетипового документа "ВыдачаОборудованияНаСпецтехнику" с единственной табличной частью "ОборудованиеИКомплектующие" разработанного в конфигурации КА2. . . .	Functional First Web Framework Suave DevAlt 30.03.2026 Sauve. IO Апнулись до NET10. Из зависимостей один пакет, работает одинаково хорошо как в режиме проекта так и в интерактивном режиме. из сложностей - чисто функциональный подход. Решил. . .
Автоматическое создание документа при проведении другого документа Maks 29.03.2026 Реализация из решения ниже выполнена на нетиповых документах, разработанных в конфигурации КА2. Есть нетиповой документ "ЗаявкаНаРемонтСпецтехники" и нетиповой документ "ПланированиеСпецтехники". В. . .	Настройка движения справочника по регистру сведений Maks 29.03.2026 Решение ниже реализовано на примере нетипового справочника "ТарифыМобильнойСвязи" разработанного в конфигурации КА2, с целью учета корпоративной мобильной связи в коммерческом предприятии. . . .	Автозаполнение реквизита при выборе элемента справочника Maks 27.03.2026 Программный код из решения ниже на примере нетипового документа "ЗаявкаНаРемонтСпецтехники" разработанного в конфигурации КА2. При выборе "Спецтехники" (Тип Справочник. Спецтехника), заполняется. . .	Сумматор с применением элементов трёх состояний. Hrethgir 26.03.2026 Тут. https:/ / fips. ru/ EGD/ ab3c85c8-836d-4866-871b-c2f0c5d77fbc Первый документ красиво выглядит, но без схемы. Это конечно не даёт никаких плюсов автору, но тем не менее. . . всё может быть. . .