asio socket同步读写

同步写write_some

boost::asio提供了几种同步写的api,write_some可以每次向指定的空间写入固定的字节数,如果写缓冲区满了,就只写一部分,返回写入的字节数。

  1. void wirte_to_socket(asio::ip::tcp::socket& sock) {
  2. std::string buf = "Hello World!";
  3. std::size_t total_bytes_written = 0;
  4. //循环发送
  5. //write_some返回每次写入的字节数
  6. //total_bytes_written是已经发送的字节数。
  7. //每次发送buf.length()- total_bytes_written)字节数据
  8. while (total_bytes_written != buf.length()) {
  9. total_bytes_written += sock.write_some(
  10. asio::buffer(buf.c_str()+total_bytes_written,
  11. buf.length()- total_bytes_written));
  12. }
  13. }

同步写send

write_some使用起来比较麻烦,需要多次调用,asio提供了send函数。send函数会一次性将buffer中的内容发送给对端,如果有部分字节因为发送缓冲区满无法发送,则阻塞等待,直到发送缓冲区可用,则继续发送完成。

  1. int send_data_by_send(){
  2. std::string raw_ip_address = "127.0.0.1";
  3. unsigned short port_num = 3333;
  4. try {
  5. asio::ip::tcp::endpoint
  6. ep(asio::ip::address::from_string(raw_ip_address),
  7. port_num);
  8. asio::io_service ios;
  9. // Step 1. Allocating and opening the socket.
  10. asio::ip::tcp::socket sock(ios, ep.protocol());
  11. sock.connect(ep);
  12. std::string buf = "Hello World!";
  13. int send_length = sock.send(asio::buffer(buf.c_str(), buf.length()));
  14. if (send_length <= 0) {
  15. cout << "send failed" << endl;
  16. return 0;
  17. }
  18. }
  19. catch (system::system_error& e) {
  20. std::cout << "Error occured! Error code = " << e.code()
  21. << ". Message: " << e.what();
  22. return e.code().value();
  23. }
  24. return 0;
  25. }

同步写write

类似send方法,asio还提供了一个write函数,可以一次性将所有数据发送给对端,如果发送缓冲区满了则阻塞,直到发送缓冲区可用,将数据发送完成。

  1. int send_data_by_wirte() {
  2. std::string raw_ip_address = "127.0.0.1";
  3. unsigned short port_num = 3333;
  4. try {
  5. asio::ip::tcp::endpoint
  6. ep(asio::ip::address::from_string(raw_ip_address),
  7. port_num);
  8. asio::io_service ios;
  9. // Step 1. Allocating and opening the socket.
  10. asio::ip::tcp::socket sock(ios, ep.protocol());
  11. sock.connect(ep);
  12. std::string buf = "Hello World!";
  13. int send_length = asio::write(sock, asio::buffer(buf.c_str(), buf.length()));
  14. if (send_length <= 0) {
  15. cout << "send failed" << endl;
  16. return 0;
  17. }
  18. }
  19. catch (system::system_error& e) {
  20. std::cout << "Error occured! Error code = " << e.code()
  21. << ". Message: " << e.what();
  22. return e.code().value();
  23. }
  24. return 0;
  25. }

同步读read_some

同步读和同步写类似,提供了读取指定字节数的接口read_some

  1. std::string read_from_socket(asio::ip::tcp::socket& sock) {
  2. const unsigned char MESSAGE_SIZE = 7;
  3. char buf[MESSAGE_SIZE];
  4. std::size_t total_bytes_read = 0;
  5. while (total_bytes_read != MESSAGE_SIZE) {
  6. total_bytes_read += sock.read_some(
  7. asio::buffer(buf + total_bytes_read,
  8. MESSAGE_SIZE - total_bytes_read));
  9. }
  10. return std::string(buf, total_bytes_read);
  11. }
  12. int read_data_by_read_some() {
  13. std::string raw_ip_address = "127.0.0.1";
  14. unsigned short port_num = 3333;
  15. try {
  16. asio::ip::tcp::endpoint
  17. ep(asio::ip::address::from_string(raw_ip_address),
  18. port_num);
  19. asio::io_service ios;
  20. asio::ip::tcp::socket sock(ios, ep.protocol());
  21. sock.connect(ep);
  22. read_from_socket(sock);
  23. }
  24. catch (system::system_error& e) {
  25. std::cout << "Error occured! Error code = " << e.code()
  26. << ". Message: " << e.what();
  27. return e.code().value();
  28. }
  29. return 0;
  30. }

