asio(十一)、udp异步服务器

官网教程：https://think-async.com/Asio/asio-1.26.0/doc/asio/tutorial/tutdaytime6.html

udp异步服务器

int main()
{
  try
  {

创建一个服务器对象来接受传入的客户端请求，并运行io_context对象。

    asio::io_context io_context;
    udp_server server(io_context);
    io_context.run();
  }
  catch (std::exception& e)
  {
    std::cerr << e.what() << std::endl;
  }

  return 0;
}

udp_server类

class udp_server
{
public:

构造函数初始化一个套接字以侦听UDP端口13。

  udp_server(asio::io_context& io_context)
    : socket_(io_context, udp::endpoint(udp::v4(), 13))
  {
    start_receive();
  }

private:
  void start_receive()
  {

函数ip::udp::socket::async_receive_from()将导致应用程序在后台侦听新请求。当收到这样的请求时，io_context对象将使用两个参数调用handle_received()函数：一个类型为error_code的值，指示操作是成功还是失败，另一个size_t值bytes_transfer，指定接收的字节数。

    socket_.async_receive_from(
        asio::buffer(recv_buffer_), remote_endpoint_,
        boost::bind(&udp_server::handle_receive, this,
          asio::placeholders::error,
          asio::placeholders::bytes_transferred));
  }

函数handle_received()将为客户端请求提供服务。

  void handle_receive(const asio::error_code& error,
      std::size_t /*bytes_transferred*/)
  {

error参数包含异步操作的结果。由于我们只提供1字节的recv_buffer_来包含客户端的请求，因此如果客户端发送了更大的请求，io_context对象将返回一个错误。如果出现这样的错误，我们可以忽略它。

    if (!error)
    {

确定我们要发送什么。

      boost::shared_ptr<std::string> message(
          new std::string(make_daytime_string()));

我们现在调用ip::udp::socket::async_send_to()将数据提供给客户端。

      socket_.async_send_to(asio::buffer(*message), remote_endpoint_,
          boost::bind(&udp_server::handle_send, this, message,
            asio::placeholders::error,
            asio::placeholders::bytes_transferred));

启动异步操作时，如果使用boost::bind，则必须仅指定与处理程序的参数列表匹配的参数。在这个程序中，两个参数占位符（asio::placeholders::error and asio::placeholders::bytes_transferred）都可能被删除。

开始侦听下一个客户端请求。

 start_receive();

这个客户端请求的任何进一步操作现在都由handle_send()负责。

    }
  }

函数handle_send()是在服务请求完成后调用的。

  void handle_send(boost::shared_ptr<std::string> /*message*/,
      const asio::error_code& /*error*/,
      std::size_t /*bytes_transferred*/)
  {
  }

  udp::socket socket_;
  udp::endpoint remote_endpoint_;
  boost::array<char, 1> recv_buffer_;
};

#include <ctime>
#include <iostream>
#include <string>
#include <boost/array.hpp>
#include <boost/bind/bind.hpp>
#include <boost/shared_ptr.hpp>
#include <asio.hpp>

using asio::ip::udp;

std::string make_daytime_string()
{
  using namespace std; // For time_t, time and ctime;
  time_t now = time(0);
  return ctime(&now);
}

class udp_server
{
public:
  udp_server(asio::io_context& io_context)
    : socket_(io_context, udp::endpoint(udp::v4(), 13))
  {
    start_receive();
  }

private:
  void start_receive()
  {
    socket_.async_receive_from(
        asio::buffer(recv_buffer_), remote_endpoint_,
        boost::bind(&udp_server::handle_receive, this,
          asio::placeholders::error,
          asio::placeholders::bytes_transferred));
  }

  void handle_receive(const asio::error_code& error,
      std::size_t /*bytes_transferred*/)
  {
    if (!error)
    {
      boost::shared_ptr<std::string> message(
          new std::string(make_daytime_string()));

      socket_.async_send_to(asio::buffer(*message), remote_endpoint_,
          boost::bind(&udp_server::handle_send, this, message,
            asio::placeholders::error,
            asio::placeholders::bytes_transferred));

      start_receive();
    }
  }

  void handle_send(boost::shared_ptr<std::string> /*message*/,
      const asio::error_code& /*error*/,
      std::size_t /*bytes_transferred*/)
  {
  }

  udp::socket socket_;
  udp::endpoint remote_endpoint_;
  boost::array<char, 1> recv_buffer_;
};

int main()
{
  try
  {
    asio::io_context io_context;
    udp_server server(io_context);
    io_context.run();
  }
  catch (std::exception& e)
  {
    std::cerr << e.what() << std::endl;
  }

  return 0;
}