socket经验分享：如何实现基于socket的持久层的思路

本文整理于博客园博主美丽人生对socket的持久层的经验分享，如果你也对socket开发感兴趣，可以来看下。

前言

本项目Pixysoft.Framework.Noebe.Sockets，是把数据库的操作用socket暴露出来，实现局域网的调用。

不支持穿越防火墙、不支持局域网-公网链接、不支持路由。

作品完成后，能够通过这个框架，把众多异构数据库链接成一个庞大的数据库池（云？？）

开发过程

第一阶段 自以为是

刚开始，网上搜索了几个socket的局域网聊天的例子，用同步的方法实现的。

链接在这里：http://www.pudn.com/downloads40/sourcecode/p2p/detail138986.html

2天时间我就搞了个prototype，本机调用一点问题都没有。还有点沾沾自喜，以为自己牛逼了，2天搞好了个socket 的服务器。

结果一部署，问题来了。

服务器正在传输数据，但是本地收了10%不到就断了。用thread去等待简直就是放屁，谁知道thread等到什么时候。就算把数据偏移量也传递过去，一样断。

第二阶段 认真对待

一下子受了挫折，开始认真搜索资料。在codeprojects和cnblogs找到了异步socket的例子，特别是NCindy这个非常的好，有个很简单的异步模型例子。于是新的解决方案：

1. 使用异步做服务器

2. 使用自定义的结束符号，例如 \0 \0 。让socket读到才判断结束。这样不用thread去瞎等了。

3. 这个结束符号有可能分割在2次的数据包中，因此判断的时候要进行最近包合并判断。

用异步又花了2天时间搭建了系统，本机跑起来不用thread等待，更加爽了。以为ok了。再部署，又崩了。

传输到服务器的大数据量（5mb左右吧）没有问题，但是接受的时候，服务器会显示客户端断开链接，而客户端仍然在等待。

第三阶段 自我发展

由于客户端不知道链接断了，于是我想到了用双链接去保证，同时实现了一个续传的机制。就是本地发送一个命令：

   RESUME;续传的SOCKETID;偏移量

通知本socket将代替刚才失败的socket，续传。然后用一个心跳链接去检测、一个数据链接去传输。

部署，tnnd，又崩了。当2个链接同时断开的时候，又进入等待。

第四阶段 完成

继续思考，既然有了续传机制，何不自己做一个定时，如果超过这个时间，仍然接受不到数据，自己断开，再续传。

当然，我最讨厌用thread了，直接用异步去做定时。

1. 首先有个统计器，统计传输的频率

2. 异步等待的时间 = 频率*10.

3. 如果异步等待结束，发现刚才的数据仍然没有接收到，自动断开，然后启动续传。

总算完成了！

第五阶段 完成

经过测试，在超级恶劣的环境下（bt/emule/网页/土豆/还有不时断网），能够实现大数据量的稳定传输。