问题描述:服务器一个,客服端两个,现在服务器给客服端发消息,却只有一个客服端收到,然后再发又只有一个收到,不过这个时候是另一个客服端收到,依次轮流收到服务器的信息,感觉有些奇怪,有些问题是想不明白//服务器端代码:
#include "stdafx.h"
#include <windows.h>
#include <process.h>
#include <iostream>
#include <string>
using namespace std;
#pragma comment(lib,"ws2_32.lib")/*recive message thread*/
DWORD WINAPI ClientThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;//----------
char szbuff[1024];
int ret;
while(1)
{
//perform a blocking recv() call
ret = recv(sock,szbuff,1024,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "recv() failed " << WSAGetLastError() << endl;
break;
}
szbuff[ret] = '\0';
cout << "RECV:" << szbuff << " " << ret << "bytes" << endl;
}
return 0;
}/*send message thread*/
DWORD WINAPI SendThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
char buff[1024];
string msg;
int ret;
while(1)
{
cin >> msg;
char buff[1024];
strcpy(buff,msg.c_str());
ret = send(sock,buff,msg.length() + 1,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "send failed " << WSAGetLastError() << endl;
break;
}
}
return 0;
}int _tmain(int argc, _TCHAR* argv[])
{
//cout << *(int*)lp << endl;
//Initialize Winsock
WSADATA wsd;
if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)
{
cout << "Failled to load Winsock!" << endl;
return 1;
}
//create our listening socket
SOCKET sListen,sClient;
sListen = socket(AF_INET,SOCK_STREAM,IPPROTO_IP);
if(sListen == SOCKET_ERROR)
{
cout << "socket() failed " << WSAGetLastError() << endl;
return 1;
}
//Select local interface and bind to it
struct sockaddr_in local,client;
int iport = 5000;
local.sin_addr.s_addr = htonl(INADDR_ANY);
local.sin_port = htons(iport);
local.sin_family = AF_INET;
if(bind(sListen,(SOCKADDR*)&local,sizeof(local)) == SOCKET_ERROR)
{
cout << "bind() failed " << WSAGetLastError() << endl;
return 1;
}
listen(sListen,8);
cout << "server side is in listening status!" << endl;
//Waitfor incoming clients,Once one is detected,create thread and pass
//the handle off to it
int iAddrSize(0);
HANDLE hThread;
DWORD dwThreadId,dwSendThreadId;
while(1)
{
iAddrSize = sizeof(client);
sClient = accept(sListen,(SOCKADDR*)&client,&iAddrSize);
if(sClient == INVALID_SOCKET)
{
cout << "accept() failed " << WSAGetLastError() << endl;
break;
}
cout << "Accept client:" << inet_ntoa(client.sin_addr) << endl;
cout << ntohs(client.sin_port) << endl; hThread = CreateThread(NULL,0,ClientThread,
(LPVOID)sClient,0,&dwThreadId);
HANDLE hSendThread = CreateThread(NULL,0,SendThread,
(LPVOID)sClient,0,&dwSendThreadId);
if(hThread == NULL)
{
cout << "CreateThread() failed " << GetLastError() << endl;
break;
}
CloseHandle(hThread);
CloseHandle(hSendThread);
}
closesocket(sListen);
WSACleanup();
return 0;
}//客服端代码:
#include "stdafx.h"
#include <windows.h>
#include <process.h>
#include <iostream>
#include <string>
#include <stdio.h>
#include <stdlib.h>
using namespace std;
#pragma comment(lib,"ws2_32.lib")/*recive message thread*/
DWORD WINAPI ClientThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
char szbuff[1024];
int ret;
while(1)
{
ret = recv(sock,szbuff,1024,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "recv() failed " << WSAGetLastError() << endl;
break;
}
szbuff[ret] = '\0';
cout << "recv " << szbuff << " " << ret << "bytes" << endl;
}
return 0;
}
/*send message thread*/
DWORD WINAPI SendThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
string msg;
char buff[1024];
int ret;
while(1)
{
cin >> msg;
strcpy(buff,msg.c_str());
ret = send(sock,buff,msg.length() + 1,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "send failed " << WSAGetLastError() << endl;
break;
}
}
return 0;
}int _tmain(int argc, _TCHAR* argv[])
{
WSADATA wsd;
SOCKET sClient;
struct sockaddr_in server;
struct hostent *host = NULL;
//load Winsock
if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)
{
cout << "Failled to load Winsock!" << endl;
return 1;
}
//create socket and attempt to connect to the server
sClient = socket(AF_INET,SOCK_STREAM,IPPROTO_IP);
if(sClient == INVALID_SOCKET)
{
cout << "socket failed " << WSAGetLastError() << endl;
return 1;
}
string szServer;
u_long iport;
cout << "please input IP address: " << endl;
cin >> szServer;
cout << "please input port number: " << endl;
cin >> iport;
server.sin_addr.s_addr = inet_addr(INADDR_ANY);
server.sin_family = AF_INET;
server.sin_port = htons(iport);
//if the supplied server address isn't in the form
//"aaa.bbb.ccc.ddd" it's a host name,so try to resolve it
if(server.sin_addr.s_addr == INADDR_NONE)
{
host = gethostbyname(szServer.c_str());
if(host == NULL)
{
cout << "unable to resolve server: " << szServer << endl;
return 1;
}
CopyMemory(&server.sin_addr,host->h_addr_list[0],host->h_length);
}
if(connect(sClient,(SOCKADDR*)&server,sizeof(server))==SOCKET_ERROR)
{
cout << "connect failed " << WSAGetLastError() << endl;
return 1;
}
cout << "connect succeed!" << endl;
DWORD dwThreadId,dwSendThreadId;
HANDLE hThread = CreateThread(NULL,0,ClientThread,
(LPVOID)sClient,0,&dwThreadId);
HANDLE hSendThread = CreateThread(NULL,0,SendThread,
(LPVOID)sClient,0,&dwSendThreadId);
if(hThread == NULL)
{
cout << "CreateThread() failed " << GetLastError() << endl;
}
if(hSendThread == NULL)
{
cout << "CreateThread() failed " << GetLastError() << endl;
}
CloseHandle(hThread);
CloseHandle(hSendThread); //prevent main thread exit;
while(1)
{ }
closesocket(sClient);
WSACleanup();
return 0;
}我开两个客服端,然后和服务器端连接,然后服务器发消息,就出现这种情况我以为是创建线程调用同一个函数的问题,但是我写测试代码不会出现这种情况
#include "stdafx.h"
#include <windows.h>
#include <process.h>
#include <iostream>
#include <string>
using namespace std;
#pragma comment(lib,"ws2_32.lib")/*recive message thread*/
DWORD WINAPI ClientThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;//----------
char szbuff[1024];
int ret;
while(1)
{
//perform a blocking recv() call
ret = recv(sock,szbuff,1024,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "recv() failed " << WSAGetLastError() << endl;
break;
}
szbuff[ret] = '\0';
cout << "RECV:" << szbuff << " " << ret << "bytes" << endl;
}
return 0;
}/*send message thread*/
DWORD WINAPI SendThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
char buff[1024];
string msg;
int ret;
while(1)
{
cin >> msg;
char buff[1024];
strcpy(buff,msg.c_str());
ret = send(sock,buff,msg.length() + 1,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "send failed " << WSAGetLastError() << endl;
break;
}
}
return 0;
}int _tmain(int argc, _TCHAR* argv[])
{
//cout << *(int*)lp << endl;
//Initialize Winsock
WSADATA wsd;
if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)
{
cout << "Failled to load Winsock!" << endl;
return 1;
}
//create our listening socket
SOCKET sListen,sClient;
sListen = socket(AF_INET,SOCK_STREAM,IPPROTO_IP);
if(sListen == SOCKET_ERROR)
{
cout << "socket() failed " << WSAGetLastError() << endl;
return 1;
}
//Select local interface and bind to it
struct sockaddr_in local,client;
int iport = 5000;
local.sin_addr.s_addr = htonl(INADDR_ANY);
local.sin_port = htons(iport);
local.sin_family = AF_INET;
if(bind(sListen,(SOCKADDR*)&local,sizeof(local)) == SOCKET_ERROR)
{
cout << "bind() failed " << WSAGetLastError() << endl;
return 1;
}
listen(sListen,8);
cout << "server side is in listening status!" << endl;
//Waitfor incoming clients,Once one is detected,create thread and pass
//the handle off to it
int iAddrSize(0);
HANDLE hThread;
DWORD dwThreadId,dwSendThreadId;
while(1)
{
iAddrSize = sizeof(client);
sClient = accept(sListen,(SOCKADDR*)&client,&iAddrSize);
if(sClient == INVALID_SOCKET)
{
cout << "accept() failed " << WSAGetLastError() << endl;
break;
}
cout << "Accept client:" << inet_ntoa(client.sin_addr) << endl;
cout << ntohs(client.sin_port) << endl; hThread = CreateThread(NULL,0,ClientThread,
(LPVOID)sClient,0,&dwThreadId);
HANDLE hSendThread = CreateThread(NULL,0,SendThread,
(LPVOID)sClient,0,&dwSendThreadId);
if(hThread == NULL)
{
cout << "CreateThread() failed " << GetLastError() << endl;
break;
}
CloseHandle(hThread);
CloseHandle(hSendThread);
}
closesocket(sListen);
WSACleanup();
return 0;
}//客服端代码:
#include "stdafx.h"
#include <windows.h>
#include <process.h>
#include <iostream>
#include <string>
#include <stdio.h>
#include <stdlib.h>
using namespace std;
#pragma comment(lib,"ws2_32.lib")/*recive message thread*/
DWORD WINAPI ClientThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
char szbuff[1024];
int ret;
while(1)
{
ret = recv(sock,szbuff,1024,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "recv() failed " << WSAGetLastError() << endl;
break;
}
szbuff[ret] = '\0';
cout << "recv " << szbuff << " " << ret << "bytes" << endl;
}
return 0;
}
/*send message thread*/
DWORD WINAPI SendThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
string msg;
char buff[1024];
int ret;
while(1)
{
cin >> msg;
strcpy(buff,msg.c_str());
ret = send(sock,buff,msg.length() + 1,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "send failed " << WSAGetLastError() << endl;
break;
}
}
return 0;
}int _tmain(int argc, _TCHAR* argv[])
{
WSADATA wsd;
SOCKET sClient;
struct sockaddr_in server;
struct hostent *host = NULL;
//load Winsock
if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)
{
cout << "Failled to load Winsock!" << endl;
return 1;
}
//create socket and attempt to connect to the server
sClient = socket(AF_INET,SOCK_STREAM,IPPROTO_IP);
if(sClient == INVALID_SOCKET)
{
cout << "socket failed " << WSAGetLastError() << endl;
return 1;
}
string szServer;
u_long iport;
cout << "please input IP address: " << endl;
cin >> szServer;
cout << "please input port number: " << endl;
cin >> iport;
server.sin_addr.s_addr = inet_addr(INADDR_ANY);
server.sin_family = AF_INET;
server.sin_port = htons(iport);
//if the supplied server address isn't in the form
//"aaa.bbb.ccc.ddd" it's a host name,so try to resolve it
if(server.sin_addr.s_addr == INADDR_NONE)
{
host = gethostbyname(szServer.c_str());
if(host == NULL)
{
cout << "unable to resolve server: " << szServer << endl;
return 1;
}
CopyMemory(&server.sin_addr,host->h_addr_list[0],host->h_length);
}
if(connect(sClient,(SOCKADDR*)&server,sizeof(server))==SOCKET_ERROR)
{
cout << "connect failed " << WSAGetLastError() << endl;
return 1;
}
cout << "connect succeed!" << endl;
DWORD dwThreadId,dwSendThreadId;
HANDLE hThread = CreateThread(NULL,0,ClientThread,
(LPVOID)sClient,0,&dwThreadId);
HANDLE hSendThread = CreateThread(NULL,0,SendThread,
(LPVOID)sClient,0,&dwSendThreadId);
if(hThread == NULL)
{
cout << "CreateThread() failed " << GetLastError() << endl;
}
if(hSendThread == NULL)
{
cout << "CreateThread() failed " << GetLastError() << endl;
}
CloseHandle(hThread);
CloseHandle(hSendThread); //prevent main thread exit;
while(1)
{ }
closesocket(sClient);
WSACleanup();
return 0;
}我开两个客服端,然后和服务器端连接,然后服务器发消息,就出现这种情况我以为是创建线程调用同一个函数的问题,但是我写测试代码不会出现这种情况
解决方案 »
- 为什么迅雷 就能把他的 xunleiBHO_now.dll 注入到Explorer .exe 里面
- 我想做像手写板程序那样,如何在屏幕上最顶层绘图,又不会影响其它窗口的界面?!?!?
- ----求教----关于关闭模式对话框的问题
- 向工程加入一个头文件和一个CPP文件后,在链接时出现WINDOWS.H already included. MFC apps must not #include <windows.h>的错误
- C#如何获取C++动态库中的数组
- 如何以CWnd指针作为参数?
- (高难)如何打开资源中的位图
- 一个弹出式菜单的问题
- WIN2000
- VC中如何以图片的形式输出自绘的内容?
- 怎么控制浏览器的选项卡的关闭
- GDI+如何绘制图片为非正矩形?
我现在想想,应该不是这个问题,这个参数只是返回线程ID,创建的时候这几个线程的ID应该都是不同的,所以问题不应该是这里,但肯定是在服务器端
现在我开个线程专门从控制台读取消息,保存在一个全局变量中,然后在send线程里获取这个全局变量,发送给客户端,
这里涉及到两个问题
1.同步,这个主要是线程里面的cin >> message;这个不是大问题
2.消息分发,我如何控制每个send线程只对读入的message发送一次?
如下是服务器端的send线程:DWORD WINAPI SendThread(LPVOID lp)
{
SOCKET sock = (SOCKET)lp;
char buff[1024];
int ret;
while(1)
{
string msg = message; //continue get the to be send message
char buff[1024];
if(msg.length() > 0)
{
strcpy(buff,msg.c_str());
ret = send(sock,buff,msg.length() + 1,0);
if(ret == 0)
break;
else if(ret == SOCKET_ERROR)
{
cout << "send failed " << WSAGetLastError() << endl;
break;
}
}
}
return 0;
}
这是有问题的,这样写,读入一次客服端就会收到无穷个消息,可是我怎么想都想不出好办法。。求解
为什么你的服务器用的地址是INDADDR_ANY呢每次启动服务器 地址不知道··客户端怎么连接呢?