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
| #include <cstdlib>
#include <iostream>
#include <memory>
#include <utility>
#include <string>
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
class session : public std::enable_shared_from_this<session>
{
public:
session(tcp::socket socket) : socket_(std::move(socket)){}
void start()
{
do_read();
}
private:
void do_read()
{
auto self(shared_from_this());
socket_.async_receive(boost::asio::buffer(data_, max_length), [this, self](boost::system::error_code ec, std::size_t length)
{
if (!ec)
{
std::cout << data_;
do_write(length);
}
});
}
void do_write(std::size_t length)
{
auto self(shared_from_this());
boost::asio::async_write(socket_, boost::asio::buffer(data_, length), [this, self](boost::system::error_code ec, std::size_t)
{
if (!ec)
{
do_read();
}
});
}
tcp::socket socket_;
enum { max_length = 256 };
char data_[max_length];
};
class server
{
public:
server(boost::asio::io_service& io_service, short port) : acceptor_(io_service, tcp::endpoint(tcp::v4(), port)), socket_(io_service)
{
do_accept();
}
private:
void do_accept()
{
std::cout << "2";
acceptor_.async_accept(socket_, [this](boost::system::error_code ec)
{
std::cout << "3";
if (!ec)
{
std::make_shared<session>(std::move(socket_))->start();
}
do_accept();
});
}
tcp::acceptor acceptor_;
tcp::socket socket_;
};
void connexionTCP()
{
try
{
boost::asio::io_service io_service;
server s(io_service, 2017);
std::cout << "1";
io_service.run();
}
catch (std::exception& e)
{
std::cerr << "Exception: " << e.what() << "\n";
}
} |
Partager