c – 需要一个轻量级的pubsub服务库

概述我正在构建一个包含很多部分的小型系统,并且我想使用消息pub / sub服务来在部件之间进行通信. 我读了一些消息队列服务,如RabbitMQ和ZeroMQ,但我觉得他们太复杂了,觉得它是分布式系统诞生的.我的系统的所有部分都将用C / Linux编写,放在一个小型的Raspberry Pi CPU上,所以我不需要可扩展的,跨平台的,其他语言的客户端的功能… 你能给我一些关于满足我需要的服务或图书 我正在构建一个包含很多部分的小型系统,并且我想使用消息pub / sub服务来在部件之间进行通信.

我读了一些消息队列服务,如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之类的现有系统之一时,可以节省大量时间(而且还有很多错误)！

总结

以上是内存溢出为你收集整理的c – 需要一个轻量级的pubsub服务/库全部内容，希望文章能够帮你解决c – 需要一个轻量级的pubsub服务/库所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。