c – 需要一个轻量级的pubsub服务/库
|
我正在构建一个包含很多部分的小型系统,并且我想使用消息pub / sub服务来在部件之间进行通信.
我读了一些消息队列服务,如RabbitMQ和ZeroMQ,但我觉得他们太复杂了,觉得它是分布式系统诞生的.我的系统的所有部分都将用C / Linux编写,放在一个小型的Raspberry Pi CPU上,所以我不需要可扩展的,跨平台的,其他语言的客户端的功能… 你能给我一些关于满足我需要的服务或图书馆的建议吗？或者你 谢谢. 解决方法
实际上并不困难.
首先需要定义要使用的协议.这可以很简单像只是消息类型字段,有效载荷大小字段和实际有效载荷.您需要的消息类型订阅,不支持和发布. SUBSCRIBE和UNSUBSCRIBE消息的有效载荷是要订阅/取消订阅的通道的名称. PUBLISH消息的有效载荷是通道名称和实际数据(连同当然数据的大小). 要连接所有订阅者,您需要一个中央服务器.所有订阅者/发布商都需要连接到此服务器.服务器程序保留队列的集合,每个通道一个.当订阅或发布消息到达不存在的频道的服务器时,为此频道创建一个新的消息队列.对于每个通道,服务器还需要所有订阅该通道的客户端的集合.当发布消息到达服务器时,它会被添加到相关通道的队列结尾.当频道队列不为空时,将其副本发送给该频道的所有订阅者,并且当所有订阅者接收到该频道时,可以从该队列中删除该消息. 服务器的硬件部分可能将成为通信部分.容易的部分将是所有队列和集合,因为您可以使用所有的队列(例如 客户端非常简单,所有需要做的是能够将订阅和发布消息发送到服务器,并从服务器接收发布消息.硬部分将再次成为实际的沟通部分. 后记： 我从来没有真正建立过这样一个系统,我的所有上述都只是我头顶的直接.有经验的程序员不应该需要超过几个小时的时间来实现基础知识,也许需要几天的时间才能使用经验不足的程序员. 对于通信,您可以使用例如Boost ASIO,每个频道可能使用一个threads.您可以使用像Boost property tree这样的东西来构建/解析JSON或XML消息. 然而,所有这一切都是重新发明的,当您可能在几个小时内开始使用RabbitMQ之类的现有系统之一时,可以节省大量时间(而且还有很多错误)！ （编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |