C++编程: 使用 Nanomsg 进行 PUB-SUB 模式基准测试

文章目录

    • 0. 引言
    • 1. Nanomsg简介
      • 1.1 可扩展性协议类型
      • 1.2 支持的传输机制
      • 1.3 NanoMsg 架构与实现
    • 2. PUB-SUB 模式基准测试

0. 引言

Nanomsg 作为一款高性能的通信库,支持多种消息传递模式,其中包括 PUB-SUB(发布-订阅)。
本篇文章将介绍如何使用 NanoMsg 库来实现一个简单的 PUB-SUB 模式的基准测试程序,该程序能够测量消息从发布到订阅的平均延迟。

扩展阅读:开源库Nanomsg和Iceoryx发布订阅模式的性能对比

1. Nanomsg简介

1.1 可扩展性协议类型

NanoMsg 提供了以下几种通信模式:

  • PAIR:简单的点对点通信。
  • BUS:多对多的通信。
  • REQREP:请求-响应模式,适合构建无状态的集群。
  • PUBSUB:发布-订阅模式,将消息分发给订阅者。
  • PIPELINE:汇聚来自多个源的消息,并在多个目标之间进行负载均衡。
  • SURVEY:允许一次性查询多个应用程序的状态。

1.2 支持的传输机制

NanoMsg 支持以下传输机制:

  • INPROC:进程内的传输(线程、模块等之间)。
  • IPC:同一台机器上的进程间传输。
  • TCP:通过 TCP 网络传输。

1.3 NanoMsg 架构与实现

NanoMsg 的代码架构清晰,主要分为以下几个模块:

  • nn.h:对外暴露的 API 接口。
  • transport.h:通信层定义,允许用户实现扩展。
  • protocol.h:协议层定义,用户可以根据需要实现扩展。
  • utils:实用工具包,包括基本的数据结构、互斥锁和原子操作等。
  • transports:通信层实现,包括 inproc、ipc 和 tcp 通信。
  • protocols:协议层实现,包括 REQREP、PUBSUB 等。
  • core:通用代码。
  • aio:线程池模拟的异步操作,带有状态机的事件驱动模型。

2. PUB-SUB 模式基准测试

为了进一步展示 Nanomsg 在实际应用中的效果,这里提供了一个简单的 PUB-SUB 模式的基准测试程序。该程序可以测量消息从发布到订阅的平均延迟。

// pub_sub_benchmark.cpp
#include <nanomsg/nn.h>
#include <nanomsg/pubsub.h>
#include <iostream>
#include <thread>
#include <chrono>
#include <vector>
#include <numeric>using namespace std::chrono;const char* URL = "ipc:///tmp/pubsub.ipc";
const int NUM_MESSAGES = 10000;
const int MESSAGE_SIZE = 128;void publisher() {int sock = nn_socket(AF_SP, NN_PUB);nn_bind(sock, URL);char message[MESSAGE_SIZE] = "Benchmark message";std::this_thread::sleep_for(seconds(1)); // Wait for subscribers to connectfor (int i = 0; i < NUM_MESSAGES; ++i) {int bytes = nn_send(sock, message, MESSAGE_SIZE, 0);if (bytes < 0) {std::cerr << "Error sending message: " << nn_strerror(nn_errno()) << std::endl;return;}std::this_thread::sleep_for(microseconds(100)); // Throttle messages}nn_close(sock);
}void subscriber(std::vector<duration<double, std::micro>>& latencies) {int sock = nn_socket(AF_SP, NN_SUB);nn_connect(sock, URL);nn_setsockopt(sock, NN_SUB, NN_SUB_SUBSCRIBE, "", 0);char* buf = nullptr;for (int i = 0; i < NUM_MESSAGES; ++i) {auto start = high_resolution_clock::now();int bytes = nn_recv(sock, &buf, NN_MSG, 0);auto end = high_resolution_clock::now();if (bytes < 0) {std::cerr << "Error receiving message: " << nn_strerror(nn_errno()) << std::endl;nn_freemsg(buf);return;}latencies.push_back(end - start);nn_freemsg(buf);}nn_close(sock);
}int main() {std::vector<duration<double, std::micro>> latencies;std::thread pub_thread(publisher);std::thread sub_thread(subscriber, std::ref(latencies));pub_thread.join();sub_thread.join();if (!latencies.empty()) {double total_latency = std::accumulate(latencies.begin(), latencies.end(), 0.0,[](double sum, const duration<double, std::micro>& d) { return sum + d.count(); });double avg_latency = total_latency / latencies.size();std::cout << "Average latency: " << avg_latency << " microseconds" << std::endl;}return 0;
}

