asio_001.cpp
// 一个简单的回显服务器
#include <iostream>
#include <memory>
#include <array>
#include <boost/asio.hpp>
using boost::asio::ip::tcp;
// 服务器和某个客户端之间的“会话”
// 负责处理读写事件
class session : public std::enable_shared_from_this<session>
{
public:
session(tcp::socket s) : socket_(std::move(s)) {}
void start()
{
async_read();
}
private:
void async_read()
{
auto self(shared_from_this());
socket_.async_read_some(boost::asio::buffer(data_), // 异步读
[this, self](const boost::system::error_code &ec, size_t bytes_transferred) // 读操作完成时回调该函数
{ // 捕获`self`使shared_ptr<session>的引用计数增加1,在该例中避免了async_read()退出时其引用计数变为0
if (!ec)
async_write(bytes_transferred); // 读完即写
}
);
}
void async_write(std::size_t length)
{
auto self(shared_from_this());
boost::asio::async_write(socket_, boost::asio::buffer(data_, length), // 异步写
[this, self](const boost::system::error_code &ec, size_t)
{
if (!ec)
async_read();
}
);
}
tcp::socket socket_; // “会话”基于已经建立的socket连接
std::array<char, 1024> data_;
};
// 服务器类
// 监听客户端连接请求(async_accept)。与某个客户端建立socket连接后,为它创建一个session
class server
{
public:
server(boost::asio::io_service &io_service, short port)
: acceptor_(io_service, tcp::endpoint(tcp::v4(), port)), socket_(io_service)
{
async_accept();
}
private:
void async_accept()
{
acceptor_.async_accept(socket_, std::bind(&server::handle_accept, this, std::placeholders::_1)); // 异步accept。socket连接建立后,调用handle_accept()
}
void handle_accept(const boost::system::error_code &ec)
{
if (!ec)
{
std::shared_ptr<session> session_ptr(new session(std::move(socket_)));
session_ptr->start();
}
async_accept(); // 继续监听客户端连接请求
}
tcp::acceptor acceptor_;
tcp::socket socket_;
};
int main(int argc, char* argv[])
{
boost::asio::io_service io_service;
server s(io_service, 52014);
io_service.run();
return 0;
}
2 ,编译
g++ asio_001.cpp -o asio_001 -std=c++11 -I /usr/local/boost/include -L /usr/local/boost/lib -lboost_system -lboost_thread -lpthread
3,运行
./asio_001
用网络助手测试如下:
代码是借鉴的。