对C/C++远程消息队列的建议

我正在开展一个涉及几个C程序的项目,每个C程序都需要输入和生成输出.数据(几十到几百个字节,大概是 JSON)基本上在一个方向上流动(异步),程序将需要位于LAN周围的不同 Linux计算机上.

由于数据只能在一个方向流动,所以我不相信我需要像HTTP这样的事务模型.我认为一个消息队列模式(消防和忘记)是最有意义的,应该简化每个程序的逻辑.仅仅注意到消息已成功添加到远程队列可能就足够了.

我正在寻找的是如何在C或C中实现此消息队列的建议.似乎POSIXBoost消息队列仅限于单个主机,RabbitMQ似乎对C/C++支持较弱,MQ4CPP似乎对业务关键角色的支持不足.我错了吗? Boost ASIOACE还是自己编写套接代码?我期待您的建议.

解决方法

在简单的消息支持方面,ZeroMQ is hard to beat.它可用于许多语言绑定,并支持从简单的发送和接收到pub / sub,fanout甚至消息管道的一切.代码也很容易消化,并且可以很容易地在模式之间切换.

看看他们的Weather Update Server sample(在20几种奇怪的语言)显示创建发布/订阅设置是多么容易:

zmq::context_t context (1);
zmq::socket_t publisher (context,ZMQ_PUB);
publisher.bind("tcp://*:5556");
publisher.bind("ipc://weather.ipc");

while(1) {
    //  Send message to all subscribers
    zmq::message_t message(20);
    snprintf ((char *) message.data(),20,"%05d %d %d",zipcode,temperature,relhumidity);
    publisher.send(message);
}

我使用它在一些混合的C#和Python进程没有太多麻烦.

相关文章

本程序的编译和运行环境如下(如果有运行方面的问题欢迎在评...
水了一学期的院选修,万万没想到期末考试还有比较硬核的编程...
补充一下,先前文章末尾给出的下载链接的完整代码含有部分C&...
思路如标题所说采用模N取余法,难点是这个除法过程如何实现。...
本篇博客有更新!!!更新后效果图如下: 文章末尾的完整代码...
刚开始学习模块化程序设计时,估计大家都被形参和实参搞迷糊...