CAsyncSocket不触发事件？ [英] CAsyncSocket not firing events?
问题描述
class ClientSocket：public CAsyncSocket
{
//这个套接字发送数据回到backSocket，它指向这个只有
//测试，但是它也可以发送数据到其他套接字。
ClientSocket * backSocket;
//将一些数据存储在backupData中，直到建立连接。
StringBuilder * backupData;
public：
virtual void OnClose（int）;
virtual void OnReceive（int）;
ClientSocket（void）;
bool ConnectToBACK（）;
virtual〜ClientSocket（void）;
};
ClientSocket :: ClientSocket（void）
{
// DONOT运行回来！否则递归调用。
backSocket = NULL;
backupData = NULL;
}
bool ClientSocket :: ConnectToBACK（）
{
if（this-> backSocket！= NULL）
return true;
//仅用于调试:)
this-> backSocket = this;
返回true;
}
ClientSocket ::〜ClientSocket（void）
{
this-> Close（）;
if（this-> backSocket）
{
this-> backSocket-> Close（）;
删除this-> backSocket;
this-> backSocket = NULL;
}
}
void ClientSocket :: OnClose（int nErrorCode）
{
if（this-> backSocket！= NULL）
{
this-> backSocket-> Close（）;
}
CAsyncSocket :: OnClose（nErrorCode）;
}
void ClientSocket :: OnReceive（int nErrorCode）
{
if（nErrorCode == 0）
{
char * buffer = new char [2049];
int bufLen = sizeof（buffer）/ sizeof（buffer [0]）;
int received = this-> Receive（buffer，bufLen-1，0）;
if（received == SOCKET_ERROR）
{
return;
}
if（this-> ConnectToback（））
{
if（backupData）
{
int backupLen;
char * backup = backupData-> ToString（& backupLen）;
this-> backSocket->发送（backup，backupLen）;
删除backupData;
删除[]备份;
backupData = NULL;
}
this-> backSocket-> Send（buffer，received）;
删除缓冲区;
}
else
{
if（backupData == NULL）
{
backupData = new StringBuilder（）;
}
backupData-> Insert（buffer，received）;
}
}
CAsyncSocket :: OnReceive（nErrorCode）;
}
我没有关联任何GUI，因为我认为这将是好的因为没有开销。
我不需要它。我还在main中完成了AfxSocketIback（），并从一个线程开始了另一个ListeningSocket。
netstat -a在ListeningSocket端口显示正确的绑定，状态为Listening
// ListeningSocket继承公共CAsyncSocket
void ListeningSocket :: OnAccept（int nErrorCode ）
{
#ifdef DEBUG
std :: cout<<<< \\\
接受代理服务器:);
#endif
if（nErrorCode == 0）
{
ClientSocket * FromCliet = new ClientSocket（）;
FromCliet-> value = 100;
if（this-> Accept（* FromCliet，NULL，NULL））
{
//连接只有ClientSocket *客户端
连接*连接=新连接（FromCliet） ;
//一个列表< Connection *>存储在ListeningSocket
this-> clients.push_front（连接）;
}
else
{
std :: cerr<<< \\\
无法接受客户端的连接;
}
}
CAsyncSocket :: OnAccept（nErrorCode）;
}
当将Brakepoints放在ListenSocket :: OnAccept中时，它永远不会来到这里。 p>
编辑：
static DWORD WINAPI StartListening（LPVOID param）
{
ListeningSocket * app =（ListeningSocket *）param;
if（false == app-> Create（7897，SOCK_STREAM，31，127.0.0.1）
{
std :: cerr<< \无法创建\bind到端口;
删除应用程序;
return -1;
}
if（false == app-> Listen（））
{
std :: cerr<< \不听
app-> Close（）;
删除应用程序;
return -1;
}
return 0;
}
int ListeningSocket :: Start（）
{
if（NULL == CreateThread（NULL，0，StartListening，（LPVOID）this，0，NULL ））
{
return -1;
}
return 0;
}
我没有像MFC Wizard解决方案那样。我有简单的项目和main（）。
我的ListeningSocket类是Singletone类：
class ListeningSocket：public CAsyncSocket
{
private：
static ListeningSocket * ListeningSocket;
std :: list< Connection *>客户;
ListeningSocket（void）;
public：
//覆盖
virtual void OnAccept（int）;
virtual void OnClose（int）;
static ListeningSocket * GetListeningSocket（）;
virtual〜ListeningSocket（void）;
virtual void Close（）;
int Start（void）;
};
CAsyncSocket类内部使用Windows消息来触发事件。您需要在具有消息循环的线程中创建CAsyncSocket派生类。在这种情况下，事件将被调用。伪代码：
//此函数运行在工作线程
的上下文void MyClass :: ThreadFunction（）
{
mySocket.Create（...）; //创建CAsyncSocket派生类
//运行消息循环。
BOOL bRes = FALSE;
MSG msg;
while（（bRes = GetMessage（& msg，NULL，0，0））！= 0）
{
if（bRes == -1）
{
break;
}
else
{
TranslateMessage（& msg）;
DispatchMessage（& msg）;
}
}
}
要停止此线程，请使用PostQuitMessage功能。
修改。
我没有发布所有的多线程细节，假设你熟悉它们。通常，CreateThread需要全局函数作为参数（或类静态函数）。要调用常规类方法，使用this作为CreateThread参数，将其作为void *传递给全局线程函数。将其转换回类指针并调用常规类方法。
i have implemented my ClientSocket class from CAsyncSocket:
class ClientSocket : public CAsyncSocket
{
// this socket sends data back to "backSocket" which points to this only for
// testing but it can send data to other sockets like that too.
ClientSocket * backSocket;
// store some data in backupData untill connection is established.
StringBuilder * backupData;
public:
virtual void OnClose(int);
virtual void OnReceive(int);
ClientSocket(void);
bool ConnectToBACK();
virtual ~ClientSocket(void);
};
ClientSocket::ClientSocket(void)
{
// DONOT run to back !!! recursive calls otherwise.
backSocket = NULL;
backupData = NULL;
}
bool ClientSocket::ConnectToBACK()
{
if(this->backSocket != NULL)
return true;
// just for debugging :)
this->backSocket = this;
return true;
}
ClientSocket::~ClientSocket(void)
{
this->Close();
if(this->backSocket)
{
this->backSocket->Close();
delete this->backSocket;
this->backSocket = NULL;
}
}
void ClientSocket::OnClose(int nErrorCode)
{
if(this->backSocket != NULL)
{
this->backSocket->Close();
}
CAsyncSocket::OnClose(nErrorCode);
}
void ClientSocket::OnReceive(int nErrorCode)
{
if(nErrorCode == 0)
{
char *buffer = new char[2049];
int bufLen = sizeof(buffer)/sizeof(buffer[0]);
int received = this->Receive(buffer, bufLen-1, 0);
if(received == SOCKET_ERROR)
{
return ;
}
if(this->ConnectToback())
{
if(backupData)
{
int backupLen;
char *backup = backupData->ToString(&backupLen);
this->backSocket->Send(backup, backupLen);
delete backupData;
delete [] backup;
backupData = NULL;
}
this->backSocket->Send(buffer, received);
delete buffer;
}
else
{
if(backupData == NULL)
{
backupData = new StringBuilder();
}
backupData->Insert(buffer, received);
}
}
CAsyncSocket::OnReceive(nErrorCode);
}
I have not associated any GUI to this as i thought that it would be good for no overheads. I donot require it. I have also done AfxSocketIback() in main and from a thread started another ListeningSocket .
netstat -a shows proper binding at the port of ListeningSocket and status as Listening
// ListeningSocket inherits public CAsyncSocket
void ListeningSocket::OnAccept(int nErrorCode)
{
#ifdef DEBUG
std::cout << "\nOnAccepting Proxy Server :)";
#endif
if(nErrorCode == 0)
{
ClientSocket *FromCliet = new ClientSocket();
FromCliet->value = 100;
if(this->Accept(*FromCliet, NULL, NULL))
{
// Connection just has ClientSocket * client
Connection * connection = new Connection(FromCliet);
// a list<Connection *> is stored in ListeningSocket
this->clients.push_front(connection);
}
else
{
std::cerr << "\nFailed to accept connection from Client";
}
}
CAsyncSocket::OnAccept(nErrorCode);
}
When putting brakepoints in ListenSocket::OnAccept, it never comes here.
EDIT:
static DWORD WINAPI StartListening(LPVOID param)
{
ListeningSocket *app = (ListeningSocket *)param;
if(false == app->Create(7897, SOCK_STREAM, 31, "127.0.0.1"))
{
std::cerr << "\nCould not create\bind to port";
delete app;
return -1;
}
if(false == app->Listen())
{
std::cerr << "\nCould not listen";
app->Close();
delete app;
return -1;
}
return 0;
}
int ListeningSocket::Start()
{
if(NULL == CreateThread(NULL,0, StartListening, (LPVOID)this,0, NULL))
{
return -1;
}
return 0;
}
I have NOT made it like MFC Wizard solution. I have simple project and main().
My ListeningSocket Class is Singletone Class:
class ListeningSocket : public CAsyncSocket
{
private:
static ListeningSocket * ListeningSocket;
std::list<Connection *> clients;
ListeningSocket(void);
public:
// overrides
virtual void OnAccept(int);
virtual void OnClose(int);
static ListeningSocket * GetListeningSocket();
virtual ~ListeningSocket(void);
virtual void Close();
int Start(void);
};
CAsyncSocket class internally uses Windows messages for firing events. You need to create CAsyncSocket-derived class in a thread with message loop. In this case events will be called. Pseudo-code:
// This function runs in the context of worker thread
void MyClass::ThreadFunction()
{
mySocket.Create(...); // creating CAsyncSocket-derived class
// Run message loop.
BOOL bRes = FALSE;
MSG msg;
while((bRes = GetMessage( &msg, NULL, 0, 0 )) != 0)
{
if (bRes == -1)
{
break;
}
else
{
TranslateMessage(&msg);
DispatchMessage(&msg);
}
}
}
To stop this thread, use PostQuitMessage function.
Edit. I didn't post all multi-threading details, assuming that you are familiar with them. Generally, CreateThread requires global function as parameter (or class static function). To call regular class method, use "this" as CreateThread parameter, which is passed as void* to global thread function. Cast it back to the class pointer and call regular class method.
这篇关于CAsyncSocket不触发事件？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！
