一个基于 muduo 库的异步处理的 UDP 客户端实现

muduo（GitHub - chenshuo/muduo: Event-driven network library for multi-threaded Linux server in C++11）实现了一个 one loop per thread 的模型，是进行异步处理的利器。而网络通信，由于数据到达的不可预期，使用异步方式是十分合适的。本文对使用 muduo 网路库实现一个 UDP 客户端进行数据收发处理的方法作简单介绍。由于 muduo 是一个运行于 Linux 上的 C++ 网路库，本文的介绍同样适用 C++，程序运行于 Linux 系统之上。

• 用于传输信令或大量实时性数据
• 传输的消息包都是被分割为小于 MTU 的小包
• 使用 recv 的 PEEK 标志先读取消息头获取重要信息，再读取完成消息
• 使用 EventLoop 的 runAfter 轻松实现数据包重传

• UdpClient(EventLoop *loop, MainService *main_service);
• 可在一个线程中初始化一个 EventLoop，传入该类实例化一个客户端，然后进入 loop 循环，保持一个由数据驱动的异步处理的客户端的运行。

• 消息 ID
• 消息头
• 各类别消息
  • 传输的消息包都是被分割为小于 MTU 的小包

• UDP socket 分两次读取数据：在读取头部时，采用 recve(sock, head, HEADER, MSG_PEEK) 方式，这样仅仅是偷窥（peek）一下数据，得知其数据的长度(不会影响 select 以及下一次读取)，然后再一次性读完。

• 利用消息头的消息序列号
• 超时未有收到对应 ACK 时重传消息
• 收到序列号比最新收到的要小时丢弃消息

2021-10-21