同步读receive

可以一次性同步接收对方发送的数据

  1. int read_data_by_receive() {
  2. std::string raw_ip_address = "127.0.0.1";
  3. unsigned short port_num = 3333;
  4. try {
  5. asio::ip::tcp::endpoint
  6. ep(asio::ip::address::from_string(raw_ip_address),
  7. port_num);
  8. asio::io_service ios;
  9. asio::ip::tcp::socket sock(ios, ep.protocol());
  10. sock.connect(ep);
  11. const unsigned char BUFF_SIZE = 7;
  12. char buffer_receive[BUFF_SIZE];
  13. int receive_length = sock.receive(asio::buffer(buffer_receive, BUFF_SIZE));
  14. if (receive_length <= 0) {
  15. cout << "receive failed" << endl;
  16. }
  17. }
  18. catch (system::system_error& e) {
  19. std::cout << "Error occured! Error code = " << e.code()
  20. << ". Message: " << e.what();
  21. return e.code().value();
  22. }
  23. return 0;
  24. }

同步读read

可以一次性同步读取对方发送的数据

  1. int read_data_by_read() {
  2. std::string raw_ip_address = "127.0.0.1";
  3. unsigned short port_num = 3333;
  4. try {
  5. asio::ip::tcp::endpoint
  6. ep(asio::ip::address::from_string(raw_ip_address),
  7. port_num);
  8. asio::io_service ios;
  9. asio::ip::tcp::socket sock(ios, ep.protocol());
  10. sock.connect(ep);
  11. const unsigned char BUFF_SIZE = 7;
  12. char buffer_receive[BUFF_SIZE];
  13. int receive_length = asio::read(sock, asio::buffer(buffer_receive, BUFF_SIZE));
  14. if (receive_length <= 0) {
  15. cout << "receive failed" << endl;
  16. }
  17. }
  18. catch (system::system_error& e) {
  19. std::cout << "Error occured! Error code = " << e.code()
  20. << ". Message: " << e.what();
  21. return e.code().value();
  22. }
  23. return 0;
  24. }

读取直到指定字符

我们可以一直读取,直到读取指定字符结束

  1. std::string read_data_by_until(asio::ip::tcp::socket& sock) {
  2. asio::streambuf buf;
  3. // Synchronously read data from the socket until
  4. // '\n' symbol is encountered.
  5. asio::read_until(sock, buf, '\n');
  6. std::string message;
  7. // Because buffer 'buf' may contain some other data
  8. // after '\n' symbol, we have to parse the buffer and
  9. // extract only symbols before the delimiter.
  10. std::istream input_stream(&buf);
  11. std::getline(input_stream, message);
  12. return message;
  13. }

源码链接

https://gitee.com/secondtonone1/boostasio-learn

热门评论

热门文章

  1. 聊天项目(28) 分布式服务通知好友申请

    喜欢(507) 浏览(6093)
  2. 使用hexo搭建个人博客

    喜欢(533) 浏览(11888)
  3. Linux环境搭建和编码

    喜欢(594) 浏览(13540)
  4. Qt环境搭建

    喜欢(517) 浏览(24683)
  5. vscode搭建windows C++开发环境

    喜欢(596) 浏览(83343)

