沈阳营销型网站制作,网站建设的十点优势,网址大全你懂的,logo怎么注册源起
以前就知道套接字有可能出现部分发送成功的可能#xff0c;直到近段时间一个典型的使用场景触发了明确的此问题#xff0c;才予以重视#xff0c;比较深入地考虑解决这个问题的方案#xff01;
分析
因为TCP的流式特征#xff0c;如果出现部分发送成功#xff0c…源起
以前就知道套接字有可能出现部分发送成功的可能直到近段时间一个典型的使用场景触发了明确的此问题才予以重视比较深入地考虑解决这个问题的方案
分析
因为TCP的流式特征如果出现部分发送成功则剩余的部分数据也应该被发送出去以利于对端正确处理消息。
如果抛弃了剩余部分继续发送新的发送请求则对端有可能无法正确处理特别是解码带有边界特征的命令消息时不能随便出现流中的间隙
正确解决之道
缓存剩余部分数据在剩余部分未发送出去的情况下明确拒绝下次发送请求或设计一定的缓冲新发送请求的能力侦测TCP套接字的可写时机实时发送剩余部分数据 注意在TCP套接字重新可写能够被write后发送剩余部分依然可能出现剩余 有局限性的对端缓解之道
在对于TCP流式传输的数据特别在含有消息边界的业务中TCP对端尝试多次后依然无法解码数据则可以采用抛弃已缓存读取数据的策略。
因为TCP命令消息输入不可能很频繁在间歇报文信令间抛弃脏数据很有可能在后期处理就可以恢复正常
多说几句
简单的网络套接字编程在部分发送成功的处理上并不简单比较耗代码
参考
man 2 write Such partial writes can occur for various reasons; for example, because there was insufficient space on the disk device to write all of the requested bytes, or because a blocked write() to a socket, pipe, or similar was interrupted by a signal handler after it had transferred some, but before it had transferred all of the requested bytes. In the event of a partial write, the caller can make another write() call to transfer the remaining bytes. The subsequent call will either transfer further bytes or may result in an error (e.g., if the disk is now full) 重点几个错误码可能部分发送成功的场景
EAGAINEWOULDBLOCKEINTR ACE框架下的解决之道
仅ACE_Message_Block组成的链表
利用ACE_Message_Block自身的链表能力组成弹性的发送请求队列然后从队头逐个处理发送请求遇到部分发送成功则修改当前发送ACE_Message_Block读指针rd_ptr(hasSendNum)并不从队列中删除。
ACE_Message_Queue
使用ACE_Message_Queue依然可以形成弹性的发送请求队列而且具备同步策略定制能力。需要在发送时使用peek_dequeue_head接口获取队头引用但并不从链表中删除发送完整成功后再调用dequeue_head删除队头。
次之建议
ACE框架的TCP套接字提供了send_n接口保证发送n个字节数据或成功或出现终态错误。 虽然接口看似简单但是源码的解决办法还是有点ugly建议在非常关键的心跳、握手场景中使用并尽量不用之 最次建议
使用同步阻塞IO低效的同时依然存在概率比较小但仍然存在的中断情况下的部分发送成功
结束语 解决思路的关键是保留宏观上的TCP流式数据特点逐次发送直至成功或最终的失败释放连接并重新建链
