19.3 Boost Asio 多线程通信

news2024/11/24 2:06:33

多线程服务依赖于两个通用函数,首先boost::bind提供了一个高效的、简单的方法来创建函数对象和函数对象适配器,它的主要功能是提供了一种将函数和它的参数绑定到一起的方法,这种方法可以将具有参数的成员函数、普通函数以及函数对象转化为不带参数的函数对象。

当参数绑定后则下一步就需要使用多线程功能,Boost库中提供了boost::thread库,boost::thread可以用于创建线程、启动线程、等待线程执行结束以及线程间通信等多种操,有了这两个关键库那么我们只需要accept.accept(*sock)等待套接字上线,当有套接字上线后则自动创建MyThread子线程,使用该子线程维持会话,首先是服务端实现代码。

#include <iostream>
#include <boost/asio.hpp>
#include <boost/thread.hpp>

using namespace boost::asio;

std::string addr = "127.0.0.1";

// 创建子线程
void MyThread(boost::shared_ptr<ip::tcp::socket> socket)
{
  // 获取当前IP信息
  std::string local_address = socket->local_endpoint().address().to_string();
  while (true)
  {
    try
    {
      if (addr == local_address)
      {
        char data[512];
        size_t len = socket->read_some(buffer(data));
        std::cout << data << std::endl;
      }
    }
    catch (boost::system::system_error e)
    {
      return;
    }
  }
}

int main(int argc, char* argv[])
{
  typedef boost::shared_ptr<ip::tcp::socket> socket_ptr;
  io_service service;

  // 绑定IP与端口地址
  ip::tcp::endpoint ep(ip::tcp::v4(), 6666);
  ip::tcp::acceptor accept(service, ep);

  while (true)
  {
    socket_ptr sock(new ip::tcp::socket(service));

    // 侦听套接字
    accept.accept(*sock);

    // 绑定套接字参数
    boost::function0<void> function = boost::bind(MyThread, sock);

    // 创建新的子线程
    boost::thread threading(function);
  }

  system("pause");
  return 0;
}

客户端代码如下所示,由于客户端无需实现多线程所以代码中只需要简单的调用socket.connect()链接到服务端,并调用write_some发送一条消息即可,代码如下图所示;

#include <iostream>
#include <string>
#include <boost/asio.hpp>

using namespace boost::asio;

int main(int argc, char *argv[])
{
  io_service io_service;
  ip::tcp::endpoint ep(ip::address::from_string("127.0.0.1"), 6666);
  ip::tcp::socket socket(io_service);

  // 链接到服务端
  socket.connect(ep);

  char buffer[1024] = "hello lyshark";

  socket.write_some(boost::asio::buffer(buffer, 1024));

  system("pause");
  return 0;
}

运行上方服务端代码,然后开启三个客户端代码,读者可自行观察通信状态,此时三个客户端均实现了输出,如下图所示;

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1161945.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

日常笔记工具搭档(Typora、Snipaste)

一、Typora 啥也不说了直接上图 Markdown语法 Typora免费版 提取码&#xff1a;av01 二维码&#xff1a; 1&#xff09;页面展示 2&#xff09;主题 3&#xff09;偏好设置 4&#xff09;Markdown语法设置偏好 5&#xff09;编辑器 6&#xff09;系统 二、Snipaste Snipaste…

中国电子云-隐私计算-云原生安全可信计算,物理-硬件-系统-云产品-云平台,数据安全防护

目录 联邦学习的架构思想 中国电子云-隐私计算-云原生安全 可信计算&#xff0c;物理-硬件-系统-云产品-云平台&#xff0c;数据安全防护 全栈国产信创的意义 1. 提升科技创新能力 2. 推动经济发展 3. 加强信息安全与自主可控 全栈国产信创的重要领域 1. 人工智能 2.…

Nginx简介,Nginx搭载负载均衡以及Nginx部署前端项目

