当前位置: 首页 > news >正文

【C++boost::asio网络编程】有关socket的创建和连接的笔记

socket的创建和连接

  • tcp客户端创建端点
  • tcp服务端创建端点
  • 创建socket
  • 创建TCP 服务器端的 acceptor 套接字
  • 创建 acceptor 套接字并绑定
  • 客户端连接到服务器
    • 通过ip地址解析
    • 通过域名解析
  • 服务端接收新连接

tcp客户端创建端点

int client_end_point()
{std::string raw_ip_address = "127.0.0.1";unsigned short prot_num = 8888;boost::system::error_code ec;boost::asio::ip::address ip_address = boost::asio::ip::address::from_string(raw_ip_address, ec);if (ec.value() != 0){std::cout << "Failed to parse the IP address.Error code = " << ec.value() << ".Message is " << ec.message();return ec.value();}boost::asio::ip::tcp::endpoint endpoint(ip_address, prot_num);return 0;
}

  std::string raw_ip_addressunsigned short prot_num分别代表了ip地址和端口号,其中127.0.0.1为本地回环地址,也叫做localhost
  cboost::system::error_code ec用来表示可能出现的错误。Boost.Asio 使用这个对象来存储错误信息,例如网络操作中可能发生的错误
  boost::asio::ip::address ip_address = boost::asio::ip::address::from_string(raw_ip_address, ec);则是将字符串类型的ip地址解析为boost库中更为通用的boost::asio::ip::address 类型的对象
  boost::asio::ip::tcp::endpoint endpoint(ip_address, prot_num);该语句使用ip_address 和prot_num 创建了一个 TCP 端点(tcp::endpoint)。端点是网络通信中表示地址和端口的对象,通常用于设置连接目标。ip_address 是通过前面解析得到的 IP 地址。prot_num 是端口号,表示服务监听的端口。

tcp服务端创建端点

int server_end_point()
{unsigned port_num = 8888;//端口号boost::asio::ip::address ip_address = boost::asio::ip::address_v6::any();boost::asio::ip::tcp::endpoint endpoint(ip_address, port_num);return 0;
}

  boost::asio::ip::address_v6::any() 是一个特殊的 IPv6 地址,表示任意可用的地址,通常用于服务器端监听所有可用的 IPv6 地址。如果是 IPv4 地址的话,则使用 boost::asio::ip::address_v4::any()

创建socket

int create_tcp_socket()
{boost::asio::io_context ioc;boost::asio::ip::tcp protocol = boost::asio::ip::tcp::v4();boost::system::error_code ec;boost::asio::ip::tcp::socket sock(ioc);sock.open(protocol, ec);if (ec.value() != 0){std::cout<< "Failed to open the socket! Error code = "<< ec.value() << ". Message: " << ec.message();return ec.value();}return 0;
}

  boost::asio::io_context 是 Boost.Asio 中用于执行异步操作的核心对象。它是所有异步操作的调度中心,负责调度和执行异步事件

boost::asio::ip::tcp protocol = boost::asio::ip::tcp::v4();

  这段代码主要意思是选择TCP协议的版本,当使用tcp::v4()代表使用的是TCP协议的IPV4版本,如果使用的是tcp::v6()则代表选择的是IPV6

boost::asio::ip::tcp::socket sock(ioc);

  以上代码创建了一个 boost::asio::ip::tcp::socket 类型的套接字对象 sock。该套接字是基于之前创建的 ioc(io_context)对象进行初始化的。ioc 是 io_context 对象,它在后台驱动异步操作,而套接字则是与网络通信的实体,能够接收和发送数据

sock.open(protocol, ec);

  sock.open(protocol, ec) 尝试打开一个 TCP 套接字。这里的 protocol 是之前定义的 IPv4 协议(boost::asio::ip::tcp::v4())
  如果打开成功,sock 将变为可用状态,允许进行后续的读写操作。如果失败,ec 将保存错误码和错误信息

