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