失眠网 > c++ Socket实现客户端与服务器数据传输

c++ Socket实现客户端与服务器数据传输

时间：2020-07-17 06:03:18

这是自己第二次写博客,希望在博客记录自己的学习过程,欢迎大家评论!

实现: 客户端往服务器端发送一条数据,服务器端接收数据并输出;

服务器端再发送出接收到的数据给客户端!

根据自己的脑洞,想一下是否可以通过的改进实现简单的QQ聊天室!

少说废话,上代码

[文字描述都写在注释啦,也就那么点,]

服务器实现

~~一般情况下,先实现服务端的代码,这样逻辑可能会更清晰点,主要还是看个人的吧!~~

~~希望不要直接copy哦,至少自己动手敲一敲.~~

#define _WINSOCK_DEPRECATED_NO_WARNINGS //比较新版的vs,会警告我们不要使用一//下旧的函数,因为提供更新更安全的函数供我们使用,在这呢我们//还是用旧的吧,这个宏定义就是起屏蔽警告作用,VS下面也有提示的#include <stdio.h>#include <stdlib.h>#include<iostream>#include<string>#include<cstring>#include<WS2tcpip.h>#include <WinSock2.h>//一般情况下,这个头文件位于windows.h之前,避免发生某些错误#include<Windows.h>#pragma comment(lib, "ws2_32.lib") //显示加载 ws2_32.dllws2_32.dll就是最新socket版本啦using namespace std;int main(){cout << "-----------服务器-----------" << endl;//1初始化WSADATA wsadata;WSAStartup(MAKEWORD(2, 2), &wsadata);//make word,你把鼠标移到WSAStartup看看参数列表,是不是就是一个word啊//2创建服务器的套接字SOCKET serviceSocket;serviceSocket = socket(AF_INET, SOCK_STREAM, 0);//socket(协议族,socket数据传输方式,某个协议)我们默认为0,其实就是一个宏if (SOCKET_ERROR == serviceSocket) {cout << "套接字闯创建失败!" << endl;}else {cout << "套接字创建成功!" << endl;}//3绑定套接字指定绑定的IP地址和端口号sockaddr_in socketAddr;//一个绑定地址:有IP地址,有端口号,有协议族socketAddr.sin_family = AF_INET;socketAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");//代码开头第一行我们定义的宏在这就其作用啦socketAddr.sin_port = htons(1234);int bRes = bind(serviceSocket, (SOCKADDR*)&socketAddr, sizeof(SOCKADDR));//绑定注意的一点就是记得强制类型转换if (SOCKET_ERROR == bRes) {cout << "绑定失败!" << endl;}else {cout << "绑定成功!" << endl;}//4服务器监听int lLen = listen(serviceSocket, 5);//监听的第二个参数就是:能存放多少个客户端请求,到并发编程的时候很有用哦if (SOCKET_ERROR == lLen) {cout << "监听失败!" << endl;}else {cout << "监听成功!" << endl;}//5接受请求sockaddr_in revClientAddr;SOCKET recvClientSocket = INVALID_SOCKET;//初始化一个接受的客户端socketint _revSize = sizeof(sockaddr_in);recvClientSocket = accept(serviceSocket, (SOCKADDR*)&revClientAddr, &_revSize);if (INVALID_SOCKET == recvClientSocket) {cout << "服务端接受请求失败!" << endl;}else {cout << "服务端接受请求成功!" << endl;}//6发送/接受数据char recvBuf[1024] = {};int reLen = recv(recvClientSocket, recvBuf, 1024, 0);int sLen = send(recvClientSocket, recvBuf, reLen, 0);if (SOCKET_ERROR == reLen) {cout << "服务端发送数据失败" << endl;}else {cout << "服务器接受到数据: " << recvBuf << endl << endl;}//7关闭socketclosesocket(recvClientSocket);closesocket(serviceSocket);//8终止WSACleanup();cout << "服务器停止" << endl;cin.get();return 0;}

客户端代码实现

在这里再提醒一点,运行程序的时候,我们是先运行服务端程序,再运行客户端程序.

所以有些同学可能会说"我们的代码都一样啊!怎么到我这就不成功了呢?",这是一个

低级的错误,我们要避免.

还有就是我还要强调,敲代码,像我一样的初学者,咋不能直接copy,慢慢敲,不急!

~~像我写博客也一样,慢慢写,不慌.~~

乍一看,客户端跟服务器端代码差不多啊!

也确实是,而且比服务器端还简单,在这里我就不再一个个写注释啦,其实跟上面的差不多,

少废话,开始吧!

#define _WINSOCK_DEPRECATED_NO_WARNINGS #include <stdio.h>#include <stdlib.h>#include<iostream>#include<string>#include<cstring>#include<WS2tcpip.h>#include <WinSock2.h>#include<Windows.h>#pragma comment(lib, "ws2_32.lib") //加载 ws2_32.dllusing namespace std;int main(){cout << "-----------客户端-----------" << endl;//1初始化WSADATA wsadata;WSAStartup(MAKEWORD(2, 2), &wsadata);//2创建套接字SOCKET clientSocket = {};clientSocket = socket(PF_INET, SOCK_STREAM, 0);if (SOCKET_ERROR == clientSocket) {cout << "套接字闯创建失败!" << endl;}else {cout << "套接字创建成功!" << endl;}//3绑定套接字指定绑定的IP地址和端口号sockaddr_in socketAddr;socketAddr.sin_family = PF_INET;socketAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");socketAddr.sin_port = htons(1234);int cRes = connect(clientSocket, (SOCKADDR*)&socketAddr, sizeof(SOCKADDR));if (SOCKET_ERROR == cRes) {cout << "客户端:\t\t与服务器连接失败....." << endl;}else {cout << "客户端:\t\t与服务器连接成功....." << endl;}//4发送请求char sendBuf[1024] = "from Client: hello service.";send(clientSocket, sendBuf, strlen(sendBuf), 0);//5发送/接受数据char recvBuf[1024] = {};recv(clientSocket, recvBuf, 1024, 0);cout << "客户端接收数据:" << recvBuf << endl << endl;//6关闭socketclosesocket(clientSocket);//7终止WSACleanup();cout << "客户端退出" << endl;cin.get();return 0;}

这个就是运行效果啦

根据简单实现数据的发送和接受,我们一步一步改善代码

1. 首先使得客户端不断向服务器发送数据

发送数据: (也可以叫做请求,一般嘛,客户端都是向服务器端请求获得某资源).

更改代码,与上面一样,其余部分代码不做改变

服务器:

// 循环接收数据while (true){//6发送/接受数据char recvBuf[4024] = {};int reLen = recv(recvClientSocket, recvBuf, 4024, 0);int sLen = send(recvClientSocket, recvBuf, reLen, 0);if (SOCKET_ERROR != reLen) {cout << "服务器接受到数据: " << recvBuf << endl << endl;reLen = SOCKET_ERROR;}}

客户端:

while (true){//4发送请求string s;cout << "输入发送数据: " << endl;getline(cin, s);//可输入空格,默认以换行符结束输入,send(clientSocket, (char*)s.c_str(), s.length(), 0);//5发送/接受数据char recvBuf[4024] = {};recv(clientSocket, recvBuf, 4024, 0);cout << "客户端接收数据:" << recvBuf << endl << endl;}

提示:代码更改仅仅是增加一个while循环,思路很清晰. 客户端我们从控制台输入发送数据,变得更主动

2.进一步改善,再服务器端处理简单的业务逻辑

~~作为学习,简单来说呢,就是获得客户端发送来的数据做一些处理(判断).~~

下面我们提供一个简单的例子(在服务器上做修改):

服务器:

相对于上一阶段,就是在while循环里面添加条件判断语句.

~~简单吧!~~

while (true){//6发送/接受数据char recvBuf[1024] = {};int reLen = recv(recvClientSocket, recvBuf, 1024, 0);//阻塞函数,等待接受数据if (SOCKET_ERROR == reLen) {cout << "服务端发送数据失败" << endl;}else {cout << "请求命令: " << recvBuf;if (0 == strcmp("cls", recvBuf)) {//服务端执行命令system(recvBuf);}// 中文请求仅仅是为了测试可行性,一般都是用英文else if(0 == strcmp("获取版本信息",recvBuf)) {//返回数据string verData = "Version: 1.0.1\nAuthor: Primer\nReleaseData: -04-21";int sLen = send(recvClientSocket, (char*)verData.c_str(), verData.length(), 0);}else if(0 == strcmp("exit", recvBuf)){cout << endl << "退出服务器" << endl;break;}else {cout << "\t不正确..." << endl;}cout << endl;}}

客户端:

类似的修改,仅仅加了一个判断语句,不做过多的解释!

while (true){//4发送请求string s;cout << "输入发送数据:\t";getline(cin, s);//可输入空格,默认以换行符结束输入,send(clientSocket, (char*)s.c_str(), (int)s.length(), 0);//因为recv接受函数是阻塞函数,所以我们加以判断//请求正确我才接收数据,否则不影响我继续请求if(0 == strcmp("获取版本信息", s.c_str())) {char recvBuf[4024] = {};int reLen = recv(clientSocket, recvBuf, 4024, 0);//阻塞函数,等待接受数据cout << endl << recvBuf << endl << endl;}}

效果图:

若要实现更多的逻辑处理,自己大开脑洞.

3.传输结构体到服务器

数据有着各种各样的类型,文字,图片,音频,视频等都是数据,有些数据复杂有些简单,

刚开始部分我们传输的是一个字符型或者整型的数据到服务器上,那么这此我们传输

稍微复杂一些的数据—结构体.

…

编不下去了.

上代码!

第一:

在客户端和服务器端定义一个结构一致的结构体.

~~什么叫结构一致?~~

~~你在结构体里面定义的基本类型顺序一定要相同,不然在读取数据的时候,~~

~~由于字节对齐不正确,可能读取出来的就是乱码~~.~~自己体会.~~

我的结构体是真这样子的.

//// 定义一个学生结构体信息typedef struct node {intid;//学号charname[50];//姓名charsex[10];//性别intage;//年龄charclassName[100];//班级}STUDENT;

服务器端:

一样的,仅仅改动while循环部分

STUDENT student = {};//服务器接受数据,数据格式需要和客户端数据格式一致while (true){//6发送/接受数据int reLen = recv(recvClientSocket, (char*)&student, 4024, 0);if (SOCKET_ERROR != reLen){cout << "服务端输出接受数据: " << endl << endl;cout <<"学号:\t"<< student.id << endl;cout <<"姓名:\t"<< student.name << endl;cout <<"性别:\t"<< student.sex << endl;cout <<"年龄:\t"<< student.age << endl;cout <<"班级:\t"<< student.className << endl;memset(&student, 0, sizeof(student));}}

客户端:

更简单

while (true){//4发送数据STUDENT student;cout << "输入学生信息:[学号+姓名+性别+年龄+专业班级]\t";cin >> student.id >> student.name >> student.sex >> student.age >> student.className;//在发送结构体的受强制转换提供地址形式发送即可send(clientSocket, (char*)&student, sizeof(student), 0);}