6.boostTCP通信

• 客户端

  #include <boost/asio.hpp>
  #include <iostream>
  #include <stdlib.h>
  using namespace std;
  using namespace boost::asio;
  
  void main()
  {
      //创建io服务
      io_service iosev;
      //通过io服务初始化套接字
      ip::tcp::socket mysorket(iosev);
      //设置连接
      ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 1100);
  
      //保存异常信息
      boost::system::error_code ec;
      //连接
      mysorket.connect(ep, ec);
  
      while (1)
      {
          char str[1024] = { 0 };
          cout << "请输入";
          cin >> str;
          cout << endl;
  
          //通过套接字发送消息
          mysorket.write_some(buffer(str), ec);
          //清空字符串
          memset(str, 0, 1024);
          //接收字符串
          mysorket.read_some(buffer(str), ec);
          cout << "收到" << str << endl;
      }
  
      cin.get();
  }

• boost服务器端

  #include <boost/asio.hpp>
  #include <iostream>
  #include <stdlib.h>
  
  
  using namespace std;
  using namespace boost::asio;
  
  
  
  void main()
  {
      //创建io服务
      io_service iosev;
      //设置接收
      ip::tcp::acceptor myacceptor(iosev, ip::tcp::endpoint(ip::tcp::v4(), 1100));
      //处理多个客户端
      while (1)
      {
          //通过io服务初始化套接字
          ip::tcp::socket mysocket(iosev);
          //通过套接字接收连接
          myacceptor.accept(mysocket);
          //输出连接的客户端的地址以及连上的端口号
          cout << "客户端" << mysocket.remote_endpoint().address() << mysocket.remote_endpoint().port() << "链接上" << endl;
          
          //接收字符串
          char recestr[1024] = { 0 };
          //存放错误信息
          boost::system::error_code ec;
          //处理网络异常
          int length = mysocket.read_some(buffer(recestr), ec);
          cout << "收到" << recestr << "长度" << length << endl;
          //执行收到的指令
          system(recestr);
          //发送数据
          length = mysocket.write_some(buffer(recestr, length), ec);
          cout << "发送报文长度" << length << endl;
      }
      cin.get();
  }