运行环境:win2000 Professional SP4
VC6无SP
ODBC连接数据库大致如下:
写了一个控件台程序即作为Client,同时也是一个Server
在main函数中首先启动一个Client线程,该线程连接其它的服务器,如果发现连接不上时就sleep一下,然后继续连接,然后在main函数中建立了一个监听的socket,每当有一个连接进来时就启动一个新的子线程提供连接服务,在整个程序中不断的将结果通过printf函数进行输出,但是我发现过一段时间就没有输出了,然后我按CTRL + C发现又可以输出了,怎么会这样呢?BOOL InitClientSocket( SOCKET& client, struct sockaddr_in& addrServer)
{
client = socket( AF_INET, SOCK_STREAM, NULL );
if ( INVALID_SOCKET == client )
{
printf( "%s\r\n", "创建下行的短信socket失败" );
return FALSE;
}

CIniFile IniFile;
CString strSMSSvrIP;
CString strSMSSvrPort;
IniFile.GetProfileString( "SMSSvrIP", strSMSSvrIP );
IniFile.GetProfileString( "SMSSvrPort", strSMSSvrPort );

if ( strSMSSvrIP.IsEmpty() )
{
printf( "%s\r\n", "在配置文件中配置的短信服务器地址为空!" );
return FALSE;
}

if ( strSMSSvrPort.IsEmpty() )
{
printf( "%s\r\n", "在配置文件中配置的短信服务器端口为空!" );
return FALSE;
}

printf( "%s\r\n", CString("短信服务器地址: ") + strSMSSvrIP + "  端口: " + strSMSSvrPort );

sockaddr_in addr;
addr.sin_family = AF_INET;
addr.sin_port = htons( NULL );
addr.sin_addr.S_un.S_addr = INADDR_ANY;

if ( SOCKET_ERROR == bind( client, (sockaddr*)&addr, sizeof( addr ) ) )
{
printf( "%s\r\n", "绑定下行的短信socket失败!" );
return FALSE;
}

addrServer.sin_family = AF_INET;
addrServer.sin_port = htons( atoi( strSMSSvrPort ) );
addrServer.sin_addr.S_un.S_addr = inet_addr( strSMSSvrIP ); return TRUE;
}
//该线程进行下行操作,如下发广告等,其作为客户端存在
DWORD WINAPI ClientThread( LPVOID lpParameter )
{
CSMSParser SMSParser;
SOCKET client;
struct sockaddr_in addrServer;
while ( true )
{
closesocket( client );
if ( !InitClientSocket( client, addrServer ) )
{
return 0;
}
if ( SOCKET_ERROR == connect( client, (sockaddr*)&addrServer, sizeof( addrServer ) ) )
{
for ( int i = 0; i < 100000; i++ )
{
printf( "%s\r\n", "连接短信服务器失败,sleep 30秒!" );
}
// Sleep( 3 * 1000 );
continue;
} structClient* pstruClient = new structClient;
memset( pstruClient, 0, sizeof( structClient ) );
pstruClient->m_sock = client;
pstruClient->m_TimeLastEcho = COleDateTime::GetCurrentTime();
g_CLientArr.Add( pstruClient );//注意这里要添加进去,因为在登录时需要填入SessionID if ( !SMSParser.LoginSMSServer( client ) )
{
printf( "%s\r\n", "登录短信服务器失败,sleep 30秒!" );
// Sleep( 3 * 1000 );
g_CLientArr.Remove( pstruClient->m_sock );//登录失败时需要将其清除
continue;
}

while ( SMSParser.SendMsgReq( client ) )
{
Sleep( 500 );
}
g_CLientArr.Remove( pstruClient->m_sock );
}
return NULL;
}int _tmain(int argc, TCHAR* argv[], TCHAR* envp[])
{
int nRetCode = 0;
if (!AfxWinInit(::GetModuleHandle(NULL), NULL, ::GetCommandLine(), 0))
{
// TODO: change error code to suit your needs
cerr << _T("Fatal Error: MFC initialization failed") << endl;
nRetCode = 1;
}
else
{
WSADATA wsaData;
if(::WSAStartup(0x202,&wsaData)!=0)
{
printf("\nError in Startup session.\n");
WSACleanup();
return -1;
}

SOCKET server = socket( PF_INET, SOCK_STREAM, NULL );
if ( INVALID_SOCKET == server )
{
printf("创建监听套接字失败,请检查网络连接是否正常!\n");
return -1;
}

if ( argc == 1 )
{
printf("在启动可执行文件时请输入要绑定的端口号: 如sms.exe 80\n");
getchar();
return -1;
}

sockaddr_in addr_server;
addr_server.sin_addr.S_un.S_addr = INADDR_ANY; UINT uListenPort;
CIniFile IniFile;
IniFile.GetProfileInt( "ListenPort", uListenPort ); addr_server.sin_port = htons( uListenPort );
addr_server.sin_family = AF_INET;
if ( SOCKET_ERROR == bind( server, (sockaddr*)&addr_server, sizeof(addr_server) ) )
{
printf("监听线程绑定到指定端口失败,请检查是否已有一个服务器程序正在运行!\n");
goto EXIT;
}

if ( SOCKET_ERROR == listen( server, 10 ) )
{
printf("调用监听线程函数listen失败!\n");
goto EXIT;
}

printf( "服务器启动成功,正在监听%d端口...\r\n", atoi( argv[ 1 ] ) );

//创建线程,用于监视是否是有效连接,对连接进行定时检验
DWORD dwCheckThreadID;
CreateThread( NULL, 8 * 1024, CheckSysBeatThread, NULL, NULL, &dwCheckThreadID );

//创建下行线程,如下发广告等工作
DWORD dwClientThreadID;
CreateThread( NULL, 8 * 1024, ClientThread, NULL, NULL, &dwClientThreadID ); while ( TRUE )
{
SOCKET client;
sockaddr_in addr_client;
int nAddrLen = sizeof(addr_client);
if ( ( client = accept( server, (sockaddr*)&addr_client, &nAddrLen ) ) == INVALID_SOCKET )
{
goto EXIT;
}

structClient* pstruClient = new structClient;
memset( pstruClient, 0, sizeof( structClient ) );
pstruClient->m_sock = client;
pstruClient->m_TimeLastEcho = COleDateTime::GetCurrentTime();
sprintf( (char*)(pstruClient->m_ucLoginPort), "%d", ntohs( addr_client.sin_port ) );

struct in_addr addr;
addr.S_un.S_addr = addr_client.sin_addr.S_un.S_addr;
char* pAddr = inet_ntoa( addr );
strcpy( (char*)pstruClient->m_ucLoginIP, pAddr );
g_CLientArr.Add( pstruClient ); DWORD dwThreadID;
HANDLE hThread = CreateThread( NULL, 8 * 1024, ServerThread, pstruClient, NULL, &dwThreadID );
CloseHandle( hThread );
}

EXIT:
closesocket( server );
} return nRetCode;
}

解决方案 »

  1.   

    里面的 for ( int i = 0; i < 100000; i++ )是我后来随便加上测试的
      

  2.   

    if ( SOCKET_ERROR == connect( client, (sockaddr*)&addrServer, sizeof( addrServer ) ) )
    {
    for ( int i = 0; i < 100000; i++ )
    {
    printf( "%s\r\n", "连接短信服务器失败,sleep 30秒!" );
    }
    // Sleep( 3 * 1000 );
    continue;
    }----------------------------------------------------------------这里有可能出现阻塞