目录 一. Nginx简介 Nginx的优点 二. Nginx搭载负载均衡 2.1 Nginx安装 2.1.1 安装依赖 2.1.2 解压nginx安装包 2.1.3 安装nginx 2.1.4 启动nginx服务 2.2 tomcat负载均衡 2.3 Nginx配置 三. Nginx前端部署 一. Nginx简介 NGINX&#xff08;读作&#xff1a;engi…

阿里云2023年双十一活动各云产品活动内容及优惠政策汇总

阿里云2023双十一活动各云产品有哪些新购和续费优惠政策&#xff1f;小编看了一下阿里云2023年的双十一活动&#xff0c;活动分为主会场和8个云产品分会场&#xff0c;涉及的云产品涵盖了云服务器、云数据库、云存储、云网络、大数据Al、云原生、云安全等几乎所有阿里云产品&am…

技能get-ps抠颜色一样的图

公司要插个小图片&#xff0c;从网上down下来的图片是不过是jpg的&#xff0c;背景不透明&#xff0c;这时候可以使用ps工具把这种同一颜色的内容扣下来。 操作步骤&#xff1a; 选择-色彩范围&#xff0c;然后用取样器取颜色&#xff0c;再调节拉条选取颜色范围&#xff0c;最…

客户收到样品后“消失”,怎么破?

对于大部分外贸人来说&#xff0c;谈客户几乎不是一次性谈成的&#xff0c;而是要进行多次的沟通。在沟通过程中难免会遇到各种问题&#xff0c;一些小问题容易解决&#xff0c;但有一些棘手的问题却不知该如何下手。 比如&#xff1a; ①客户收到样品后就“消失”&#xff0c…

某数据库为提升搜索效率,对某一整型字段构建二叉搜索树(BST)

声明&#xff1a;下面的方法不一定正确&#xff0c;个人学习过程中所写&#xff0c;并未做大量测试&#xff0c;仅供参考&#xff0c;应该有BUG&#xff0c;暂时不改了。 描述&#xff1a;某数据库为提升搜索效率&#xff0c;对某一整型字段构建二叉搜索树(BST)。每个结点包含…

07、vue : 无法加载文件 C:\Users\JH\AppData\Roaming\npm\vue.ps1,因为在此系统上禁止运行脚本。

目录 问题解决&#xff1a; 问题 vue : 无法加载文件 C:\Users\JH\AppData\Roaming\npm\vue.ps1&#xff0c;因为在此系统上禁止运行脚本。 在使用 VSCode 时&#xff0c;创建 Vue 项目报的错 创建不了 Vue 项目 解决&#xff1a; 因为在此系统上禁止运行该脚本&#xff0…

[ 云计算 | AWS 实践 ] 使用 Java 列出存储桶中的所有 AWS S3 对象

本文收录于【#云计算入门与实践 - AWS】专栏中&#xff0c;收录 AWS 入门与实践相关博文。 本文同步于个人公众号&#xff1a;【云计算洞察】 更多关于云计算技术内容敬请关注&#xff1a;CSDN【#云计算入门与实践 - AWS】专栏。 本系列已更新博文&#xff1a; [ 云计算 | …

利用工业视频AI分析,能否消除企业生产安全隐患?

讲个去年11月的案例&#xff0c;某家工厂发生火灾&#xff0c;直接导致38人死亡和2人受伤。然后在今年2月&#xff0c;某家新能源汽车公司发生机械伤害事故&#xff0c;导致1人死亡。4月&#xff0c;一家船厂发生生产安全事故&#xff0c;造成7人死亡和5人受伤。5月&#xff0c…

5.4 可靠传输的工作原理

思维导图&#xff1a; 5.4 可靠传输的工作原理 前言概述 TCP与IP层的关系&#xff1a;TCP负责发送报文段&#xff0c;而IP层负责传送这些报文段。IP层仅提供“尽最大努力服务”&#xff0c;本质上是不可靠的传输。TCP的责任&#xff1a;为了弥补IP层的不可靠性&#xff0c;TC…

