概述
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 循环,保持一个由数据驱动的异步处理的客户端的运行。
消息的设计
消息的读取与解析
- UDP socket 分两次读取数据:在读取头部时,采用 recve(sock, head, HEADER, MSG_PEEK) 方式,这样仅仅是偷窥(peek)一下数据,得知其数据的长度(不会影响 select 以及下一次读取),然后再一次性读完。
传输可靠性设计
- 利用消息头的消息序列号
- 超时未有收到对应 ACK 时重传消息
- 收到序列号比最新收到的要小时丢弃消息
2021-10-21
|