创建TCP 服务器端的 acceptor 套接字

int create_acceptor_socket()
{boost::asio::io_context ioc;boost::asio::ip::tcp::acceptor acceptor(ioc);boost::asio::ip::tcp protocol = boost::asio::ip::tcp::v4();boost::system::error_code ec;acceptor.open(protocol, ec);if (ec.value() != 0){std::cout << "false" << std::endl;return ec.value();}return 0;
}
boost::asio::ip::tcp::acceptor acceptor(ioc);

  boost::asio::ip::tcp::acceptor 是一个用于监听客户端连接请求的对象。在这里,acceptor 对象会依赖于 ioc(io_context)来执行其异步操作。acceptor 的作用是等待客户端发起连接,并接受连接。

boost::asio::ip::tcp protocol = boost::asio::ip::tcp::v4();

  boost::asio::ip::tcp::v4() 表示使用 IPv4 协议类型。这里创建了一个表示 IPv4 协议的 protocol 对象。可以理解为告诉 acceptor 套接字它应该使用 IPv4 协议来进行通信。
  Boost.Asio 同时支持 IPv4 和 IPv6,这里选择了 v4(),意味着服务器将只监听 IPv4 地址

acceptor.open(protocol, ec);

  以上代码 是用来打开 acceptor 套接字的函数。在这里,protocol 参数指定了使用的协议(IPv4),ec 用于捕获错误代码。该操作会尝试在指定协议(IPv4)下打开一个套接字,并让其开始监听传入连接的请求。
  如果 acceptor.open() 操作失败,错误信息会被记录在 ec 中。
  这段代码并没有绑定 acceptor 到具体的地址和端口。通常情况下,acceptor.open() 之后,还需要通过 acceptor.bind() 或直接在 acceptor 构造函数中指定一个端点(IP 地址和端口)来完成绑定
  还有一种更加方便的方式创建acceptor 套接字

int create_acceptor_socket()
{boost::asio::io_context ioc;boost::asio::ip::tcp::acceptor a(ioc,boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(),8888));
return 0;
}

acceptor的构造函数接收了两个参数

  1. ioc:即之前创建的 boost::asio::io_context 对象。acceptor 需要依赖它来执行后续的 I/O 操作。
  2. boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 8888):这是一个 endpoint 对象,表示监听的具体地址和端口

创建 acceptor 套接字并绑定

int bind_acceptor_socket()
{boost::asio::io_context ioc;unsigned short prot_num = 8888;boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address_v4::any(), prot_num);boost::asio::ip::tcp::acceptor a(ioc, ep.protocol());boost::system::error_code ec;a.bind(ep,ec);if (ec.value() != 0) {std::cout << "Failed to bind the acceptor socket."<< "Error code = " << ec.value() << ". Message: "<< ec.message();return ec.value();}return 0;
}

为什么这里没有对acceptor的open操作?
  通常情况下,open 操作用来显式地打开一个套接字并指定其协议类型。在之前创建boost::asio::ip::tcp::acceptor对象时只传递了一格参数ioc而没有指定协议类型(是IPV4还是IPV6?),所以需要手动显示open,但是这里boost::asio::ip::tcp::acceptor a(ioc, ep.protocol());创建时传递了协议类型,它就是在构造函数中自动完成open操作

客户端连接到服务器

通过ip地址解析


int connect_to_end()
{unsigned short prot_num = 8888;std::string ip = "127.0.0.1";try{boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address::from_string(ip), prot_num);boost::asio::io_context ioc;boost::asio::ip::tcp::socket sock(ioc, ep.protocol());sock.connect(ep);}catch (const boost::system::system_error& e){std::cout << "Error occured! Error code = " << e.code() << ".Message:" << e.what();return e.code().value();}return 0;
}

通过域名解析

