networking - websocket能保证单条消息的完整性吗?我应该为 websocket 消息实现自己的标头吗?
问题描述
我正在用 C++(使用 boost-beast)为 Web 应用程序编写后端,而前端可能会使用 socket.io。所以这个问题既适用于实现,也适用于 websocket 标准中是否有一些东西可以回答我的问题。
我不确定要采取哪些预防措施来保证消息的完整性。假设客户端发送一条 100 字节长的消息,boost::beast 将消息读取async_read
到multi_buffer
. 我能保证收到全部 100 个字节吗?大概。但是如果消息是 1 MB 怎么办?
为什么我认为这个问题很重要?因为这决定了我的通信协议有多简单。如果只发送和接收完整的消息,那么我不必实现带有决定消息大小的标头的中间件协议(这通常对于 TCP 是必需的,但在某些消息传递库中不是必需的像 ZeroMQ)。但是,如果不能保证消息在到达时是完整的,那么我应该实现一个协议来获取消息大小。类似(最简单的):6 个字节,包含消息大小 + 消息。然后我将其作为 FIFO 队列读取以处理消息的大小,然后读取消息。
我以错误的方式接近 websocket 吗?请指教。
解决方案
是的,这个问题很重要。
幸运的是,答案很简单:websocket 不像 TCP 那样基于流的协议,它是基于消息的。
RFC包括下图
+-+-+-+-+-------+-+-------------+-------------------------------+
0 1 2 3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-------+-+-------------+-------------------------------+
|F|R|R|R| opcode|M| Payload len | Extended payload length |
|I|S|S|S| (4) |A| (7) | (16/64) |
|N|V|V|V| |S| | (if payload len==126/127) |
| |1|2|3| |K| | |
+-+-+-+-+-------+-+-------------+ - - - - - - - - - - - - - - - +
| Extended payload length continued, if payload len == 127 |
+ - - - - - - - - - - - - - - - +-------------------------------+
| | Masking-key, if MASK set to 1 |
+-------------------------------+-------------------------------+
| Masking-key (continued) | Payload Data |
+-------------------------------- - - - - - - - - - - - - - - - +
: Payload Data continued ... :
+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +
| Payload Data continued ... |
+---------------------------------------------------------------+
所以框架是 websocket 协议的一部分。如果你想了解它的细节,我认为这看起来像是一个很好的背景资料:http: //lucumr.pocoo.org/2012/9/24/websockets-101/
但是,在实践中,您将使用更高级别的 Websockets 库并使用它。
推荐阅读
- r - R 复制文件的文件名是 %in% 的列表
- angular - DevExtreme devexpress 从图表角度 8 创建图像
- javascript - 邮递员请求有效,但我的 React 请求无效。我的错在哪里
- arduino - Arduino analogWrite() 导致程序冻结
- c# - 请求被中止:未能创建 SSL/TLS 安全通道
- python - ClickHouse - 是否有可能通过 JOIN 查询 Jupyter Notebook 中的 DataFrame?
- python - 为什么列表在 Python 的函数中被修改?
- audiounit - 基于 AVAudioUnitSampler 的 AUv3 扩展未注册
- python - 当我尝试将用户上传的图像保存在视图中时,为什么 ImageField 中的 upload_to 根本不起作用
- angular - 如何在角度 10 中自动重置输入值(formGroup)?