以前学过mfc,我用过的它里面的包装winsock的两个类csocket和casyncsocket,我一直觉得它哪个事件通知的功能比较不错，特别是在连接的两方收发数据没有一定的规律的时候比较有用，虽然不用它的事件通知也可以实现功能，但是你需要循环检测套接字的状态或者阻塞等待，如果每次都要做这些琐碎的工作岂不是很麻烦，于是我就想对这些功能作一次封装。当然在.net里面采用delegate和event是最好的选择了。下面就是我实现的一些细节：
先讲一下思路：其实这个还是很简单了，估计高手们会不屑一顾了^_^。当套接字开始工作，比如开始监听、开始连接的时候，启动一个线程不停的检测套接字的状态，当某一事件的状态条件满足时就触发此事件，要知道具体检测套接字状态的方法，请往下看。
平常用套接字编成的时候可能需要用到的功能就是：连接成功或者失败的通知、在监听的套接字上有挂起的连接的通知、有数据可以接受的通知、套接字关闭的通知、还有套接字空闲可以发送数据的通知等，我也就使对上面几个功能作了封装，不过我觉得最后面一个功能用处不大???
我的socket类是从system.net.sockets.socket继承下来的，类名tcpeventsocket,实现如下：
先申明事件的委托类型，具体看代码
public delegate void acceptconnectionhandler();
public delegate void connectcompletedhandler(bool connected); //connected表明连接成功与否
public delegate void datacansendhandler();
public delegate void datacanreceivehandler(int buffersize); //当前可以接受的数据量
public delegate void socketclosedhandler();
这些类型具体什么意思应该能看出来吧，另外还要申明对应的事件
public event acceptconnectionhandler acceptconnection;
public event connectcompletedhandler connectcompleted;
public event datacansendhandler datacansend;
public event datacanreceivehandler datacanreceive;
public event socketclosedhandler socketclosed;
另外加了几个虚方法，这几个方法用来触发事件
protected virtual void onacceptconnection();
protected virtual void onconnectcompleted(bool connected)
protected virtual void ondatacansend()
protected virtual void ondatacanreceive(int buffersize)
protected virtual void onsocketclosed()
为了在适当的事机启动检测线程，我重写了几个基类的方法：
new public void listen(int backlog)
{
base.listen(backlog);
sockstate = socketstate.listenning;
if (!checkthread.isalive)
checkthread.start();
}
new public void connect(endpoint remoteep)
{
try
{
base.connect(remoteep);
this.blocking = false; //设置非阻塞状态，以便事件通知的效率
if (!checkthread.isalive)
checkthread.start();
}
catch(socketexception)
{
onconnectcompleted(false);
}
}
这两个方法实际编成中都应该首先被调用的，所以有他们启动检测线程比较合适，另外线程启动了必然也要中止，于是我重写了close方法
new public void close()
{
if(checkthread.isalive) //先中止线程再关闭连接
checkthread.abort();
base.close();
sockstate = socketstate.disconnected;
onsocketclosed();
}
于是剩下的工作就是怎么检测套接字了，socket类有个select的静态方法，它可以检测很多套接字的状态，不过这里只需要检测一个，所以直接用socket的poll方法，poll的具体用法可以看msdn，我这里用代码说明我对套接字的检测方法
while(true) //循环检查
{
if (sockstate == socketstate.disconnected) //如果当前没有连接
{
if (poll(500, selectmode.selectwrite))
onconnectcompleted(true); //如果为可写状态，则表示连接成功
}
else if(sockstate == socketstate.listenning)
{
if (poll(500, selectmode.selectread)) //如果在监听状态发现套接字有数据可读则表示已经有人连接上来可以调用accept接受连接
onacceptconnection();
}
else //这里sockstate = socketstate.connected
{
if (poll(500, selectmode.selectwrite)) //如果有可写状态则表示可以发送数据
ondatacansend();
if (poll(500, selectmode.selectread)) //如果有可读状态
{
if (available > 0) //如果有数据可读表示可以调用receive接受数据
ondatacanreceive(available);
else
{
onsocketclosed(); //没数据可读表示连接已经关闭
break;
}
}
}
//如果没有连接并且有错误状态，则连接失败
if (sockstate == socketstate.disconnected && poll(500, selectmode.selecterror))
onconnectcompleted(false);
}
这里的onxxx方法就是执行事件通知的方法，并且派生类中可以重载这些方法直接获得事件通知而不需要挂界别的事件通知处理函数(类似于mfc的onaccept等虚函数)。不过派生的函数集的调用基类的相应方法哦。很可惜没有重写socket.accept方法，让它返回一个tcpeventsocket,这样应该就比较完整了，只可惜我不知道怎么做^_^,如果谁知道的话欢迎指教。
事件通知机制已经基本完成，所缺乏的只是大量的测试（我做了几下最简单的测试，惭愧！！^_^）
如果有问题请联系 yzx110@bit.edu.cn
如对本文有疑问，
点击进行留言回复！！
我要评论
网友评论