模板消息速度_分享一个可用于本地组播消息的SPMC队列

水深无声 2022-11-19 12:41 30阅读 0赞

在一些场景下我们需要把消息发送给多个接收者，并且基于简单和高效的角度，发送者不需要等待接收者，也不用支持消息重传，甚至不用知道接收者的存在，它只需要根据预定的节奏发消息就行了；对于接收者来说，它需要确保消息处理速度能跟上发送速度，否则可能出现消息丢失，因此应用层也需要能够容忍一定程度的消息丢失。

这种场景的一个典型应用就是交易行业的行情分发，交易所把行情消息分发给各个broker，broker再分发给客户，客户自己也可以内部再次分发。基于网络的行情分发最适合的方式自然是组播，但很多时候我们也需要在同一台机器内部进行消息分发，这可以是线程间的也可以是进程间的，此时就无法使用常规的udp组播方式了。本文分享一个用于解决这个问题的SPMC（单生产者多消费者）队列：

MengRao/SPMC\_Queuegithub.com

![024b803da2ffcc14d9b29cb13e4b5351.png][]

SPMCQueue这是一个单头文件的C++模板类，支持固定长度的消息类型，实现非常简单，总共只有50行代码，且不包含其他头文件。这个队列可用于线程间通信，也能支持基于共享内存的进程间通信。SPMCQueue的使用也很简单，写不超过10行代码就能用起来：

定义一个消息类型为`int`，长度为1024的队列：

SPMCQueue<int, 1024> q;

对于生产者，发送一个消息：

q.write([](int& msg){
         
      msg = 123;
    });

对于消费者，每一个消费者需要先获得一个`Reader` 对象：

auto reader = q.getReader();

然后以非阻塞的方式轮询读取最新的消息：

int* msg = reader.read();
    if (msg) {
         
      std::cout << "msg: "<< *msg << std::endl;
    }

进程间通信的用法可以参考项目中的example。

性能方面的话，可以不用担心。

以上。

[024b803da2ffcc14d9b29cb13e4b5351.png]: /images/20221119/6497ae8d7c174003be33f67f38a847d4.png

发表评论取消回复

表情：

评论列表（有 0 条评论，30人围观）

还没有评论，来说两句吧...

相关阅读

相关如何设计一个消息队列

如何设计一个消息队列 * 前言 * 面试官心理分析 * 面试题剖析前言在面试中，消息队列也是经常被考察的点，本文中我们将要来分析的面试题是...

亦凉/ 2024年04月17日 14:13/ 0 赞/ 63 阅读

相关消息队列中的事务消息

大家好，我是易安！今天我们谈一谈消息队列中的事务消息这个话题。一说起事务，你可能自然会联想到数据库。我们日常使用事务的场景，绝大部分都是在操作数据库的时候。像MySQL、O

Dear 丶/ 2024年03月22日 13:37/ 0 赞/ 57 阅读

相关消息队列用于故障记录

1、不加处理CTL+C退出删除消息队列处理编译：gcc progress2.c -o progress1 -lpthread -lrt

柔情只为你懂/ 2023年01月18日 02:25/ 0 赞/ 101 阅读

相关模板消息速度_分享一个可用于本地组播消息的SPMC队列

在一些场景下我们需要把消息发送给多个接收者，并且基于简单和高效的角度，发送者不需要等待接收者，也不用支持消息重传，甚至不用知道接收者的存在，它只需要根据预定的节奏发消息就行了；

╰半橙微兮°/ 2023年01月06日 01:39/ 0 赞/ 87 阅读

相关消息队列用于双向进程通信

progressA.c include <stdio.h> include <unistd.h> include <stdlib.h> inc

系统管理员/ 2022年12月21日 15:54/ 0 赞/ 145 阅读

相关消息队列

1. 消息队列在项目中的使用背景：在分布式系统中是如何处理高并发的。由于在高并发的环境下，来不及同步处理用户发送的请求，则会导致请求发生阻塞。比如说，大量的ins

﹏ヽ暗。殇╰゛Y/ 2022年12月15日 03:23/ 0 赞/ 278 阅读

相关模板消息速度_分享一个可用于本地组播消息的SPMC队列

在一些场景下我们需要把消息发送给多个接收者，并且基于简单和高效的角度，发送者不需要等待接收者，也不用支持消息重传，甚至不用知道接收者的存在，它只需要根据预定的节奏发消息就行了；

水深无声/ 2022年11月19日 12:41/ 0 赞/ 31 阅读

相关消息队列用于线程间通信

我们知道，消息队列是进程间通信的方法之一，当然，消息队列也可以用于线程间通信。进程间通信的时候，我们需要使用ftok()函数创建同一个key值，线程间通信时，我们可以不

骑猪看日落/ 2022年10月06日 15:57/ 0 赞/ 146 阅读

相关进程的消息通信、消息队列

文章目录 1. 代码详解 1.1清楚两个概念 1.2 消息队列通信过程（五步） 1 生成一个键值

悠悠/ 2022年04月23日 17:08/ 0 赞/ 441 阅读

相关消息和消息队列

每个事件的操作系统被打包成一个称为消息结构MSG要传递给应用 typedef struct tagMSG { HWND hwnd;

超、凢脫俗/ 2022年03月28日 08:42/ 0 赞/ 361 阅读