int dns_connect_to_end()
{std::string host = "www.baidu.com";std::string port_num = "8888";boost::asio::io_context ioc;boost::asio::ip::tcp::resolver::query resolver_query(host, port_num, boost::asio::ip::tcp::resolver::query::numeric_service);boost::asio::ip::tcp::resolver resolver(ioc);try{boost::asio::ip::tcp::resolver::iterator it = resolver.resolve(resolver_query);boost::asio::ip::tcp::socket sock(ioc);boost::asio::connect(sock, it);}catch (boost::system::system_error& e){std::cout << "Error occured! Error code = " << e.code() << ".Message:" << e.what() << std::endl;return e.code().value();}return 0;
}
boost::asio::ip::tcp::resolver::query resolver_query(host, port_num, boost::asio::ip::tcp::resolver::query::numeric_service);

  这里创建了一个 resolver_query 对象,指定了要解析的域名 host 和端口号 port_num。
  boost::asio::ip::tcp::resolver::query 是 Boost.Asio 中用于描述解析查询的类,它包含了域名和端口信息,告诉解析器要解析哪个主机的 IP 地址。
  boost::asio::ip::tcp::resolver::query::numeric_service 表示请求解析服务的端口号为数值类型,确保解析器解析的是数字形式的端口号。

boost::asio::ip::tcp::socket sock(ioc);
boost::asio::connect(sock, it);

  boost::asio::ip::tcp::socket sock(ioc) 创建了一个 TCP 套接字 sock,并使用 ioc(I/O 服务对象)进行初始化。
  boost::asio::connect(sock, it) 尝试连接到解析出来的第一个 IP 地址。这里,it 是从 resolver.resolve() 返回的迭代器,表示解析到的 IP 地址列表。connect 会逐个尝试列表中的 IP 地址,直到找到一个能够成功连接的地址。

服务端接收新连接

int accept_new_connection()
{const int BACKLOG_SIZE = 30;boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address_v4::any(), 8888);boost::asio::io_context ioc;try{boost::asio::ip::tcp::acceptor ac(ioc,ep.protocol());ac.bind(ep);ac.listen(BACKLOG_SIZE);boost::asio::ip::tcp::socket sock(ioc);ac.accept(sock);}catch (boost::system::system_error& e){std::cout << "Error occured! Error code = " << e.code() << ".Message:" << e.what() << std::endl;return e.code().value();}return 0;
}

  BACKLOG_SIZE 设置为 30,表示服务器在等待连接时能够排队的最大连接数。这是 TCP 协议栈的一个参数,通常设置为比实际预期连接数稍大的值,防止过多的连接被拒绝。

boost::asio::ip::tcp::socket sock(ioc);
ac.accept(sock);

  boost::asio::ip::tcp::socket sock(ioc); 创建一个新的 TCP 套接字 sock,用于与连接的客户端进行通信。这个套接字是通过 ioc(I/O 上下文)初始化的。
  ac.accept(sock); 调用 accept() 方法等待接受客户端的连接。当有客户端尝试连接到指定端口时,accept() 会阻塞直到接收到连接请求。成功后,sock 就与客户端建立了连接,并且可以用它来进行数据传输。

相关文章:

【C++boost::asio网络编程】有关socket的创建和连接的笔记

