我读了一些消息队列服务,如RabbitMQ和ZeroMQ,但我觉得他们太复杂了,觉得它是分布式系统诞生的.我的系统的所有部分都将用C / Linux编写,放在一个小型的RaspBerry Pi cpu上,所以我不需要可扩展的,跨平台的,其他语言的客户端的功能…
你能给我一些关于满足我需要的服务或图书馆的建议吗？或者你
谢谢.
解决方法
首先需要定义要使用的协议.这可以很简单像只是消息类型字段,有效载荷大小字段和实际有效载荷.您需要的消息类型订阅,不支持和发布. SUBSCRIBE和UNSUBSCRIBE消息的有效载荷是要订阅/取消订阅的通道的名称. PUBLISH消息的有效载荷是通道名称和实际数据(连同当然数据的大小).
要连接所有订阅者,您需要一个中央服务器.所有订阅者/发布商都需要连接到此服务器.服务器程序保留队列的集合,每个通道一个.当订阅或发布消息到达不存在的频道的服务器时,为此频道创建一个新的消息队列.对于每个通道,服务器还需要所有订阅该通道的客户端的集合.当发布消息到达服务器时,它会被添加到相关通道的队列结尾.当频道队列不为空时,将其副本发送给该频道的所有订阅者,并且当所有订阅者接收到该频道时,可以从该队列中删除该消息.
服务器的硬件部分可能将成为通信部分.容易的部分将是所有队列和集合,因为您可以使用所有的队列(例如std::queue为实际队列,std::unordered_map为频道,std::vector为连接的客户端集合).
客户端非常简单,所有需要做的是能够将订阅和发布消息发送到服务器,并从服务器接收发布消息.硬部分将再次成为实际的沟通部分.
后记：
我从来没有真正建立过这样一个系统,我的所有上述都只是我头顶的直接.有经验的程序员不应该需要超过几个小时的时间来实现基础知识,也许需要几天的时间才能使用经验不足的程序员.
对于通信,您可以使用例如Boost ASIO,每个频道可能使用一个threads.您可以使用像Boost property tree这样的东西来构建/解析JSON或XML消息.
然而,所有这一切都是重新发明的,当您可能在几个小时内开始使用RabbitMQ之类的现有系统之一时,可以节省大量时间(而且还有很多错误)！
原文地址：https://www.jb51.cc/c/113858.html
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
