Asio的Buffer应该如何使用

文章目录

Asio的Buffer应该如何使用
- 什么是asio::buffer
- asio::const_buffer和asio::mutable_buffer
- - asio::mutable_buffer的设计
  - asio::const_buffer的设计
- asio::buffer使用方法
- 例子

什么是asio::buffer

asio::buffer并不是真正的缓冲区，想要获得缓冲区必须传入一段内存，比如st::vector<>，char[]，std::string等。而asio::buffer负责管理这段内存，特别注意对于异步API内存在使用时必须有效。

asio::const_buffer和asio::mutable_buffer

构造函数不同
const_buffer不可修改，初始化是什么使用socket发送时就会发送什么，比如使用st::vector初始化，虽然vector的内容可以修改，但是对asio::buffer来说不起作用

asio::mutable_buffer的设计

asio::mutable_buffer的设计不复杂，就是将缓冲区作为参数传进去；读写都由其它函数负责，asio::mutable_buffer本身只负责存储数据。

class mutable_buffer {public:/// Construct an empty buffer.mutable_buffer() BOOST_ASIO_NOEXCEPT:data_(0),size_(0) {}/// Construct a buffer to represent a given memory range.mutable_buffer(void* data, std::size_t size) BOOST_ASIO_NOEXCEPT:data_(data),size_(size) {}#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING)mutable_buffer(void* data, std::size_t size,boost::asio::detail::function<void()> debug_check): data_(data),size_(size),debug_check_(debug_check) {}const boost::asio::detail::function<void()>& get_debug_check() const {return debug_check_;}
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGING/// Get a pointer to the beginning of the memory range.void* data() const BOOST_ASIO_NOEXCEPT {#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING)if (size_ && debug_check_)debug_check_();
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGINGreturn data_;}/// Get the size of the memory range.std::size_t size() const BOOST_ASIO_NOEXCEPT {return size_;}/// Move the start of the buffer by the specified number of bytes.mutable_buffer& operator+=(std::size_t n) BOOST_ASIO_NOEXCEPT{std::size_t offset = n < size_ ? n : size_;data_ = static_cast<char*>(data_) + offset;size_ -= offset;return *this;}private:void* data_;std::size_t size_;#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING)boost::asio::detail::function<void()> debug_check_;
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGING
};

asio::const_buffer的设计

与asio::mutable_buffer类似，同样只存储数据，但是不可更改。

class const_buffer {public:/// Construct an empty buffer.const_buffer() BOOST_ASIO_NOEXCEPT:data_(0),size_(0) {}/// Construct a buffer to represent a given memory range.const_buffer(const void* data, std::size_t size) BOOST_ASIO_NOEXCEPT:data_(data),size_(size) {}/// Construct a non-modifiable buffer from a modifiable one.const_buffer(const mutable_buffer& b) BOOST_ASIO_NOEXCEPT:data_(b.data()),size_(b.size())
#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING), debug_check_(b.get_debug_check())
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGING{}#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING)const_buffer(const void* data, std::size_t size,boost::asio::detail::function<void()> debug_check): data_(data),size_(size),debug_check_(debug_check) {}const boost::asio::detail::function<void()>& get_debug_check() const {return debug_check_;}
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGING/// Get a pointer to the beginning of the memory range.const void* data() const BOOST_ASIO_NOEXCEPT {#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING)if (size_ && debug_check_)debug_check_();
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGINGreturn data_;}/// Get the size of the memory range.std::size_t size() const BOOST_ASIO_NOEXCEPT {return size_;}/// Move the start of the buffer by the specified number of bytes.const_buffer& operator+=(std::size_t n) BOOST_ASIO_NOEXCEPT{std::size_t offset = n < size_ ? n : size_;data_ = static_cast<const char*>(data_) + offset;size_ -= offset;return *this;}private:const void* data_;std::size_t size_;#if defined(BOOST_ASIO_ENABLE_BUFFER_DEBUGGING)boost::asio::detail::function<void()> debug_check_;
#endif // BOOST_ASIO_ENABLE_BUFFER_DEBUGGING
};

