C++ 网络编程(11)服务器逻辑层设计和消息完善
🎯 C++ 网络编程(11)服务器逻辑层设计和消息完善
📅 更新时间：2025年6月7日
🏷️ 标签：C++ | Boost.Asio | 网络编程 | tlv协议 | TCP
文章目录
- 前言
- 一、服务器架构设计
- 二、消息头完善
- 三、MsgNode.h
- 1.代码部分
- 2.代码讲解
- 3.MsgNode中类构造函数实现
- 4.注意点
- 四、Session类改写
- CSession.h
- CSession::Send
- CSession::HandleRead
- 总结
前言
提示：这里可以添加本文要记录的大概内容：
本文概述基于boost::asio实现的服务器逻辑层结构，并且完善之前设计的消息结构。因为为了简化粘包处理，我们简化了发送数据的结构,这次我们给出完整的消息设计，以及服务器架构设计
提示：以下是本篇文章正文内容，下面案例可供参考
一、服务器架构设计
我们接下来要设计的服务器结构是这样的
二、消息头完善
我们这次用一个完整的tlv协议的结果来实现，之前我们只有一个消息长度和消息内容
现在将其完善为如下的样子
为了减少耦合和歧义，我们重新设计消息节点
MsgNode表示消息节点的基类，头部的消息用这个结构存储。
RecvNode表示接收消息的节点。
SendNode表示发送消息的节点。
我们将上述结构定义在MsgNode.h中
三、MsgNode.h
1.代码部分
#pragma once
#include2.代码讲解
我们这里用MsgNode作为基类
然后收发用两个类去实现，因为收信息和发信息都需要数组来存储，所以在基类构造函数中我们new 一个数组
同时收消息，我们只知道消息id和长度，所以构造函数中就是这两个参数
但发信息的时候，我们知道消息id 消息长度 消息首地址，所以有三个参数
同时在构造函数初始化的时候，我们直接把数据长度传给基类中构造即可
3.MsgNode中类构造函数实现
#include "MsgNode.h"
#include"const.h"
RecvNode::RecvNode(short max_len, short msg_id)
:MsgNode(max_len), _msg_id(msg_id)
{
}
SendNode::SendNode(const char* msg, short max_len, short msg_id)
:MsgNode(max_len + HEAD_TOTAL_LEN),_msg_id(msg_id)
{
//id
short msg_id_network =
boost::asio::detail::socket_ops::host_to_network_short(_msg_id);
memcpy(_data, &msg_id_network, HEAD_ID_LEN);
//长度
short msg_len_network =
boost::asio::detail::socket_ops::host_to_network_short(max_len);
memcpy(_data + HEAD_ID_LEN, &msg_len_network, HEAD_DATA_LEN);
//消息体
memcpy(_data + HEAD_TOTAL_LEN, msg, msg_len_network);
}
4.注意点
在发信息的构造函数中，别忘记要对消息id和消息长度转换字节序
//id
short msg_id_network =
boost::asio::detail::socket_ops::host_to_network_short(_msg_id);
//长度
short msg_len_network =
boost::asio::detail::socket_ops::host_to_network_short(max_len);
四、Session类改写
SendNode发送节点构造时，先将id转为网络字节序，然后写入_data数据域。
然后将要发送数据的长度转为大端字节序，写入_data数据域，注意要偏移HEAD_ID_LEN长度。
最后将要发送的数据msg写入_data数据域，注意要偏移
HEAD_ID_LEN+HEAD_DATA_LEN
CSession.h
因为我们这里设置了三个类，不再是第八章的那样全部用一个类MsgNode了
所以我们这里要改一下
std::queue<shared_ptr<SendNode> > _send_que;
std::mutex _send_lock;
//收到的消息结构
std::shared_ptr<RecvNode> _recv_msg_node;
bool _b_head_parse;
//收到的头部结构
std::shared_ptr<MsgNode> _recv_head_node;
分别用SendNode
RecvNode
MsgNode
去表示收发数据和收发数据的头部
CSession::Send
这里在发送的时候我们需要把消息id也传进来
void CSession::Send(char* msg, short max_length, short msgid) {
std::lock_guard<std::mutex> lock(_send_lock);
int send_que_size = _send_que.size();
if (send_que_size > MAX_SENDQUE) {
std::cout << "session: " <<
_uuid << " send que fulled, size is " << MAX_SENDQUE << endl;
return;
}
_send_que.push(make_shared<SendNode>(msg, max_length, msgid));！！！！！！
if (send_que_size>0) {
return;
}
auto& msgnode = _send_que.front();
boost::asio::async_write(_socket, boost::asio::buffer
(msgnode->_data, msgnode->_total_len),
std::bind(&CSession::HandleWrite,
this, std::placeholders::_1, SharedSelf()));
}
基本上和第八章的一样，就改写了这里
_send_que.push(make_shared<SendNode>(msg, max_length, msgid));
CSession::HandleRead
在读数据进行解析的时候，要用以下的片段写法
比如一开始在判断收入数据不足头部大小的时候，记得是4字节，不再是2字节了
因为此时头部包含消息id 消息长度
所以这里用HEAD_TOTAL_LEN而不是HEAD_HEAD_LEN
//收到的数据不足头部大小
if (bytes_transferred + _recv_head_node->_cur_len < HEAD_TOTAL_LEN) {
..........
.........
........
.....
}
然后在调用Send发送回客户端的时候，我们需要对传入的消息id 和 消息长度这两个参数进行转为网络格式
//取id
msg_id = 0;
memcpy(&msg_id, _recv_head_node->_data, HEAD_ID_LEN);
msg_id = boost::asio::detail::socket_ops::host_to_network_short(msg_id);
总结
本文介绍了服务器逻辑和网络层的设计，并且基于这个架构，完善了消息发送结构，下一篇带着大家设计逻辑类和逻辑队列
❤️ 如果你觉得本文对你有帮助，欢迎点赞、评论与收藏。更多 c++ asio网络编程 开发知识，敬请关注后续更新！
