技术标签: c++ 网络 client server tcpip socket 网络编程
可大致分为以下5个步骤:
1.初始化环境
2.创建监听套接字
3.监听套接字与IP地址及端口绑定
4.监听套接字
5.等待客户端连接
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
WSAStartup()函数的调用指明Windows Sockets API的版本号及获得特定Windows Sockets实现的细节,应用程序或DLL只能在一次成功的WSAStartup()调用之后才能调用进一步的Windows Sockets API函数。
该函数执行成功后返回0。
m_listenSocket = socket(AF_INET, SOCK_STREAM, 0));
AF_INET:指定使用IPV4协议簇
SOCK_STREAM:字节流,数据有保障的传输
0:不希望指定协议
该函数执行成功返回一个新的套接字,否则返回:INVALID_SOCKET。
sockaddr_in sockadd = {
0, };
sockadd.sin_family = AF_INET;//IPV4协议簇
sockadd.sin_port = htons(m_uPort);//监听端口
sockadd.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//监听本机任意IP
bind(m_listenSocket, (struct sockaddr*) & sockadd, sizeof(sockadd));
m_listenSocket:已经创建好的监听套接字
INADDR_ANY:如果机器存在多网卡,客户端连接任意一个IP地址均可建立通信
执行失败时返回: SOCKET_ERROR
listen(m_listenSocket, 1);
m_listenSocket:绑定IP地址及端口的监听地址
1:指定最大允许同时连接的客户端数
m_clientSocket = accept(m_listenSocket, (struct sockaddr*) & addr, &addrlen);
提取套接字m_listenSocket上挂起连接队列的第一个连接,然后返回新套接字m_clientSocket,如过要与客户端通信就需要通过m_clientSocket来发送或接收数据
如果暂时没有客户端连接过来,该函数将阻塞在此处,直到新连接到来才会返回。
const int iBufSize = 1024;
char recvBuf[iBufSize] = {
0, };
auto iRecvSize = recv(m_clientSocket, recvBuf, iBufSize, 0);//若不支持C++11及以上,auto改为int
m_clientSocket:收发数据时,均需要用到accept()返回的客户端套接字
recvBuf:接收数据缓冲区,收到的数据就保存在该数组中
iBufSize:recvBuf数组的字节长度,最多接收到的数据长度,该缓冲区也只能接收这么多,否则会溢出,造成程序异常
0:将数据从TCP从输入队列中剪切到recvBuf,且不做其他操作
返回值:如果没有发生错误,recv将返回接收到的字节数,recvBuf参数指向的缓冲区将包含接收到的数据。如果连接已经正常关闭,则返回值为零。否则,将返回一个SOCKET_ERROR值
如果套接字m_clientSocket上没有可用的传入数据,则recv调用阻塞并等待数据并不会返回,除非定义了其他阻塞规则,此处并没有指定
std::string strMsg = "hello";
send(m_clientSocket, strMsg.c_str(), strMsg.length(), 0);
m_clientSocket:收发数据时,均需要用到accept()返回的客户端套接字
strMsg.c_str():发送数据首地址
strMsg.length():数据长度
0:无特别指定调用
返回值:如果没有发生错误,send返回发送的字节总数,它可能小于len参数中请求发送的字节数。否则,将返回SOCKET_ERROR的值
//CTcpServer.h
#pragma once
#include <string>
#include <winsock2.h>
#pragma comment(lib,"ws2_32")//Standard socket API.
class CTcpServer
{
public:
CTcpServer(std::string strIp, unsigned int uPort);
virtual ~CTcpServer();
//初始化网络服务端
bool InitServer();
//发送数据
bool SendMsg(const std::string& strMsg);
//接收数据并打印
bool RecvMsg();
private:
unsigned int m_uPort;//监听端口
std::string m_strIp;//用于监听本机指定IP地址
SOCKET m_listenSocket = NULL;//监听套接字
SOCKET m_clientSocket = NULL;//客户端套接字
};
//CTcpServer.cpp
#include <iostream>
#include "CTcpServer.h"
CTcpServer::CTcpServer(std::string strIp, unsigned int uPort) :
m_strIp(strIp),
m_uPort(uPort)
{
}
CTcpServer::~CTcpServer()
{
if (m_clientSocket)
{
closesocket(m_clientSocket);
m_clientSocket = NULL;
}
if (m_listenSocket)
{
closesocket(m_listenSocket);
m_listenSocket = NULL;
}
WSACleanup();
}
bool CTcpServer::InitServer()
{
WSADATA wsaData;
//1. 初始化环境
if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
{
std::cout << "Init Windows Socket Failed!\n";
return false;
}
//2. 创建监听套接字
if ((m_listenSocket = socket(AF_INET, SOCK_STREAM, 0)) == INVALID_SOCKET)
{
std::cout << "Create socket failed!\n";
return false;
}
//协议
sockaddr_in sockadd = {
0, };
sockadd.sin_family = AF_INET;//IPV4协议簇
sockadd.sin_port = htons(m_uPort);//监听端口
sockadd.sin_addr.S_un.S_addr = htonl(INADDR_ANY);//监听本机任意IP
//3. 监听套接字与IP地址及端口绑定
if (bind(m_listenSocket, (struct sockaddr*) & sockadd, sizeof(sockadd)) == SOCKET_ERROR)
{
closesocket(m_listenSocket);
m_listenSocket = INVALID_SOCKET;
std::cout << "Socket bind failed!\n";
return false;
}
//4. 监听套接字
if (listen(m_listenSocket, 1) == SOCKET_ERROR)
{
closesocket(m_listenSocket);
m_listenSocket = INVALID_SOCKET;
std::cout << "Socket listen failed!\n";
return false;
}
sockaddr_in addr = {
0, };
int addrlen = sizeof(addr);
//5. 等待客户端连接
m_clientSocket = accept(m_listenSocket, (struct sockaddr*) & addr, &addrlen);
if (m_clientSocket == SOCKET_ERROR)
{
closesocket(m_clientSocket);
m_clientSocket = INVALID_SOCKET;
std::cout << "Socket accept failed!\n";
return false;
}
return true;
}
bool CTcpServer::SendMsg(const std::string& strMsg)
{
if (!m_clientSocket) return false;
if (send(m_clientSocket, strMsg.c_str(), strMsg.length(), 0) != INVALID_SOCKET)
{
std::cout << "发送成功:" << strMsg << "\n";
return true;
}
else
{
std::cout << "发送失败!\n";
return false;
}
}
bool CTcpServer::RecvMsg()
{
if (!m_clientSocket) return false;
const int iBufSize = 1024;
char recvBuf[iBufSize] = {
0, };
auto iRecvSize = recv(m_clientSocket, recvBuf, iBufSize, 0);//若不支持C++11及以上,auto改为int
if (iRecvSize <= 0)
{
std::cout << "接收失败!\n";
return false;
}
else
{
std::cout << "接收成功:" << recvBuf << "\n";
return true;
}
}
#include <iostream>
#include "CTcpServer.h"
int main()
{
{
CTcpServer tcpServer("127.0.0.1", 6005);
if (!tcpServer.InitServer())
getchar();
for (int i = 0; i != 3; ++i)
{
//接收数据成功后,向客户端返回"answer"
if (tcpServer.RecvMsg())
{
std::string strAnswerMsg{
"answer" };
tcpServer.SendMsg(strAnswerMsg);
}
}
}//接收3次数据后出此大括号,tcpServer对象被析构,客户端连接被关闭
return 0;
}
1. 初始化环境
2. 创建一个新的套接字
3. 建立连接
客户端的创建比较简单,只需要三步,创建好了之后就可以进行数据的收发了
短链接:客户端与服务端建立连接之后,进行短暂的收发数据之后即断开连接(closesocket())称为短链接
长连接:两者建立连接之后需要长时间保持该连接的成为长连接,在不需要数据交互时可以每隔一定时间其中一方发送一个心跳报文(内容可以是约定的任意值,比如字符串“heartBeat”)到另一方,另一方收到心跳报文后立即恢复一个应答(同样是约定的任意值),发送方在一定次数没有收到应答 或者 接收方一定次数没有收到心跳报文时,均可判定对方断线,此时可以关闭套接字或其他业务逻辑
还是直接上代码吧
//CTcpClient.h
#pragma once
#include <string>
#include <winsock2.h>
#pragma comment(lib,"ws2_32")//Standard socket API.
class CTcpClient
{
public:
CTcpClient(std::string strServerIp, unsigned uServerPort);
virtual ~CTcpClient();
//建立连接
bool InitConnect();
//发送数据
bool SendMsg(const std::string& strMsg);
//接收数据并打印
bool RecvMsg();
private:
SOCKET m_socket = INVALID_SOCKET;
std::string m_strServerIp;//服务端监听IP地址
unsigned int m_uServerPort = -1;//服务端监听端口
struct addrinfo* m_servAddrInfo = NULL;//服务端地址结构链表
};
//CTcpClient.cpp
#include <sstream>
#include <iostream>
#include <Ws2tcpip.h>
#include <mstcpip.h>
#include "CTcpClient.h"
CTcpClient::CTcpClient(std::string strServerIp, unsigned uServerPort) :
m_strServerIp(strServerIp),
m_uServerPort(uServerPort)
{
}
CTcpClient::~CTcpClient()
{
if (m_socket != INVALID_SOCKET)
closesocket(m_socket);
WSACleanup();
freeaddrinfo(m_servAddrInfo);
}
bool CTcpClient::InitConnect()
{
WSADATA wsaData;
//1. 初始化环境
if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
{
std::cout << "Init Windows Socket Failed!\n";
return false;
}
addrinfo hints = {
0, };//协议无关(IPV4 or IPV6)
hints.ai_flags = AI_NUMERICHOST;
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
hints.ai_protocol = IPPROTO_TCP;
std::stringstream ssPort;
ssPort << m_uServerPort;
//获取服务端地址结构
if (getaddrinfo(m_strServerIp.c_str(), ssPort.str().c_str(), &hints, &m_servAddrInfo) != 0)
{
std::cout << "Get server addrInfo failed!\n";
return false;
}
if (m_socket != INVALID_SOCKET)
closesocket(m_socket);
m_socket = INVALID_SOCKET;
//2. 创建一个新的套接字
if ((m_socket = socket(m_servAddrInfo->ai_family, m_servAddrInfo->ai_socktype, m_servAddrInfo->ai_protocol)) == SOCKET_ERROR)
return false;
//3. 建立连接
int iResult = connect(m_socket, m_servAddrInfo->ai_addr, (int)m_servAddrInfo->ai_addrlen);
if (iResult == SOCKET_ERROR)
{
iResult = WSAGetLastError();
if (iResult != WSAEWOULDBLOCK)
{
std::cout << "Connect server failed!\n";
closesocket(m_socket);
m_socket = INVALID_SOCKET;
return false;
}
}
std::cout << "Connect Server succeed!\n";
return true;
}
bool CTcpClient::SendMsg(const std::string& strMsg)
{
if (!m_socket) return false;
if (send(m_socket, strMsg.c_str(), strMsg.length(), 0) != INVALID_SOCKET)
{
std::cout << "发送成功:" << strMsg << "\n";
return true;
}
else
{
std::cout << "发送失败!\n";
return false;
}
}
bool CTcpClient::RecvMsg()
{
if (!m_socket) return false;
const int iBufSize = 1024;
char recvBuf[iBufSize] = {
0, };
auto iRecvSize = recv(m_socket, recvBuf, iBufSize, 0);//若不支持C++11及以上,auto改为int
if (iRecvSize <= 0)
{
std::cout << "接收失败!\n";
return false;
}
else
{
std::cout << "接收成功:" << recvBuf << "\n";
return true;
}
}
#include <iostream>
#include "CTcpClient.h"
int main()
{
{
CTcpClient tcpClient("127.0.0.1", 6005);
if (!tcpClient.InitConnect())
getchar();
std::string strAskMsg{
"ask" };
for (int i = 0; i != 3; ++i)
{
if (tcpClient.SendMsg(strAskMsg))
{
tcpClient.RecvMsg();
}
}
}
getchar();
return 0;
}
有任何问题,欢迎留言
文章浏览阅读2.6k次。解决Python词云库wordcloud不显示中文的问题2018-11-25背景:wordcloud是基于Python开发的词云生成库,功能强大使用简单。github地址:https://github.com/amueller/word_cloudwordcloud默认是不支持显示中文的,中文会被显示成方框。安装:安装命令:pip install wordcloud解决:经过测试发现不支持显示中文..._词云python代码无法输出文字
文章浏览阅读807次。扩展。_jmap 在线分析
文章浏览阅读1.1w次。随着炎热夏季的到来,当玩游戏正爽的时候,电脑突然死机了,自动关机了,是不是有想给主机一脚的冲动呢?这个很大的原因是因为CPU温度过高导致的。很多新手玩家可能都有一个疑虑,cpu温度多少以下正常?有些说是60,有些说是70,到底多高CPU温度不会死机呢?首先我们先看看如何查看CPU的温度。下载鲁大师并安装,运行鲁大师软件,即可进入软件界面,并点击温度管理,即可看到电脑各个硬件的温度。鲁大师一般情况下..._台式机玩游戏温度多少正常
文章浏览阅读243次。Day2-打印打印打印!我终于更新了!(哭腔)一、 最简单的打印最最简单的打印语句: print(“打印内容”)注意:python是全英的,符号记得是半角下面是我写的例子:然后进入power shell ,注意:你需要使用cd来进入你保存的例子的文件夹,保存时名字应该取为xxx.py我终于知道为什么文件夹取名都建议取英文了,因为进入的时候是真的很麻烦!如果你没有进入正确的文件夹..._puthon打印任务收获
文章浏览阅读1k次。centos8问题参考CentOS 8 EOL如何切换源? - 云服务器 ECS - 阿里云_"cenerrors during download metadata for repository \"appstream"
文章浏览阅读2.7k次,点赞3次,收藏11次。SpringBoot+Maven+MabatisPlusmaven在新建springboot项目引入RELEASE版本出错maven在新建springboot项目引入RELEASE版本出错maven详解maven就是通过pom.xml中的配置,就能够从仓库获取到想要的jar包。仓库分为:本地仓库、第三方仓库(私服)、中央仓库springframework.boot:spring-boot-starter-parent:2.2.1.RELEASE’ not found若出现jar包下载不了只有两_基于微服务的在线教育平台尚硅谷
文章浏览阅读316次。路由的概念路由器它称之为网关设备。路由器就是用于连接不同网络的设备路由器是位于OSI模型的第三层。路由器通过路由决定数据的转发。网关的背景:当时每家计算机厂商,用于交换数据的通信程序(协议)和数据描述格式各不相同。因此,就把用于相互转换这些协议和格式的计算机称为网关。路由器与三层交换器的对比路由协议对比路由器的作用:1.路由寻址2.实现不同网络之间相连的功能3.通过路由决定数据的转发,转发策略称为 路由选择。VLAN相关技术什么是VLAN?中文名称叫:虚拟局域网。虚_路由和vlan
文章浏览阅读2.8w次,点赞6次,收藏22次。设置div背景颜色透明度,内部元素不透明:.demo{ background-color:rgba(255,255,255,0.15) } 错误方式:.demo{ background-color:#5CACEE;opacity:0.75;} 这样会导致div里面的元素内容和背景颜色一起变透明只针对谷歌浏览器的测试_div设置透明度,里面的内容不透明
文章浏览阅读563次。1.[ u]文字:在文字的位置可以任意加入您需要的字符,显示为下划线效果。2.[ align=center]文字:在文字的位置可以任意加入您需要的字符,center位置center表示居中,left表示居左,right表示居右。5.[ color=red]文字:输入您的颜色代码,在标签的中间插入文字可以实现文字颜色改变。6.[ SIZE=数字]文字:输入您的字体大小,在标签的中间插入文..._discuzcode 大全
文章浏览阅读2.6k次。iOS中定时器有三种,分别是NSTimer、CADisplayLink、dispatch_source,下面就分别对这三种计时器进行说明。一、NSTimerNSTimer这种定时器用的比较多,但是特别需要注意释放问题,如果处理不好很容易引起循环引用问题,造成内存泄漏。1.1 NSTimer的创建NSTimer有两种创建方法。方法一:这种方法虽然创建了NSTimer,但是定时器却没有起作用。这种方式创建的NSTimer,需要加入到NSRunLoop中,有NSRunLoop的驱动才会让定时器跑起来。_ios nstimer
文章浏览阅读4.8k次,点赞17次,收藏51次。Linux的命令有几百个,对程序员来说,常用的并不多,考虑各位是初学者,先学习本章节前15个命令就可以了,其它的命令以后用到的时候再学习。1、开机 物理机服务器,按下电源开关,就像windows开机一样。 在VMware中点击“开启此虚拟机”。2、登录 启动完成后,输入用户名和密码,一般情况下,不要用root用户..._ls-lmore
文章浏览阅读4.1k次。1.登录MYSQL系统命令打开DOS命令框shengfen,以管理员的身份运行命令1:mysql -u usernae -p password命令2:mysql -u username -p password -h 需要连接的mysql主机名(localhost本地主机名)或是mysql的ip地址(默认为:127.0.0.1)-P 端口号(默认:3306端口)使用其中任意一个就OK,输入命令后DOS命令框得到mysql>就说明已经进入了mysql系统2. 查看mysql当中的._mysql -u user