执行结果:
本文测试机的硬件信息请查看 python或者shell获取系统信息
在这里插入图片描述
平均延迟是7.8ms

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

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

相关文章

yolov8环境安装

一、Miniconda Conda 是一个开源的包管理和环境管理系统&#xff0c;它能运行、安装和更新各种包和依赖&#xff0c;同时还能创建隔离的环境。 1.1 下载安装 Miniconda https://repo.anaconda.com/miniconda/Miniconda3-py39_24.5.0-0-Windows-x86_64.exe1.2 打开 Anaconda …

向量数据库(一)

写在前面 最近在学习一些 AI 相关的开发&#xff0c;了解了一些未接触过的东西&#xff0c;其中有一部分是向量数据库&#xff0c;想开一个专题&#xff0c;对相关的内容做一下整理。 内容 什么是向量数据库 一般在我们的日常开发中&#xff0c;使用的数据库存储主要有两种…

面试题-Redis

Redis部分 讲一下你理解的Redis&#xff0c;为什么Redis很快 Redis是一种高性能的&#xff0c;开源的&#xff0c;C语言编写的非关系型数据库&#xff0c;可以对关系型数据库起到补充作用&#xff0c;同时支持持久化&#xff0c;可以将数据同步保存到磁盘 说Redis很快是相对…

Matlab进阶绘图第65期—带分组折线段的柱状图

带分组折线段的柱状图是在原始柱状图的基础上&#xff0c;在每组柱状图位置处分别添加折线段&#xff0c;以进行对比或添加额外信息。 由于Matlab中未收录带分组折线段的柱状图的绘制函数&#xff0c;因此需要大家自行设法解决。 本文使用自制的BarwithGroupedLine小工具进行…

大模型算法面试题(十四)

本系列收纳各种大模型面试题及答案。 1、微调后的模型出现能力劣化&#xff0c;灾难性遗忘是怎么回事 微调后的模型出现能力劣化&#xff0c;灾难性遗忘&#xff08;Catastrophic Forgetting&#xff09;是一个在机器学习领域&#xff0c;尤其是在深度学习和大模型应用中频繁出…

数据库(MySQL)-DQL数据查询语言

DQL(Data Query Language 数据查询语言)的用途是查询数据库数据&#xff0c;如select语句。其中&#xff0c;可以根据表的结构和关系分为单表查询和多表联查。 单表查询 单表查询&#xff1a;针对数据库中的一张数据表进行查询 全字段查询 语法&#xff1a;select 字段名 fro…

报警系统与机房动力环境监控系统的集成及报警功能实施

在当今的运维行业中&#xff0c;确保关键基础设施的安全与稳定运行面临着诸多挑战&#xff0c;如设备故障、环境异常、非法入侵等。为了有效应对这些挑战&#xff0c;报警系统与机房动力环境监控系统的集成变得至关重要。本文旨在为运维团队提供关于报警系统与机房动力环境监控…

使用frrouting、gns3、pim实现ipv6组播(三)

翻遍整个网络都没有找到用ipv6进行组播推流的实例。 朋友说&#xff1a;A true strong person never complains about the environment 那么&#xff0c;就由我来创造一个吧~ 此文涉及到的所有软件均为开源软件&#xff0c;进行深入学习与其他平台移植时十分便利。 记得点赞额…

25考研数据结构复习·6.2图的存储及基本操作

邻接矩阵 数组实现的顺序存储&#xff0c;空间复杂度高&#xff0c;不适合存储稀疏图 &#x1f469;‍&#x1f4bb; 如何求顶点的度、入度、出度&#xff1f; 无向图 第i个结点的度 第i行&#xff08;或第i列&#xff09;的非零元素个数。有向图 第i个结点的出度 第i行非零…

如何在GPU服务器上安装Stable Diffusion webUI

一、前提条件 1、硬件条件 GPU&#xff1a;12G&#xff0c;建议16G以上&#xff0c;还是尽量勾搭&#xff0c;好像现在最大32G&#xff0c;目前个人性价比24G有时长出售。 内存&#xff1a;16G以上&#xff0c;建议32G&#xff0c;也是越大越好。 硬盘&#xff1a;最好使用…

