我封装的一个完成端口类

yahle

下面的是基本的使用方法

struct TSession
{
        SOCKET socket;
        int id;
};

class myIocp:public CIOCP
{
public:
        void OnRead(void * p, char * buf, int len);
        void OnAccept(SOCKET socket);
        void OnClose(void * p);
};

void myIocp::OnAccept(SOCKET socket)
{

        TSession *s = new TSession;
        s->socket = socket;
//这里可以对连接的session进行自己的操作，例如给id找一个唯一的值
        SetIoCompletionPort(socket, s)        //        使连接socket与一个自定义结构体关联
}

void myIocp::OnRead(void * p, char * buf, int len)
{
        TSession *s  = (TSession *)p;
        send(s->socket, buf, len, 0);        //        这里只是简单的把收到的消息返回给客户端
...
}

void myIocp::OnClose(void * p)
{
        delete p;
}


myIoncp iocp;
main()
{
        ...
        iocp.listen(4311);                //        开始监听网络端口，等待客户端连接
        ...
}

component

不错， 正在学习中..........................

component

但是我不会使用，能不能把使用它的例子也传上来呢？谢谢！！！

homeway9916

发送代码了？

moonwellatg4

不错

phevos

研究中,我正准备把完成IO类封装到C++Builder里面

TaoshaGod

支持。顶

cn_zhangJW

建议作者可以考虑，抽象自己的概念。
改的更简捷些。

这样和直接用完成端口实际差别不大。

封装一个可重用的库，一定要体现它重用的意义—— 学习简单，开发高效。

moonwellatg4

1,没有封装发送的接口.

如果用户自己调用WSASend()的话,将会无法回收使用WSASend()需要创建的Buffer.

2,另外,应该加上'分包','粘包'处理的代码.

可以这么做: void OnRead() 改成 int OnRead(). 每次OnRead()返回剩余的字节数.
假设收到了1000字节的数据包,其中的800字节属于第一个数据包(逻辑上的数据包,或者叫做指令),第二个数据包的长度为500.
这时,OnRead()返回200,接着在底层(封装的类)把最后200的数据copy到buffer最前面,然后在下一个WSARecv()时候,从偏移量为200的地方开始接收,最后在下一次OnRead()时候返回整个的剩余数据包.