🚀 VMUX技术分析：OPENPPP2中的虚拟多路复用技术

🌟 一、技术目标

🔗 连接多路复用
通过单个或多个物理链路，承载多个逻辑TCP连接。
🚀 高性能传输
- 支持数据包乱序重组
- 实现动态流量控制（拥塞检测/加速切换）
- 高效内存管理（缓冲池复用）
🌐 跨平台调优
- Windows：QoS差分服务
- Linux：网络保护
🔒 连接管理
- 心跳保活
- 超时自动清理
- 防火墙策略集成

🏗️ 二、核心架构图解

1. 结构总览

2. 物理链路与逻辑连接关系

🧩 三、关键组件详解

📡 `vmux_net`（网络层）

核心结构示意图

多物理链路承载机制

示例：添加链路的代码片段

bool vmux_net::add_linklayer(const VirtualEthernetTcpipConnectionPtr& connection,vmux_linklayer_ptr& linklayer) 
{rx_links_.emplace_back(linklayer);   // 添加接收链路tx_links_.emplace_back(linklayer);   // 添加发送链路// 启动链路转发协程ppp::coroutines::YieldContext::Spawn([this, linklayer](auto& y){forwarding(linklayer, y);});
}

🎯 动态链路选择策略

🔗 `vmux_skt`（连接层）

类结构示意

连接状态机

流量控制示例

bool vmux_skt::rx_congestions(int64_t value) {rx_congestions_ += value;if (rx_congestions_ >= max_congestions && status_.rx_acceleration_) {// 触发减速mux_->post(cmd_acceleration, &FALSE);} else if (rx_congestions_ <= 0 && !status_.rx_acceleration_) {// 触发加速mux_->post(cmd_acceleration, &TRUE);}
}

📝 工作流程

1. 连接建立流程

2. 数据传输流程

🛠️ 六、关键技术点

1. 乱序包处理

使用有序映射队列存储乱序包
依据序列号（seq）填补间隙

if (status_.rx_ack_ == seq) {// 当前包连续status_.rx_ack_++;// 检查后续包是否连续while (!rx_queue_.empty() && rx_queue_.begin()->first == status_.rx_ack_) {status_.rx_ack_++;}
}

2. 流量动态调节

bool vmux_skt::rx_congestions(int64_t value) {rx_congestions_ += value;if (rx_congestions_ >= max_congestions && status_.rx_acceleration_) {// 减速mux_->post(cmd_acceleration, &FALSE);} else if (rx_congestions_ <= 0 && !status_.rx_acceleration_) {// 加速mux_->post(cmd_acceleration, &TRUE);}
}

3. 跨平台优化

Windows QoS

#if defined(_WIN32)
bool apply_qos(SOCKET sock, const ip_address& ip) {qoss_ = ppp::net::QoSS::New(sock);if (qoss_) {return qoss_->Set(ip, DSCP_AF42);}return false;
}
#endif

Linux 网络保护

#if defined(_LINUX)
bool protect_socket(int fd, ppp::coroutines::YieldContext& y) {if (protector_network) {return protector_network->Protect(fd, y);}return true;
}
#endif

🚀 七、性能优化策略

内存管理：
- 采用**缓冲池（BufferSwapAllocator）**实现高效复用
- 固定大小块，减少内存碎片

make_byte_array(size); // 从缓冲池获取

零拷贝设计：
- 使用shared_ptr传递数据包，避免复制

bool underlyin_sent(const std::shared_ptr<Byte>& packet) {transmission->Write(packet.get(), ...);
}

协程优化：

vmux_spawn(context, strand, [](auto y){// 同步操作
});

🎯 八、应用场景

场景	描述
VNP多路复用	多物理连接承载多个TCP会话，降低连接建立成本
物联网网关	低功耗设备连接管理，心跳维持长连接
游戏服务器	高并发连接处理，低延迟数据传输