ブーストasio、async_readとacync_writeコールバックを呼び出さない

Question

私はboost-asioソケットをカプセル化していますが、問題がありますが、async_readもasync_writeもコールバック関数を呼び出すのではありません。

私はasync_read_someを使用しようとしましたが、同じ問題がありました。

ここで私はmallocビットは、私はC.

を使用せずにそれを行うための方法を見つけるまで、誰かができれば、私は本当に感謝するだろう一時的なものであり、これまで

#include <iostream> 
#include "socket.hpp" 

Socket::Socket() 
{ 
    boost::asio::ip::tcp::endpoint ep_tmp(boost::asio::ip::tcp::v4(), 4242); 

    endpoint = ep_tmp; 
    acceptor = new boost::asio::ip::tcp::acceptor(ios, endpoint); 
    tcp_socket = new boost::asio::ip::tcp::socket(ios); 
    acceptor->listen(); 
} 

Socket::~Socket() 
{ 
    delete(acceptor); 
    delete(tcp_socket); 
} 

void  Socket::get_connection() 
{ 
    acceptor->async_accept(*tcp_socket, [](const boost::system::error_code &ec) 
      { 
       std::cout << "Connection received." << std::endl; 
       if (ec) 
       std::cout << "Error " << ec << std::endl; 
      }); 
    this->exec(); 
} 

void  Socket::send(std::string &message) 
{ 
    async_write(*tcp_socket, boost::asio::buffer(message), 
      [](const boost::system::error_code &ec, 
     std::size_t bytes_transferred) 
      { 
     std::cout << "Sending datas." << std::endl; 
     if (ec) 
      std::cout << "Error " << ec << std::endl; 
     else 
      std::cout << bytes_transferred << " bytes transferred." << std::endl; 
      }); 
} 

void  Socket::receive(void) 
{ 
    char  *buf; 

    buf = (char *)malloc(sizeof(char) * 50); 
    buf = (char *)memset(buf, 0, 50); 
    async_read(*tcp_socket, boost::asio::buffer(buf, 50), 
     [](const boost::system::error_code &ec, 
     std::size_t bytes_transferred) 
     { 
      std::cout << "Receiving datas." << std::endl; 
      if (ec) 
     std::cout << "Error " << ec << std::endl; 
      else 
     std::cout << bytes_transferred 
       << " bytes transferred." << std::endl; 
     }); 
} 

void  Socket::exec(void) 
{ 
    ios.run(); 
} 

int  main() 
{ 
    Socket serv; 
    std::string data_test; 

    data_test = "Test\n"; 
    serv.get_connection(); 
    serv.send(data_test); 
    serv.exec(); 
    serv.receive(); 
    serv.exec(); 
    return (0); 
} 

を書いたコードですその問題について教えてください

Answer 1

私はyuriと一緒です：あなたが何をしているのか分からない限り、非同期ではない方が好きです。

それは次のようになります。あなたは非同期動作が必要な場合はhttp://coliru.stacked-crooked.com/a/523a7828a9aee4b2

#include <boost/asio.hpp> 
#include <iostream> 

namespace ba = boost::asio; 
using ba::ip::tcp; 

class Socket { 
    public: 
    Socket() { acceptor.listen(); } 

    void get_connection(); 
    void exec(); 
    void send(std::string const &message); 
    void receive(void); 

    private: 
    ba::io_service ios; 
    tcp::endpoint endpoint{ tcp::v4(), 4242 }; 
    tcp::acceptor acceptor{ ios, endpoint }; 
    tcp::socket tcp_socket{ ios }; 
}; 

void Socket::get_connection() { 
    acceptor.accept(tcp_socket); 
    std::cout << "Connection received.\n"; 
} 

void Socket::send(std::string const &message) { 
    std::cout << "Sending datas.\n"; 
    auto bytes_transferred = ba::write(tcp_socket, ba::buffer(message)); 
    std::cout << bytes_transferred << " bytes transferred.\n"; 
} 

void Socket::receive(void) { 
    std::cout << "Receiving datas.\n"; 

    char buf[50] = { 0 }; 
    auto bytes_transferred = ba::read(tcp_socket, ba::buffer(buf)); 
    std::cout << bytes_transferred << " bytes transferred.\n"; 
} 

int main() { 
    Socket serv; 

    serv.get_connection(); 
    serv.send("Test\n"); 
    serv.receive(); 
} 

、あなたは各バッファ/接続固有のリソースの寿命を管理する必要があります。多くの例があります。バッファ寿命の危険にhttp://coliru.stacked-crooked.com/a/95e2000e49b4db1d

• ：client server simple example nonblocking

ここにドキュメントやで

Answer 2

に2回目以降の電話をかける前にio_service::resetに電話する必要があります。現在のアプローチが非同期の目的を絶対に打ち負かすため、おそらく同期APIを代わりに使用したいと考えています。