首先需要定义要使用的协议.这可以很简单像只是消息类型字段,有效载荷大小字段和实际有效载荷.您需要的消息类型订阅,不支持和发布. SUBSCRIBE和UNSUBSCRIBE消息的有效载荷是要订阅/取消订阅的通道的名称. PUBLISH消息的有效载荷是通道名称和实际数据(连同当然数据的大小).

要连接所有订阅者,您需要一个中央服务器.所有订阅者/发布商都需要连接到此服务器.服务器程序保留队列的集合,每个通道一个.当订阅或发布消息到达不存在的频道的服务器时,为此频道创建一个新的消息队列.对于每个通道,服务器还需要所有订阅该通道的客户端的集合.当发布消息到达服务器时,它会被添加到相关通道的队列结尾.当频道队列不为空时,将其副本发送给该频道的所有订阅者,并且当所有订阅者接收到该频道时,可以从该队列中删除该消息.

服务器的硬件部分可能将成为通信部分.容易的部分将是所有队列和集合,因为您可以使用所有的队列(例如std::queue为实际队列,std::unordered_map为频道,std::vector为连接的客户端集合).

客户端非常简单,所有需要做的是能够将订阅和发布消息发送到服务器,并从服务器接收发布消息.硬部分将再次成为实际的沟通部分.

后记：

我从来没有真正建立过这样一个系统,我的所有上述都只是我头顶的直接.有经验的程序员不应该需要超过几个小时的时间来实现基础知识,也许需要几天的时间才能使用经验不足的程序员.

对于通信,您可以使用例如Boost ASIO,每个频道可能使用一个threads.您可以使用像Boost property tree这样的东西来构建/解析JSON或XML消息.

然而,所有这一切都是重新发明的,当您可能在几个小时内开始使用RabbitMQ之类的现有系统之一时,可以节省大量时间(而且还有很多错误)！