最新评论

  1. 堆排序 secondtonone1:堆排序非常实用,定时器就是这个原理制作的。
  2. 聊天项目(15) 客户端实现TCP管理者 lkx:已经在&QTcpSocket::readyRead 回调函数中做了处理了的。
  3. protobuf配置和使用 熊二:你可以把dll放到系统目录,也可以配置环境变量,还能把dll丢到lib里
  4. 无锁并发队列 TenThousandOne:_head  和 _tail  替换为原子变量。那里pop的逻辑,val = _data[h] 可以移到循环外面吗
  5. 答疑汇总(thread,async源码分析) Yagus:如果引用计数为0,则会执行 future 的析构进而等待任务执行完成,那么看到的输出将是 这边应该不对吧,std::future析构只在这三种情况都满足的时候才回block: 1.共享状态是std::async 创造的(类型是_Task_async_state) 2.共享状态没有ready 3.这个future是共享状态的最后一个引用 这边共享状态类型是“_Package_state”,引用计数即使为0也不应该block啊
  6. 创建项目和编译 secondtonone1:谢谢支持
  7. 聊天项目(9) redis服务搭建 pro_lin:redis线程池的析构函数,除了pop出队列,还要free掉redis连接把
  8. 聊天项目(7) visualstudio配置grpc diablorrr:cmake文件得改一下 find_package(Boost REQUIRED COMPONENTS system filesystem),要加上filesystem。在target_link_libraries中也同样加上
  9. 面试题汇总(一) secondtonone1:看到网络上经常提问的go的问题,做了一下汇总,结合自己的经验给出的答案,如有纰漏,望指正批评。
  10. interface应用 secondtonone1:interface是万能类型,但是使用时要转换为实际类型来使用。interface丰富了go的多态特性,也降低了传统面向对象语言的耦合性。
  11. string类 WangQi888888:确实错了,应该是!isspace(sind[index]). 否则不进入循环,还是原来的字符串“some string”
  12. Qt 对话框 Spade2077:QDialog w(); //这里是不是不需要带括号
  13. 处理网络粘包问题 zyouth: //消息的长度小于头部规定的长度,说明数据未收全,则先将部分消息放到接收节点里 if (bytes_transferred < data_len) { memcpy(_recv_msg_node->_data + _recv_msg_node->_cur_len, _data + copy_len, bytes_transferred); _recv_msg_node->_cur_len += bytes_transferred; ::memset(_data, 0, MAX_LENGTH); _socket.async_read_some(boost::asio::buffer(_data, MAX_LENGTH), std::bind(&CSession::HandleRead, this, std::placeholders::_1, std::placeholders::_2, shared_self)); //头部处理完成 _b_head_parse = true; return; } 把_b_head_parse = true;放在_socket.async_read_some前面是不是更好
  14. Qt MVC结构之QItemDelegate介绍 胡歌-此生不换:gpt, google
  15. boost::asio之socket的创建和连接 项空月:发现一些错别字 :每隔vector存储  是不是是每个. asio::mutable_buffers_1 o或者    是不是多打了个o
  16. 解决博客回复区被脚本注入的问题 secondtonone1:走到现在我忽然明白一个道理,无论工作也好生活也罢,最重要的是开心,即使一份安稳的工作不能给我带来事业上的积累也要合理的舍弃,所以我还是想去做喜欢的方向。
  17. C++ 并发三剑客future, promise和async Yunfei:大佬您好,如果这个线程池中加入的异步任务的形参如果有右值引用,这个commit中的返回类型推导和bind绑定就会出现问题,请问实际工程中,是不是不会用到这种任务,如果用到了,应该怎么解决?
  18. 网络编程学习方法和图书推荐 Corleone:啥程度可以找工作
  19. 再谈单例模式 secondtonone1:是的,C++11以后返回局部static变量对象能保证线程安全了。
  20. visual studio配置boost库 一giao里我离giaogiao:请问是修改成这样吗:.\b2.exe toolset=MinGW
  21. 类和对象 陈宇航:支持!!!!
  22. 构造函数 secondtonone1:构造函数是类的基础知识,要着重掌握
  23. 利用栅栏实现同步 Dzher:作者你好!我觉得 std::thread a(write_x); std::thread b(write_y); std::thread c(read_x_then_y); std::thread d(read_y_then_x); 这个例子中的assert fail并不会发生,原子变量设定了非relaxed内存序后一个线程的原子变量被写入,那么之后的读取一定会被同步的,c和d线程中只可能同时发生一个z++未执行的情况,最终z不是1就是2了,我测试了很多次都没有assert,请问我这个观点有什么错误,谢谢!

个人公众号

个人微信