异步模式的socket在connect之后如何知道connect成功还是失败?
代码:
BOOL CAMIClient::Create( CString strServerIP,int nPort )
{
Destroy();
m_strServerIP = strServerIP;
m_nPort = nPort;
while( true )
{
// 创建套接字
m_socket = socket(AF_INET,SOCK_STREAM,0);
if( m_socket == INVALID_SOCKET )
break;
// 设置为非阻塞模式
DWORD ul = 1;
if( 0 != ioctlsocket( m_socket, FIONBIO, &ul) )
break;
// 创建通知监听线程退出的事件句柄
m_wsaSocketClose = WSACreateEvent();
if( m_wsaSocketClose == WSA_INVALID_EVENT )
break;
// 创建监听线程收到消息的事件句柄
m_wsaSocketEvent = WSACreateEvent();
if( m_wsaSocketEvent == WSA_INVALID_EVENT )
break;
// 将UNICODE的IP地址转换为多字节字符的IP地址
char szServerIP[16] = { 0 };
if( WideCharToMultiByte( CP_ACP,0,m_strServerIP,m_strServerIP.GetLength(),szServerIP,sizeof(szServerIP),NULL,NULL ) == 0 )
break;
// 连接指定的IP地址和端口
SOCKADDR_IN sin;
sin.sin_family = AF_INET;
sin.sin_port = htons(m_nPort);
sin.sin_addr.s_addr = inet_addr( szServerIP );
if( ! ( SOCKET_ERROR == connect( m_socket, (SOCKADDR *)&sin, sizeof(sin)) && WSAGetLastError() == WSAEWOULDBLOCK ) )
break;
// 给监听线程的消息到达事件句柄配置要通知的事件类型
if( WSAEventSelect( m_socket,m_wsaSocketEvent,FD_READ|FD_WRITE|FD_CONNECT|FD_CLOSE ) != 0 )
break;
// 创建消息事件监听线程
DWORD dwThreadId;
m_hThreadSocketEvent = CreateThread( NULL, 0, ThreadProc_SocketEvent, this, 0, &dwThreadId );
if( m_hThreadSocketEvent == NULL )
break;
// 创建定时发送心跳包的事件句柄
m_hEventHeartbeat= CreateEvent( NULL,TRUE,FALSE,NULL );
if( m_hEventHeartbeat == NULL )
break;
// 创建定时发送心跳包的线程
m_hThreadHeartbeat = CreateThread( NULL,0,ThreadProc_Heartbeat,this,0, &dwThreadId );
if( m_hThreadHeartbeat == NULL )
break;
// 全部创建成功,返回TRUE
return TRUE;
}
ShowMessage();
Destroy();
return FALSE;
}
// 下面是接收消息事件的线程:
DWORD WINAPI CAMIClient::ThreadProc_SocketEvent( LPVOID lpParameter)
{
CAMIClient * pThis = ( CAMIClient * )lpParameter;
while( true )
{
WSAEVENT wsaEventAry[2] = { WSA_INVALID_EVENT };
wsaEventAry[0] = pThis->m_wsaSocketClose;
wsaEventAry[1] = pThis->m_wsaSocketEvent;
DWORD dwIndex = WSAWaitForMultipleEvents( 2,wsaEventAry,FALSE,WSA_INFINITE,FALSE );
if( WSA_WAIT_FAILED == dwIndex )
continue;
dwIndex = dwIndex - WSA_WAIT_EVENT_0;
if( dwIndex == 0 )
break;
WSANETWORKEVENTS wsaEvents;
if( 0 != WSAEnumNetworkEvents( pThis->m_socket,pThis->m_wsaSocketEvent,&wsaEvents ) )
continue;
if( wsaEvents.lNetworkEvents & FD_READ )
{
if( wsaEvents.iErrorCode[FD_READ_BIT] == 0 )
{
pThis->OnReceiveData();
}
}
else if( wsaEvents.lNetworkEvents & FD_WRITE )
{
if( wsaEvents.iErrorCode[FD_WRITE_BIT] == 0 )
{
CString s;
}
}
else if( wsaEvents.lNetworkEvents & FD_CONNECT )
{
if( wsaEvents.iErrorCode[FD_CONNECT_BIT] == 0 )
{
CString s;
}
}
else if( wsaEvents.lNetworkEvents & FD_CLOSE )
{
if( wsaEvents.iErrorCode[FD_CLOSE_BIT] == 0 )
{
CString s;
}
}
}
return 0L;
}
我的想法是:用户点击登录时显示一个滚动条,等待登录成功或失败,关键是这个异步里面我怎么知道connect成功了还是失败了呢?没有好办法啊!