asio 异步demo

教程地址：

https://github.com/sprinfall/boost-asio-study/tree/master/src

sever：

for循环发送堵塞了读，所以新连接收不到消息了。

  

   

    

     

    
    

     

      // asio_server.cpp : 定义控制台应用程序的入口点。
     
    
   

    

     

    
    

     

      //
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include "stdafx.h"
     
    
   

    

     

    
    

     

      #include <asio.hpp>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      using namespace asio;
     
    
   

    

     

    
    

     

      using asio::ip::tcp;
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #include <array>
     
    
   

    

     

    
    

     

      #include <functional>
     
    
   

    

     

    
    

     

      #include <iostream>
     
    
   

    

     

    
    

     

      #include <memory>
     
    
   

    

     

    
    

     

      #include <string>
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      // -----------------------------------------------------------------------------
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      #define USE_BIND 1 // Use std::bind or lambda
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      enum { BUF_SIZE = 1024 };
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      // -----------------------------------------------------------------------------
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      class Session : public std::enable_shared_from_this<Session> {
     
    
   

    

     

    
    

     

      public:
     
    
   

    

     

    
    

     

      	Session(tcp::socket socket) : socket_(std::move(socket)) {
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     
	void Start() {
     
    
   

    

     

    
    

     

      		DoRead();
     
    
   

    

     

    
    

     

      	}
     
    
   

    

     

    
    

     
 
     
    
   

    

     

    
    

     

      private:
     
    
   

    

     

    
    

     
	void DoRead() {
     
    
   

    

     

    
    

     

      #if USE_BIND
     
    
   

    

     

    
    

     

      		socke
     
    
  
 

文章来源: blog.csdn.net，作者：网奇，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/jacke121/article/details/89431675