2024年【金属非金属矿山(地下矿山)安全管理人员】考试报名及金属非金属矿山(地下矿山)安全管理人员模拟考试

题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 2024年金属非金属矿山&#xff08;地下矿山&#xff09;安全管理人员考试报名为正在备考金属非金属矿山&#xff08;地下矿山&#xff09;安全管理人员操作证的学员准备的理论考试专题&#xff0c;每个月更新的金属非…

抖音矩阵管理系统功能说明:一站式掌握

在当下这个信息爆炸的时代&#xff0c;抖音作为短视频领域的佼佼者&#xff0c;其用户规模持续扩大&#xff0c;影响力日益增强。对于内容创作者和营销人员来说&#xff0c;如何高效管理抖音账号&#xff0c;实现内容的多平台分发和精准触达&#xff0c;成为了亟待解决的问题。…

Redis常用指令(不定期更新)

Redis常用指令&#xff08;不定期更新&#xff09; 查询指定前缀key的数量查看键空间事件开启键空间通知 查询指定前缀key的数量 查询【TEST前缀】的key数量 EVAL "return #redis.call(keys,TEST:*)" 0返回信息 查看键空间事件 config get notify-keyspace-even…

Navicat Charts Creator for Mac:数据可视化利器

Navicat Charts Creator for Mac是一款专为Mac用户设计的数据可视化工具&#xff0c;它将复杂的数据转化为直观、易懂的图表&#xff0c;帮助用户更好地理解和分析数据。 该软件支持连接到多种数据库&#xff0c;如MySQL、MariaDB、PostgreSQL等&#xff0c;轻松获取实时数据&…

【QGroundControl二次开发】七.QGC自定义MAVLink消息MavLink通信协议 C++应用

1. 接收解析源码分析 通过接收串口或UDP发来的的字节流buffer&#xff0c;长度lengthbuffer.size()&#xff0c;通过下列脚本解析&#xff0c;每解析出一个mavlink数据包就执行onMavLinkMessage函数 for(int i 0 ; i < length ; i){msgReceived mavlink_parse_char(MAVL…

边集数组的存储和访问的完整代码

使用到的数据结构&#xff1a; struct eage {ll u,v,w;};//存储起点&#xff0c;重点&#xff0c;边权de数据类型 eage e[N];//开数组 ll m;//一共m条边 bool vis[N];//防止死循环&#xff0c;在dfs之前判断一下有没有走过 #include <bits/stdc.h>using namespace std; …

【Python】在CentOS 7上安装Python 3.9

在CentOS 7上安装Python 3.9.6的详细指南 本文将详细介绍如何在CentOS 7系统上安装Python 3.9。通过执行以下步骤&#xff0c;你可以顺利完成安装&#xff0c;并配置相关环境变量。 1. 准备环境 首先&#xff0c;我们需要安装开发工具和一些必要的依赖项。这些工具和库将帮助…

MySQL中,除了使用LIKE进行模糊搜索外,还有其他几种方法可以执行搜索操作

在PHP和MySQL中&#xff0c;除了使用LIKE进行模糊搜索外&#xff0c;还有其他几种方法可以执行搜索操作&#xff0c;具体使用哪种方法取决于你的具体需求&#xff08;如性能、精确度、查询的复杂性等&#xff09;。以下是一些常用的搜索方法&#xff1a; REGEXP 或 RLIKE&…

VS2022下安装和配置OpenCV环境参数+QT开发环境搭建

1.工具准备 VS2022,OpenCV4.5.5版本&#xff0c;QT5.12.12 VisualStudio最新版直接官网下载&#xff0c;根据需要进行下载&#xff0c;我下载的免费社区版本。日常开发完全够用。 qt官网下载5.12版本。 OpenCVReleases - OpenCV 选择Windows版本下载并解压到本地磁盘&#xff0…

在Spring项目中使用Maven和BCrypt来实现修改密码功能

简介 在数字时代&#xff0c;信息安全的重要性不言而喻&#xff0c;尤其当涉及到个人隐私和账户安全时。每天&#xff0c;无数的用户登录各种在线服务&#xff0c;从社交媒体到银行账户&#xff0c;再到电子邮件和云存储服务。这些服务的背后&#xff0c;是复杂的系统架构&am…