16,551
社区成员
发帖
与我相关
我的任务
分享Socket 编程，recv接收数据时，如何判断有数据？？？
我在做SOCKET编程时，用的是socket，在线程中接收数据，用的是recv函数，如果服务端没有给客户端发送数据，程序就停在recv处，如何在recv前判断是否有数据？？？
...全文
请发表友善的回复…
发表回复
mryinliang 2002-09-04
- 打赏
- 举报
可以用select函数检查
czy412 2002-09-04
- 打赏
- 举报
同意楼上!
everandforever 2002-09-04
- 打赏
- 举报
应该用消息驱动的啊，有数据来了，系统通知，然后去收。
liuyup 2002-09-04
- 打赏
- 举报
gz
xiaotian2000 2002-09-04
- 打赏
- 举报
1.const int WM_SERVER_ACCEPT = WM_USER+101;
const int WM_CLIENT_CLOSE = WM_USER+102;
const int WM_CLIENT_READ = WM_USER+103;
const int WM_CLIENT_READCLOSE=WM_USER+105;
2.LRESULT CServerDlg::OnServerAccept(WPARAM wParam, LPARAM lParam)
{
int iErrorCode;
int nLength = sizeof(SOCKADDR);
int i;
iErrorCode=0;
SOCKADDR_IN sockAddr;
sockAddr.sin_family=AF_INET;
sockAddr.sin_port=htons(5000);
sockAddr.sin_addr.S_un.S_addr=INADDR_ANY;
if (WSAGETSELECTERROR(lParam))
{
m_staticmsg.SetWindowText("Error detected on entry into OnServerAccept.");
return 0L;
}
if (WSAGETSELECTEVENT(lParam) == FD_ACCEPT)
{
for(i=0;(i<MAXClient)&&(m_aClientSocket[i]!=INVALID_SOCKET);i++);
if(i==MAXClient)
{
m_staticmsg.SetWindowText("not empty m_ClientSock!\n");
return 0L;//not empty m_ClientSock;
}
m_staticmsg.SetWindowText("One Client is Connecting!\n");
m_aClientSocket[i] = accept(m_hSocket, (LPSOCKADDR)&sockAddr, (LPINT)&nLength);
if (m_aClientSocket[i] == INVALID_SOCKET)
{
m_staticmsg.SetWindowText("Server socket failed to accept connection.");
return 0L;
}
CString csDottedDecimal = "ONE CLIENT CONNECTED to ";
csDottedDecimal += inet_ntoa(sockAddr.sin_addr);
// m_pDoc->SetTitle(csDottedDecimal);
csDottedDecimal += "\n";
m_staticmsg.SetWindowText("==>>"+csDottedDecimal);
WSAAsyncSelect(m_aClientSocket[i],m_hWnd,WM_CLIENT_READCLOSE,FD_READ|FD_CLOSE);
CString csText = "Connected to Server";
LPSTR lpszResponse = csText.GetBuffer(1000);
// iErrorCode = send( m_aClientSocket[i], lpszResponse, lstrlen(lpszResponse), NO_FLAGS);
if (iErrorCode == SOCKET_ERROR)
m_staticmsg.SetWindowText("Error sending response to client.");
//else
// PrintString("Response sent!\n");
//OnClientClose();
}
return 0L;
}
3.LRESULT CServerDlg::OnSocketRead(WPARAM wParam, LPARAM lParam)
{
int iBytesRead;
int iBufferLength;
int iEnd;
int iSpaceRemaining;
char chIncomingDataBuffer[1024];
CString str;
int i;
for(i=0;(i<MAXClient)&&(m_aClientSocket[i]!=wParam);i++)
{
}
if(i==MAXClient) return 0L;
iBufferLength = iSpaceRemaining = sizeof(chIncomingDataBuffer);
iEnd = 0;
iSpaceRemaining -= iEnd;
iBytesRead = recv(m_aClientSocket[i], (LPSTR)(chIncomingDataBuffer+iEnd), iSpaceRemaining, 0);
iEnd+=iBytesRead;
if (iBytesRead == SOCKET_ERROR)
m_staticmsg.SetWindowText("OnClientRead recv reported a socket error. ");
chIncomingDataBuffer[iEnd] = '\0';
if (lstrlen(chIncomingDataBuffer) != 0)
{
m_recevmsg[i]=chIncomingDataBuffer;
//分析收到包,如果格式不对,错包数加1
//if (chIncomingDataBuffer[1]!="1")
// m_erropage[i]++;
//********
}
m_recevpage[i]++;
return(0L);
}
需要更全的代码请和我联系!
const int WM_CLIENT_CLOSE = WM_USER+102;
const int WM_CLIENT_READ = WM_USER+103;
const int WM_CLIENT_READCLOSE=WM_USER+105;
2.LRESULT CServerDlg::OnServerAccept(WPARAM wParam, LPARAM lParam)
{
int iErrorCode;
int nLength = sizeof(SOCKADDR);
int i;
iErrorCode=0;
SOCKADDR_IN sockAddr;
sockAddr.sin_family=AF_INET;
sockAddr.sin_port=htons(5000);
sockAddr.sin_addr.S_un.S_addr=INADDR_ANY;
if (WSAGETSELECTERROR(lParam))
{
m_staticmsg.SetWindowText("Error detected on entry into OnServerAccept.");
return 0L;
}
if (WSAGETSELECTEVENT(lParam) == FD_ACCEPT)
{
for(i=0;(i<MAXClient)&&(m_aClientSocket[i]!=INVALID_SOCKET);i++);
if(i==MAXClient)
{
m_staticmsg.SetWindowText("not empty m_ClientSock!\n");
return 0L;//not empty m_ClientSock;
}
m_staticmsg.SetWindowText("One Client is Connecting!\n");
m_aClientSocket[i] = accept(m_hSocket, (LPSOCKADDR)&sockAddr, (LPINT)&nLength);
if (m_aClientSocket[i] == INVALID_SOCKET)
{
m_staticmsg.SetWindowText("Server socket failed to accept connection.");
return 0L;
}
CString csDottedDecimal = "ONE CLIENT CONNECTED to ";
csDottedDecimal += inet_ntoa(sockAddr.sin_addr);
// m_pDoc->SetTitle(csDottedDecimal);
csDottedDecimal += "\n";
m_staticmsg.SetWindowText("==>>"+csDottedDecimal);
WSAAsyncSelect(m_aClientSocket[i],m_hWnd,WM_CLIENT_READCLOSE,FD_READ|FD_CLOSE);
CString csText = "Connected to Server";
LPSTR lpszResponse = csText.GetBuffer(1000);
// iErrorCode = send( m_aClientSocket[i], lpszResponse, lstrlen(lpszResponse), NO_FLAGS);
if (iErrorCode == SOCKET_ERROR)
m_staticmsg.SetWindowText("Error sending response to client.");
//else
// PrintString("Response sent!\n");
//OnClientClose();
}
return 0L;
}
3.LRESULT CServerDlg::OnSocketRead(WPARAM wParam, LPARAM lParam)
{
int iBytesRead;
int iBufferLength;
int iEnd;
int iSpaceRemaining;
char chIncomingDataBuffer[1024];
CString str;
int i;
for(i=0;(i<MAXClient)&&(m_aClientSocket[i]!=wParam);i++)
{
}
if(i==MAXClient) return 0L;
iBufferLength = iSpaceRemaining = sizeof(chIncomingDataBuffer);
iEnd = 0;
iSpaceRemaining -= iEnd;
iBytesRead = recv(m_aClientSocket[i], (LPSTR)(chIncomingDataBuffer+iEnd), iSpaceRemaining, 0);
iEnd+=iBytesRead;
if (iBytesRead == SOCKET_ERROR)
m_staticmsg.SetWindowText("OnClientRead recv reported a socket error. ");
chIncomingDataBuffer[iEnd] = '\0';
if (lstrlen(chIncomingDataBuffer) != 0)
{
m_recevmsg[i]=chIncomingDataBuffer;
//分析收到包,如果格式不对,错包数加1
//if (chIncomingDataBuffer[1]!="1")
// m_erropage[i]++;
//********
}
m_recevpage[i]++;
return(0L);
}
需要更全的代码请和我联系!