socket的创建和连接 tcp客户端创建端点tcp服务端创建端点创建socket创建TCP 服务器端的 acceptor 套接字创建 acceptor 套接字并绑定客户端连接到服务器通过ip地址解析通过域名解析 服务端接收新连接 tcp客户端创建端点 int client_end_point() {std::string raw_ip_address …...

超级灵感:前端页面功能统一管理方案

前端页面功能统一管理方案 引言 我和朋友聊天想到一个灵感&#xff0c;关于支付状态机管理&#xff0c;这个类可以让我们知道具体上一个状态和下一个状态&#xff0c;这是由于那个事件触发改变&#xff0c;这个功能设计非常好&#xff01; 从而讨论出为什么我们不能把某一个…...

力扣第 77 题 组合

题目描述 给定两个整数 n 和 k&#xff0c;返回范围 [1, n] 中所有可能的 k 个数的组合。 你可以按任意顺序返回答案。 示例 示例 1 输入&#xff1a; n 4, k 2输出&#xff1a; [[1, 2], [1, 3], [1, 4], [2, 3], [2, 4], [3, 4]]示例 2 输入&#xff1a; n 1, k …...

(超详细图文)PLSQL Developer 配置连接远程 Oracle 服务

1、下载配置文件 &#xff08;超详细图文详情&#xff09;Navicat 配置连接 Oracle-CSDN博客 将下载的文件解压到单独文件夹&#xff0c;如&#xff1a;D:\App\App_Java\Oracle\instantclient-basic-windows.x64-19.25.0.0.0dbru 2、配置 打开 PLSQL Developer&#xff0c;登…...

元器件选型与参数13 电源的分类-线性电源参数 RT9013 AMS1117 PCB布局布线

目录 一、线性电源 1、重要参数 2、线性电源效率一定低吗 3、线性电源并联扩流 4、常见电路 RT9013-LDO AMS1117-xx-LDO 5、布局布线 6、外置输入与电池供电 7、单片机控制其他模组供电实现低功耗 二、开关电源与线性电源配合 1、高效率与低噪声 DC-DC电源大致分为…...

RHEL7+Oracle11.2 RAC集群-多路径(multipath+udev)安装步骤

RHEL7Oracle11.2RAC集群-多路径&#xff08;multipathudev&#xff09;安装 配置虚拟存储 使用StarWind Management Console软件&#xff0c;配置存储 dggrid1: 1g*3 Dggrid2: 1g*3 Dgsystem: 5g*1 系统表空间&#xff0c;临时表空间&#xff0c;UNDO&#xff0c;参数文件…...

每日速记10道java面试题03

其他资料 每日速记10道java面试题01-CSDN博客 每日速记10道java面试题02-CSDN博客 目录 一、你使用过java的反射机制吗&#xff1f;如何应用反射&#xff1f; 二、什么是泛型&#xff1f;泛型的作用是什么&#xff1f; 三、java的泛型擦除是什么&#xff1f; 四、Java 中…...

Vue 3 的双向绑定原理

Vue 3 的双向绑定原理是基于 响应式系统 和 数据劫持 技术来实现的。在 Vue 3 中&#xff0c;双向绑定通常是通过 v-model 指令来完成的&#xff0c;它本质上是数据的双向同步&#xff1a;当数据改变时&#xff0c;视图自动更新&#xff0c;反之&#xff0c;视图的修改也会更新…...

如何使用 Chrome 无痕浏览模式访问网站?

无痕浏览&#xff08;Incognito Mode&#xff09;是 Google Chrome 浏览器提供的一种隐私保护功能&#xff0c;它允许用户在一个独立的会话中浏览网页&#xff0c;而不会记录用户的浏览历史、下载历史、表单数据等。这对于希望保护个人隐私或进行临时性匿名浏览的用户来说非常有…...

Idea 2024.3 突然出现点击run 运行没有反应,且没有任何提示。

写这篇文章的目的是为了提供一个新的解决思路&#xff0c;因为存在同病不同原因。 如果你进行了1. 检查运行配置 (Run Configuration) 2. 清理和重建项目 3. 清除缓存并重启 IDEA 4.排除kotlin 5.重装idea等等操作之后仍然没有解决&#xff0c;可以试着按一下步骤进行解决。 检…...

【小白学机器学习36】关于独立概率,联合概率,交叉概率,交叉概率和,总概率等 概念辨析的例子

目录 1 先说结论 2 联合概率 3 边缘概率 4 (行/列)边缘概率的和 总概率1 5 条件概率 5.1 条件概率的除法公式 5.2 条件概率和联合概率区别 1 先说结论 关于独立概率&#xff0c;联合概率&#xff0c;交叉概率&#xff0c;交叉概率和&#xff0c;总概率 类型含义 …...

Spring Boot 项目——分层架构

在创建一个 Spring Boot 项目时&#xff0c;为了提高代码的可维护性、可扩展性和清晰度&#xff0c;通常会按照一定的分层架构进行设计。常见的分层架构包括以下几层&#xff1a; 1. Controller 层&#xff08;Web 层&#xff09; 作用&#xff1a;接收用户请求&#xff0c;并…...

wordpress网站首页底部栏显示网站备案信息

一、页脚文件footer.php 例如&#xff0c;wordpress主题使用的是simple-life主题&#xff0c;服务器IP为192.168.68.89,在wordpress主题文件中有个页脚文件footer.php&#xff0c;这是一个包含网站页脚代码的文件。 footer.php 路径如下&#xff1a; /www/wwwroot/192.168.68…...

python面向对象编程练习

学生成绩管理系统 定义一个Student类&#xff0c;包括属性&#xff08;姓名、成绩&#xff09;和方法&#xff08;设置成绩、获取成绩、计算平均成绩&#xff09;。 实例化多个学生对象并调用方法。 功能说明&#xff1a; Student 类&#xff1a; init(self, name)&#xff1a;…...

OpenCV_Code_LOG

孔洞填充 void fillHole(const Mat srcBw, Mat &dstBw) {Size m_Size srcBw.size();Mat TempMat::zeros(m_Size.height2,m_Size.width2,srcBw.type());//延展图像srcBw.copyTo(Temp(Range(1, m_Size.height 1), Range(1, m_Size.width 1)));cv::floodFill(Temp, Point(…...

力扣第 74 题是 搜索二维矩阵

题目描述 给定一个 m x n 的矩阵 matrix 和一个目标值 target&#xff0c;请你编写一个函数来判断目标值 target 是否在矩阵中。 每行的元素按升序排列。每列的元素按升序排列。 示例 1 输入&#xff1a; matrix [[1, 4, 7, 11],[2, 5, 8, 12],[3, 6, 9, 16],[10, 13, 14…...

[极客大挑战 2019]BabySQL--详细解析

信息搜集 进入界面&#xff1a; 输入用户名为admin&#xff0c;密码随便输一个&#xff1a; 发现是GET传参&#xff0c;有username和password两个传参点。 我们测试一下password点位能不能注入&#xff1a; 单引号闭合报错&#xff0c;根据报错信息&#xff0c;我们可以判断…...

实现Linux平台自定义协议族

一 简介 我们常常在Linux系统中编写socket接收TCP/UDP协议数据&#xff0c;大家有没有想过它怎么实现的&#xff0c;如果我们要实现socket接收自定义的协议数据又该怎么做呢&#xff1f;带着这个疑问&#xff0c;我们一起往下看吧~~ 二 Linux内核函数简介 在Linux系统中要想…...

RL78/G15 Fast Prototyping Board Arduino IDE 平台开发过程

这是一篇基于RL78/G15 Fast Prototyping Board的Arduino IDE开发记录 RL78/G15 Fast Prototyping Board硬件简介&#xff08;背景&#xff09;基础测试&#xff08;方法说明/操作说明&#xff09;开发环境搭建&#xff08;方法说明/操作说明代码结果&#xff09;Arduino IDE RL…...

YOLOv11 NCNN安卓部署

YOLOv11 NCNN安卓部署 前言 yolov11 NCNN安卓部署 目前的帧率可以稳定在20帧左右&#xff0c;下面是这个项目的github地址&#xff1a;https://github.com/gaoxumustwin/ncnn-android-yolov11 上面的检测精度很低时因为这个模型只训练了5个epoch&#xff0c;使用3090训练一个…...

在四层代理中还原真实客户端ngx_stream_realip_module

一、模块原理与价值 PROXY Protocol 回溯 第三方负载均衡&#xff08;如 HAProxy、AWS NLB、阿里 SLB&#xff09;发起上游连接时&#xff0c;将真实客户端 IP/Port 写入 PROXY Protocol v1/v2 头。Stream 层接收到头部后&#xff0c;ngx_stream_realip_module 从中提取原始信息…...

LLM基础1_语言模型如何处理文本

基于GitHub项目&#xff1a;https://github.com/datawhalechina/llms-from-scratch-cn 工具介绍 tiktoken&#xff1a;OpenAI开发的专业"分词器" torch&#xff1a;Facebook开发的强力计算引擎&#xff0c;相当于超级计算器 理解词嵌入&#xff1a;给词语画"…...

初探Service服务发现机制

1.Service简介 Service是将运行在一组Pod上的应用程序发布为网络服务的抽象方法。 主要功能&#xff1a;服务发现和负载均衡。 Service类型的包括ClusterIP类型、NodePort类型、LoadBalancer类型、ExternalName类型 2.Endpoints简介 Endpoints是一种Kubernetes资源&#xf…...

无人机侦测与反制技术的进展与应用

国家电网无人机侦测与反制技术的进展与应用 引言 随着无人机&#xff08;无人驾驶飞行器&#xff0c;UAV&#xff09;技术的快速发展&#xff0c;其在商业、娱乐和军事领域的广泛应用带来了新的安全挑战。特别是对于关键基础设施如电力系统&#xff0c;无人机的“黑飞”&…...

如何应对敏捷转型中的团队阻力

应对敏捷转型中的团队阻力需要明确沟通敏捷转型目的、提升团队参与感、提供充分的培训与支持、逐步推进敏捷实践、建立清晰的奖励和反馈机制。其中&#xff0c;明确沟通敏捷转型目的尤为关键&#xff0c;团队成员只有清晰理解转型背后的原因和利益&#xff0c;才能降低对变化的…...

客户案例 | 短视频点播企业海外视频加速与成本优化:MediaPackage+Cloudfront 技术重构实践

01技术背景与业务挑战 某短视频点播企业深耕国内用户市场&#xff0c;但其后台应用系统部署于东南亚印尼 IDC 机房。 随着业务规模扩大&#xff0c;传统架构已较难满足当前企业发展的需求&#xff0c;企业面临着三重挑战&#xff1a; ① 业务&#xff1a;国内用户访问海外服…...

【若依】框架项目部署笔记

参考【SpringBoot】【Vue】项目部署_no main manifest attribute, in springboot-0.0.1-sn-CSDN博客 多一个redis安装 准备工作&#xff1a; 压缩包下载&#xff1a;http://download.redis.io/releases 1. 上传压缩包&#xff0c;并进入压缩包所在目录&#xff0c;解压到目标…...

拟合问题处理

在机器学习中&#xff0c;核心任务通常围绕模型训练和性能提升展开&#xff0c;但你提到的 “优化训练数据解决过拟合” 和 “提升泛化性能解决欠拟合” 需要结合更准确的概念进行梳理。以下是对机器学习核心任务的系统复习和修正&#xff1a; 一、机器学习的核心任务框架 机…...

大数据驱动企业决策智能化的路径与实践

&#x1f4dd;个人主页&#x1f339;&#xff1a;慌ZHANG-CSDN博客 &#x1f339;&#x1f339;期待您的关注 &#x1f339;&#x1f339; 一、引言&#xff1a;数据驱动的企业竞争力重构 在这个瞬息万变的商业时代&#xff0c;“快者胜”的竞争逻辑愈发明显。企业如何在复杂环…...

react菜单,动态绑定点击事件,菜单分离出去单独的js文件,Ant框架

1、菜单文件treeTop.js // 顶部菜单 import { AppstoreOutlined, SettingOutlined } from ant-design/icons; // 定义菜单项数据 const treeTop [{label: Docker管理,key: 1,icon: <AppstoreOutlined />,url:"/docker/index"},{label: 权限管理,key: 2,icon:…...