高效稳定完成端口IOCP动态库VC6.0版

#include "fun_iocpsvr.h" #include <stdio.h> char *buffer = "HTTP/1.1 200 OK\r\nContent-Length: 5\r\nConnection: close\r\nContent-Type: text/html\r\n\r\nHello"; //高效稳定的完成端口动态库 // //Powered by ChinaIM.net // //chinaim.net@gmail.com // //2009-6-19 Tfun_iocpsvr *fun_iocpsvr = NULL; //----------------------------------------------------------------- __stdcall Tfun_iocpsvr::Tfun_iocpsvr(char *ip,int port) { m_iocp_obj = NULL; //------------------------------ dll_iocplib = new Tdll_iocplib(); #ifdef _DEBUG dll_iocplib->load_dll_lib(L"iocplibd.dll"); #else dll_iocplib->load_dll_lib(L"iocplib.dll"); #endif //----------------------------------------------- dll_iocplib->load_lib_function(); dll_iocplib->fun_create_iocplib(&m_iocp_obj); m_iocp_obj->start_iocp(ip,port); m_iocp_obj->set_fun_proc((IOCP_ACCEPT)iocp_accept, (IOCP_RECV_MESSAGE)iocp_recv, (IOCP_CLOSE)iocp_close, (void*)this); } //----------------------------------------------------------------- __stdcall Tfun_iocpsvr::~Tfun_iocpsvr() { if(m_iocp_obj) { m_iocp_obj->stop_iocp(); dll_iocplib->fun_delete_iocplib(&m_iocp_obj); } m_iocp_obj = NULL; delete dll_iocplib; dll_iocplib = NULL; } //----------------------------------------------------------------- void __stdcall Tfun_iocpsvr::iocp_accept(tag_iocp_node *user_node,void *param) { Tfun_iocpsvr *m_this = (Tfun_iocpsvr*)param; m_this->fun_accept(user_node); } //----------------------------------------------------------------- void __stdcall Tfun_iocpsvr::iocp_recv(tag_iocp_node *user_node,void *param) { Tfun_iocpsvr *m_this = (Tfun_iocpsvr*)param; m_this->fun_recv(user_node); } //----------------------------------------------------------------- void __stdcall Tfun_iocpsvr::iocp_close(tag_iocp_node *user_node,int close_type,void *param) { Tfun_iocpsvr *m_this = (Tfun_iocpsvr*)param; m_this->fun_close(user_node,close_type); } //----------------------------------------------------------------- //----------------------------------------------------------------- //----------------------------------------------------------------- //----------------------------------------------------------------- void __stdcall Tfun_iocpsvr::fun_accept(tag_iocp_node *user_node) { //连接到来时，同时也有消息需要提取，这是完成端口的与众不同之处之一 char *sock_buf = user_node->szBuffer; int sock_len = user_node->szBuffer_len; //处理实际的socket数据 printf("\n %s len: %d \n",sock_buf,sock_len); m_iocp_obj->send_message(user_node,buffer,strlen(buffer)); static int i_connect_count = 0; i_connect_count ++; //--- printf("\n有连接来了: %lu \n",i_connect_count); } //----------------------------------------------------------------- void __stdcall Tfun_iocpsvr::fun_recv(tag_iocp_node *user_node) { char *sock_buf = user_node->szBuffer; int sock_len = user_node->szBuffer_len; if(sock_len > 0) { //处理实际的socket数据 printf("\n %s \n",sock_buf); m_iocp_obj->send_message(user_node,buffer,strlen(buffer)); } } //----------------------------------------------------------------- void __stdcall Tfun_iocpsvr::fun_close(tag_iocp_node *user_node,int close_type) { //用户节点即将关闭之前发来的调用 static int i_deconnect_count = 0; i_deconnect_count ++; printf("\n有连接关闭: %lu : %d \n",i_deconnect_count, close_type); }