Yos*_*shi 13 c++ linux message-queue static-libraries publish-subscribe
我正在构建一个包含许多部分的小型系统,我想使用消息pub/sub服务在各部分之间进行通信.
我读到了一些像RabbitMQ和ZeroMQ这样的消息队列服务,但我觉得它们太复杂了,感觉它是为分布式系统而生的.我的系统的所有部分都将用C++/Linux编写并放在一个小型的Raspberry Pi CPU上,因此我不需要像可扩展,跨平台,其他语言客户端这样的功能......
你们能给我一些适合我需要的服务或图书馆的建议吗？
实际上做自己并不难.
首先,您需要定义要使用的协议.它可以很简单; 就像消息类型字段,有效负载大小字段和实际有效负载一样.您需要的消息类型SUBSCRIBE,UNSUBSCRIBE以及PUBLISH.SUBSCRIBE和UNSUBSCRIBE消息的有效负载是订阅/取消订阅的频道的名称.PUBLISH消息的有效负载是通道名称和实际数据(当然还有数据大小).
要连接所有订户,您需要一个中央服务器.所有订阅者/发布者都需要连接到此服务器.服务器程序保留一组队列,每个通道一个.当订阅或发布消息到达服务器以查找不存在的通道时,请为此通道创建新的消息队列.对于每个通道,服务器还需要订阅该通道的所有客户端的集合.当发布消息到达服务器时,它会被添加到相关频道的队列末尾.当通道队列不为空时,将其副本发送给该通道的所有订户,并且当所有订户都收到该通道时,可以从队列中删除该消息.
服务器的难点可能是通信部分.简单的部分将是所有队列和集合,因为您可以为所有队列使用C++标准容器(例如std::queue,实际队列,std::unordered_map通道和std::vector连接客户端的集合.)
客户端非常简单,所有需要做的就是能够发送订阅并将消息发布到服务器,并从服务器接收发布消息.困难的部分将再次成为实际的沟通部分.
后记:
我从来没有真正建立过这样一个我自己的系统,所有上述内容都只是我的头脑.经验丰富的程序员不需要花费几个小时来实现基础知识,对于缺乏经验的程序员来说可能需要几天时间.
对于您可以使用的通信,例如Boost ASIO,可能每个通道使用一个线程.并且您可以使用类似Boost属性树的内容来构造/解析JSON或XML消息.
然而,当你可能在几个小时内开始使用像RabbitMQ这样的现有系统时,所有这些都重新发明了轮子,为你节省了大量的时间(以及很多错误!)