springboot的请求与响应

一&#xff0c;简单参数 Get请求&#xff1a;只需要在postman中的Params参数与方法中的形参一致就可以Post请求与Get方法一致只需要在 如果参数名不一致--通过RequestParam中的value属性执行请求参数名 RequestParam(name "name",required false) //表示name参数不是…

安装VMware后无VMnet1和VMnet8网卡

问题描述 通过进入 按键盘&#xff08;WINR&#xff09;&#xff0c;输入cmd&#xff0c;进入管理员页面 输入ipconfig,没有vmnet1和vmnet8 进入电脑--->更改适配器&#xff08;也无vmnet1和vmnet8&#xff09; 一&#xff0c;解决方法1 直接还原vmware网络设置。 还原成…

WIN10专业版64位22H2正式版19045.3324 简体中文版、英文版

微软在面向 Win10 21H2/22H2 发布了累积更新 KB5029244 之外&#xff0c;在更新日志中也表示&#xff0c;也为包括 1809&#xff0c;1607 和 1507 在内的功能更新提供了累积更新。 IT之家在此附上 Win10 Build 19044.3324 和 Build 19045.3324 更新内容如下&#xff1a; 修复了…

【行云流水线实践】基于“OneBuild”方法对镜像进行快速装箱 | 京东云技术团队

在云原生领域&#xff0c;无论使用哪种编排调度平台&#xff0c;Kubernetes&#xff0c;DockerSwarm&#xff0c;OpenShift等&#xff0c;业务都需要基于镜像进行交付&#xff0c;我们在内部实践“Source-to-image”和链式构建&#xff0c;总而总结出“OneBuild”模式。 其核心…

HT3163 免电感滤波 音频功率放大器工作原理

HT3163是一款G效AB/D类音频功率放大器。在D类模式&#xff0c;18V供电、THDN10%条件下&#xff0c;能够持续提供40W/4Ω功率输出。在AB类模式&#xff0c;12V供电、THDN10%条件下&#xff0c;能够持续输出17W/4Ω功率。 HT3163具有防削顶失真&#xff08;ACF&#xff09;输出控…

第02章-变量与运算符

1 关键字 关键字&#xff1a;被Java语言赋予了特殊含义&#xff0c;用作专门用途的字符串&#xff08;或单词&#xff09;。如class、public、static、void等&#xff0c;这些单词都被Java定义好了&#xff0c;称为关键字。 特点&#xff1a;关键字都是小写字母&#xff1b;官…

中国长城-安全防护-硬件,软件,细粒度权限划分-等级保护,人员意识

目录 等级保护 安全防护 中国长城-安全防护 硬件&#xff0c;软件&#xff0c;细粒度权限划分-等级保护&#xff0c;人员意识 等级保护 安全防护 建立安全管理制度&#xff1a;制定信息安全政策&#xff0c;明确安全管理职责&#xff0c;建立安全培训和考核机制&#xff0c…

Mgeo:multi-modalgeographic language model pre-training

文章目录 question5.1 Geographic Encoder5.1.1 Encoding5.1.2 5.2 multi-modal pre-training 7 conclusionGeo-Encoder: A Chunk-Argument Bi-Encoder Framework for Chinese Geographic Re-Rankingabs ERNIE-GeoL: A Geography-and-Language Pre-trained Model and its Appli…

开发第一个flutter app的六个关键步骤

Flutter这些年发展的很快&#xff0c;特别是在 Google 持续的加持下&#xff0c;Flutter SDK 的版本号已经来到了 3开头&#xff0c;也正式开始对 Windows、macOS 和 Linux 桌面环境提供支持。如果从 Flutter 特有的优势来看&#xff0c;我个人认为主要是它已经几乎和原生的性能…