Boost.Asio c++ 网络编程翻译(10)
read/write方法
这些方法对一个流进行读写操作(能够是套接字,或者其它表现的像流的类):
async_read(stream, buffer [, completion],handler):这种方法异步地从一个流读取。结束时,处理方法被调用。处理方法的格式是:void handler(const boost::system::error_ code & err, size_tbytes);。你能够选择指定一个完毕处理方法。完毕处理方法会在每一个read操作调用成功之后调用,然后告诉Boost.Asio async_read操作是否完毕(假设没有完毕,它会继续读取)。它的格式是:size_t completion(const
boost::system::error_code& err, size_tbytes_transfered) 。当这个完毕处理方法返回0时,我们觉得read操作完毕;假设它返回一个非0值,它表示了下一个async_read_some操作须要从流中读取的字节数。
接下来会有一个样例来具体展示这些。
async_write(stream, buffer [, completion],handler):这种方法异步地向一个流写入数据。參数的意义和async_read是一样的。
read(stream, buffer [, completion]):这种方法同步地从一个流中读取数据。參数的意义和async_read是一样的。
rite(stream, buffer [, completion]): 这种方法同步地向一个流写入数据。參数的意义和async_read是一样的。
° async_read(stream,stream_buffer [, completion], handler)
° async_write(strean,stream_buffer [, completion], handler)
° write(stream, stream_buffer[, completion])
° read(stream, stream_buffer[, completion])
首先,要注意第一个參数变成了流,而不单是socket。这个包括了socket但不不过socket。比方,你能够用一个Windows的文件句柄来替代socket。
当以下情况出现时,全部read和write操作都会结束:
可用的缓冲区满了(当读取时)或者全部的缓冲区已经被写入(当写入时)。
完毕处理方法返回0(假设你提供了这么一个方法)
发生错误时
以下的代码会异步地从一个socket中间读取数据直到读取到’\n’:
io_service service;
ip::tcp::socket sock(service);
char buff[512];
size_t up_to_en
int offset = 0;
stem::error_code &, size_t bytes) {
ter(const boost::s
y
for( size_t i = 0; i < bytes; ++i)
if ( buff[i + offset] == '\n')
return 0;
return 1;
}
void on_read(const boost::system::error_code &, size_t) {}
...
c_read(sock, buffer(buff), up_to_enter,on_read);
asy
n
Boost.Asio也提供了一些简单的完毕处理仿函数:
• transfer_at_least(n)
• transfer_exactly(n)
• transfer_all(
)
样例例如以下:
char buff[512];
void on_read(constboost::system::error_code &, size_t) {}
// 读取32个字节
async_read(sock, buffer(buff),transfer_exactly(32), on_read);
上述的4个方法,不使用普通的缓冲区,而使用由Boost.Asio的std::streambuf类继承来的stream_buffer方法,stl流和流缓冲区很复杂;以下是样例:
io_service service;
void on_read(streambuf& buf, constboost::system::error_code &,
size_t) {
std::istream in(&buf);
std::string line;
std::getline(in, line);
std::cout << "first line: "<< line << std::endl;
}
int main(int argc, char* argv[]) {
HANDLE file =::CreateFile("readme.txt", GENERIC_READ, 0, 0,
OPEN_ALWAYS, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED,
0);
windows::stream_handle h(service, file);
streambuf buf;
uf, transfer_exactly(256),
async_read(h,
b
boost::bind(on_read,boost::ref(buf),_1,_2));
service.run();
}
在这里,我向你们展示了在一个Windows文件句柄上调用async_read。我们读取了前面的256个字符,然后把它们保存到缓冲区,当操作结束时。on_read被调用,然后创建std::istream来传递缓冲区,读取第一行(std::getline),最后把它输出到命令行中。
read_until/async_read_until方法
这些方法在条件满足之前一直读取:
async_read_until(stream, stream_buffer,delim, handler):这种方法启动一个异步read操作。read操作会在读取到某个分隔符时结束。分隔符能够是字符,std::string或者boost::regex。处理方法的格式为:void handler(const boost::system::error_code & err, size_tbytes);。
async_read_until(strem, stream_buffer,completion, handler):这种方法和之前的方法是一样的,可是没有分隔符,而是一个完毕处理方法。完毕处理方法的格式为:pair<iterator,bool> completion(iterator begin, iterator end);,当中迭代器的类型为buffers_iterator<streambuf::const_buffers_type>。你须要记住的是迭代器的类型是随机訪问的迭代器。你扫描整个区间(begin,end),然后认为read操作是否应该结束。你会返回一个结果对,第一个成员是一个指向最后被这种方法訪问的字符的迭代器;第二个成员当read操作须要结束时返回true,否则返回false。
read_until(stream, stream_buffer, delim):这种方法运行一个同步的read操作,參数的意义和async_read_until一样。
read_until(stream, stream_buffer,completion):这种方法运行一个同步的read操作,參数的意义和async_read_until一样。
以下这个样例会一直读取直到读到一个指定的标点符号
typedefbuffers_iterator<streambuf::const_buffers_type> iterator;
std::pair<iterator, bool>match_punct(iterator begin, iterator end) {
while ( begin != end)
if ( std::ispunct(*begin))
return std::make_pair(begin,true);
return std::make_pair(end,false);
}
void on_read(constboost::system::error_code &, size_t) {}
...
streambuf buf;
async_read_until(sock, buf, match_punct,on_read);
假设我们想读到一个空格结束,我们须要把最后一行改动为:
async_read_until(sock, buff, ' ', on_read);
最新文章
- Oracle索引梳理系列(九)- 浅谈聚簇因子对索引使用的影响及优化方法
- Xcode7 模拟器安装app (转)
- 【转】执行脚本出现bin/bash: bad interpreter: No such file or directory
- WINCE+6410 拨号上网
- C 封装一个csv 解析库
- javascript操作html元素CSS属性
- Esper系列(三)Context和Group by
- [iOS]C语言技术视频-12-指针变量练习二(数组打印)
- SQL SERVER将多行数据合并成一行(转载)
- kickstart 实现批量安装centos7.x系统
- Flash Builder4.7安装破解
- 机器学习——KMeans聚类,KMeans原理,参数详解
- (贪心 优先队列)P1090合并果子 洛谷
- 2019年北航OO第2单元(电梯模拟)总结
- Linux内核源码分析--内核启动之(4)Image内核启动(setup_arch函数)(Linux-3.0 ARMv7)【转】
- 你的产品适不适合做微信小程序?你需要这篇产品逻辑分析
- opencv3.2.0形态学滤波之腐蚀
- MySQL学习笔记:like和regexp的区别
- 第106天:Ajax中同步请求和异步请求
- vsftpd被动模式配置
热门文章
- hdu 3294 Girls&;#39; research
- BZOJ2716: [Violet 3]天使玩偶(KD-Tree)
- 【例题 8-10 UVA - 714】 Copying Books
- Java Web学习总结(2)——Servlet入门
- 洛谷 P1480 A/B Problem
- LINUX设备驱动程序笔记(三)字符设备驱动程序
- [转]Linq使用心得——SelectMany替代二重foreach循环
- 韦东山网课https://edu.csdn.net/course/play/207/1117
- 16.用Spring Boot颠覆Java应用开发
- vue使用(二)