Cleofwine | 开发者

游戏后端技术_boost_asio网络编程

最近更新：2024-09-23 | 字数总计：398 | 阅读估时：2分钟 | 阅读量：次

什么是boost asio
boost asio如何解决问题
Boost Asio Server Example

什么是boost asio

async io核心功能用于异步io的处理
asio是跨平台的网络库

boost asio如何解决问题

cmake组织boost asio
- boost::system
  - boost::system::error_code
  - boost::system::system_error
- boost::regex 可选
  - read_until
  - async_read_until
命名空间
- boost::asio
  - 核心类以及函数
  - io_context
    - linux：reactor对象
    - windows：iocp对象
  - 同步io函数
    - 类似posix函数，connect、accept、read_some、write_some
  - 异步io函数
    - async_connect、async_accept、async_read_some、async_write_some
- boost::asio::ip
  - 网络通信相关
  - ip地址：ip::address 对ip地址的封装
  - 端点：ip::tcp::endpoint、ip::udp::endpoint 对ip::port的封装
  - 套接字：ip::tcp::socket、ip::udp::socket 创建时需要绑定io_context
  - 套接字控制
    - set_option等设置套接字属性
    - get_option 获取套接字属性
    - io_control 在套接字上执行一段io指令

Boost Asio Server Example

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

using namespace boost::asio;
using namespace boost::asio::ip;
using namespace std;

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()); // 这里是为了保证回调的时候这个对象仍然存在，用智能指针的方式保证至少有一个引用，不然调用do_write会有问题
        socket_.async_read_some(buffer(data_, max_length),[this, self](boost::system::error_code err, std::size_t length){
            if(!err){
                do_write(length);
            }
        });
    }
    void do_write(std::size_t length){
         auto self(shared_from_this());
         socket_.async_write_some(buffer(data_, length), [this, self](boost::system::error_code err, std::size_t length){
            if(!err){
                do_read();
            }
         });
    }
    tcp::socket socket_;
    enum {max_length = 1024};
    char data_[max_length];
};

class Server{
public:
    Server(io_context &io_ctx, short port) : acceptor_(io_ctx, tcp::endpoint(tcp::v4(), port))
    {
        do_accept();
    }
private:
    void do_accept(){
        acceptor_.async_accept([this](boost::system::error_code err, tcp::socket socket){
            if(!err){
                std::make_shared<Session>(std::move(socket))->Start();
            }
            do_accept();
        });
    }
private:
    tcp::acceptor acceptor_;
};

int main()
{
    io_context io_ctx;
    Server s(io_ctx, 8989);
    io_ctx.run();
    return 0;
}

2024-06-12 该篇文章被 Cleofwine 归为分类: Game