C++ boost::asio プログラミング - 同期 TCP の詳細な説明とコード例

boost::asio プログラミング - 同期 TCP

boost.asio ライブラリは、クロスプラットフォーム ネットワークおよび基礎となる IO C++ プログラミング ライブラリであり、最新の C++ 技術を使用して、統合された非同期呼び出しモデルを実装します。

boost.asio ライブラリは、TCP、UDP、および ICMP 通信プロトコルをサポートします。

以下では、同期 TCP モードを紹介します:

皆さん、こんにちは!同期モードに入っています！

私の一番の特徴は粘り強さです！戻る前にすべての操作を完了するか、エラーを起こす必要があります。しかし、私のしつこさは皆からブロックと呼ばれ、本当に憂鬱です〜〜（観客からブーイング）実際、これはです。 ロジックが明確になり、プログラミングが容易になるなどの利点もあります。

サーバー側では、ソケットを作成してアクセプターオブジェクトに渡し、クライアントが接続するのを待ちます。接続後、このソケットを介してクライアントと通信します。 すべての通信はブロッキング方式で実行され、読み取りまたは書き込みが完了するまで通信は戻りません。

このとき、サーバーへの接続にはソケットを使用しますが、最終的には接続が完了したとき、またはエラーが発生したときにのみ戻ります。ブロッキング方式でサーバーと通信します。
同期方式は非同期方式ほど効率的ではないと考える人もいますが、実際にはこれは一方的な理解です。これは、ネットワーク操作に費やした時間を他のことに使えないシングルスレッドの場合に当てはまるかもしれません。 感情は調整の良い方法ではありません。ただし、この問題はマルチスレッドによって回避できます。たとえば、サーバー側では、スレッドの 1 つがクライアントの接続を待機し、接続が確立されるとソケットが別のスレッドに渡されます。 クライアントと通信することで、1 つのクライアントと通信しながら、他のクライアントからの接続も受け入れることができ、メイン スレッドが完全に解放されます。

私の紹介は以上です、皆さんありがとうございました！

同期方法のサンプルコード:

サーバー側

// BoostTcpServer.cpp : 定义控制台应用程序的入口点。 
// 
   
#include "stdafx.h" 
#include "boost/asio.hpp" 
#include "boost/thread.hpp" 
   
using namespace std; 
using namespace boost::asio; 
   
#ifdef _MSC_VER 
#define _WIN32_WINNT  0X0501 //避免VC下编译警告 
#endif 
   
#define PORT 1000 
#define IPV6 
//#define IPV4 
   
int _tmain(int argc, _TCHAR* argv[]) 
{ 
  // 所有asio类都需要io_service对象 
  io_service iosev; 
   
  //创建用于接收客户端连接的acceptor对象 
#ifdef IPV4 
  ip::tcp::acceptor acceptor(iosev,ip::tcp::endpoint(ip::tcp::v4(), PORT)); 
#endif 
   
#ifdef IPV6 
  ip::tcp::acceptor acceptor(iosev,ip::tcp::endpoint(ip::tcp::v6(), PORT)); 
#endif 
   
  while (true) 
  { 
    // socket对象 
    ip::tcp::socket socket(iosev); 
    // 等待直到客户端连接进来 
    acceptor.accept(socket); 
    // 显示连接进来的客户端 
    std::cout <<"remote ip:"<<socket.remote_endpoint().address()<<endl; 
    std::cout <<"remote port:"<<socket.remote_endpoint().port() << std::endl; 
   
    char buf[2048]; 
    boost::system::error_code ec; 
    while(1) 
    { 
      socket.read_some(buffer(buf),ec); 
      if (ec) 
      { 
        std::cout <<boost::system::system_error(ec).what() << std::endl; 
        break ; 
      } 
      std::cout<<"recv msg:"<<buf<<endl; 
      if(strcmp(buf,"bye")==0)//收到结束消息结束客户端连接 
      { 
        break; 
      } 
      socket.write_some(buffer("I heared you!\n"),ec); 
      if (ec) 
      { 
        std::cout <<boost::system::system_error(ec).what() << std::endl; 
        break ; 
      } 
    } 
    socket.close(); 
    // 与当前客户交互完成后循环继续等待下一客户连接 
  } 
  return 0; 
}

クライアント側

// BoostTcpClient.cpp : 定义控制台应用程序的入口点。 
// 
   
#include "stdafx.h" 
#include "boost/asio.hpp" 
   
using namespace boost::asio; 
   
#ifdef _MSC_VER 
#define _WIN32_WINNT  0X0501 //避免VC下编译警告 
#endif 
   
#define PORT 1000 
#define IPV6 
//#define IPV4 
   
int _tmain(int argc, _TCHAR* argv[]) 
{ 
  // 所有asio类都需要io_service对象 
  io_service iosev; 
  // socket对象 
  ip::tcp::socket socket(iosev); 
   
  // 连接端点，这里使用了本机连接，可以修改IP地址测试远程连接 
#ifdef IPV4 
  ip::address_v4 address=ip::address_v4::from_string("127.0.0.1"); 
#endif 
   
#ifdef IPV6 
  //"0:0:0:0:0:0:0:1"为IPV6的本机回环地址，类似于"127.0.0.1" 
  ip::address_v6 address=ip::address_v6::from_string("0:0:0:0:0:0:0:1"); 
#endif 
  ip::tcp::endpoint ep(address, PORT); 
  // 连接服务器 
  boost::system::error_code ec; 
  socket.connect(ep,ec); 
  // 如果出错，打印出错信息 
  if (ec) 
  { 
    std::cout << boost::system::system_error(ec).what() << std::endl; 
    return -1; 
  } 
   
  //循环发送和接收数据 
  for(int i=0;i<5;++i) 
  { 
    //发送数据 
    socket.write_some(buffer("hello"), ec); 
    // 接收数据 
    char buf[100]; 
    size_t len=socket.read_some(buffer(buf), ec); 
    std::cout.write(buf, len); 
    Sleep(500); 
  } 
  //发送与服务端约定好的结束语,由服务端断链 
  socket.write_some(buffer("bye"), ec); 
     
  getchar(); 
  return 0; 
}

このコードは、使用する IP プロトコルを選択するためにマクロ定義を使用します。クライアント 通常の通信では、サーバーとのプロトコルが一貫している必要があります。

読んでいただきありがとうございます。他の関連記事については、PHP 中国語 Web サイト (www.php.cn) に注目してください。