#include<ctime>
#include<iostream>
#include<string>
#include<boost/bind/bind.hpp>
#include<boost/shared_ptr.hpp>
#include<boost/enable_shared_from_this.hpp>
#include<boost/asio.hpp>
using boost::asio::ip::tcp;
std::string make_dattime_string() {
using namespace std;
time_t now = time(0);
char buff[26];
ctime_s(buff, sizeof buff, &now);
return buff;
}
class tcp_connection :public boost::enable_shared_from_this<tcp_connection> {
public:
typedef boost::shared_ptr<tcp_connection> pointer;
static pointer create(boost::asio::io_context& io_context) {
return pointer(new tcp_connection(io_context));
}
tcp::socket& socket() {
return socket_;
}
void start() {
message_ = make_dattime_string();
boost::asio::async_write(socket_, boost::asio::buffer(message_), boost::bind(&tcp_connection::handle_write, shared_from_this(),
boost::asio::placeholders::error, boost::asio::placeholders::bytes_transferred));
}
private:
tcp_connection(boost::asio::io_context& io_context):socket_(io_context) {
}
void handle_write(const boost::system::error_code& /*error */, size_t) {};
tcp::socket socket_;
std::string message_;
};
class tcp_server {
public:
tcp_server(boost::asio::io_context& io_context) :io_context_(io_context), acceptor_(io_context, tcp::endpoint(tcp::v4(), 8888)) {
start_accept();
}
private:
boost::asio::io_context& io_context_;
tcp::acceptor acceptor_;
void start_accept() {
tcp_connection::pointer new_connection = tcp_connection::create(io_context_);
acceptor_.async_accept(new_connection->socket(), boost::bind(&tcp_server::handle_accept,this, new_connection, boost::asio::placeholders::error));
}
void handle_accept(tcp_connection::pointer new_connection, const boost::system::error_code& error) {
if (!error)
{
new_connection->start();
}
}
};
int main() {
try
{
boost::asio::io_context io_context;
tcp_server server(io_context);
io_context.run();
}
catch (const std::exception& e)
{
std::cerr << e.what() << std::endl;
}
}
转载请注明来源,欢迎对文章中的引用来源进行考证,欢迎指出任何有错误或不够清晰的表达。可以在下面评论区评论,也可以邮件至 ggchzzz@163.com