asio::buffer使用方法

简单的方法就是在session类里申请一片内存（或全局内存），发送时使用asio::buffer包装
BufferSequence
使用内存池

例子

在session类里申请一片内存

class session: public std::enable_shared_from_this<session> {public:session(tcp::socket socket): socket_(std::move(socket)) {}~session() {}void start() {for (int i = 0; i < 100; ++i) {do_write();}}private:void do_write() {auto str = std::to_string(num);for (int i = 0; i < str.size(); ++i) {data[i] = str[i];}data[str.size()] = '\n';num++;//保证调用异步方法时session仍然存在auto self(shared_from_this());//使用boost::asio::buffer包装并发送boost::asio::async_write(socket_, boost::asio::buffer(data),[self](boost::system::error_code /*ec*/, std::size_t /*length*/) {});}// The socket used to communicate with the client.tcp::socket socket_;//固定大小缓冲区char data[128];int num = 0;
};

BufferSequence

class shared_const_buffer
{public:// Construct from a std::string.explicit shared_const_buffer(const std::string& data): data_(new std::vector<char>(data.begin(), data.end())),buffer_(boost::asio::buffer(*data_)){}// Implement the ConstBufferSequence requirements.typedef boost::asio::const_buffer value_type;typedef const boost::asio::const_buffer* const_iterator;const boost::asio::const_buffer* begin() const { return &buffer_; }const boost::asio::const_buffer* end() const { return &buffer_ + 1; }private:boost::shared_ptr<std::vector<char> > data_;//这里可以使用boost::asio::const_buffer数组//可以使用初始化列表初始化boost::asio::const_buffer buffer_;
};class session: public std::enable_shared_from_this<session>
{public:session(tcp::socket socket): socket_(std::move(socket)){}void start(){do_write();}private:void do_write(){std::time_t now = std::time(0);//初始化后不能更改，缺点就是对于变化的信息每次都要重新构造buffershared_const_buffer buffer(std::ctime(&now));auto self(shared_from_this());boost::asio::async_write(socket_, buffer,[self](boost::system::error_code /*ec*/, std::size_t /*length*/){});}// The socket used to communicate with the client.tcp::socket socket_;
};

内存池

内存池技术比较复杂了，也有不少开源实现，这里就不详述了

Asio的Buffer应该如何使用相关推荐

网上收集下boost::asio发送与传输相关的几个函数，老是忘记
刚连接上:调用async_accept 1 boost::shared_ptr<tcp::socket> spMySocket(new tcp::socket(m_ioservice)); ...
Boost.Asio技术文档
文章来源:http://blog.csdn.net/henreash/article/details/7469707 Boost.Asio是一个跨平台的网络及底层IO的C++编程库,它使用现代C++手 ...
【Boost】boost库asio详解7——boost::asio::buffer用法
1. asio::buffer常用的构造方法 asio::buffer有多种的构造方法,而且buffer大小是自动管理的 1.1 字符数组 [cpp] view plain copy print? ...
boost库学习④：boost::asio::buffer
asio::buffer常用的构造方法字符数组 char d1[128]; size_t bytes_transferred = socket.receive(boost::asio::buffer ...
boost::asio使用UDP协议通信源码实现
说明:以下源码来自参考文献[1], 比原文更丰富, 更有指导意义, 方便日后参考. udp servr端源码 //g++ -g udp_server.cpp -o udp_server -lboost ...

Asio的Buffer应该如何使用

Asio的Buffer应该如何使用

文章目录

什么是asio::buffer

asio::const_buffer和asio::mutable_buffer

asio::mutable_buffer的设计

asio::const_buffer的设计

asio::buffer使用方法

例子

Asio的Buffer应该如何使用相关推荐

最新文章

热门文章