。

对应就要实现三个大模块有三种角色生产者消费者中间人。

对应就要实现三个大模块服务端消息生产客户端消息消费客户端。

服务端要完成一个消息队列服务器模块这个模块是整个项目的核心

二.服务器模块概述

本地模块服务器的核心模块也可以叫业务模块对本地消息的增删查完全自主实现协议模块数据序列化和反序列化报文封装与解包。

使用

Protobuf

库实例代码中提供的自定义协议完成后者网络模块字节流接受和发送以及连接管理。

前者由

muduo

服务器上可以有多个数据库那么一台消息队列服务器上也可以有多台虚拟机。

虚拟机是一个逻辑上的集合里面有很多对象有哪些呢有以下这些消息队列一个虚拟机中可以有很多不同类型的消息队列用来存储不同类型的消息交换机生产者的目的是要将消息发布到指服务器的消息队列中但有时候想要把一条消息发布到多个队列比如我现在有一份素材想要交给消息队列服务器推送给消费者去加工素材形成新闻。

服务器上有很多类型的队列比如和音乐素材队列体育素材队列我的素材是某体育明星创作了一首歌曲我想要同时发布到音乐和体育队列那么我就就要去发布两次比较繁琐。

所以引出了交换机的概念我不会直接把把消息给消息队列而是先给交换机让交换机使用交换路由算法把消息发布到音乐和体育素材队列中去。

绑定交换机要把消息发送到队列那么一定要和队列建立联系Binding

和交换机的交换路由算法有关这里不展开谈消息要传递的内容需要持久化除了消息上述的对象都需要持久化只不过消息直接写到文件其它对象用的是

sqlite

的简化版服务器上只有一台虚拟机所以本地模块的核心接口就是虚拟机的核心接口有如下这些

交换机消息队列绑定的创建与销毁发布消息订阅队列和取消订阅确认消息消息发送给消费者后暂时不会删除直到消费者手动调用应答的接口发送应答请求服务器收到后调用确认应答的接口把消息删除

2.网络模块

的连接和关闭交换机队列绑定的创建和销毁发布消息订阅队列和取消订阅确认消息

你会发现服务器提供的几个接口本地模块网络模块不是也有吗实际上这几个接口实现就是使用的是网络模块和本地模块这就是分层设计的思想。

Connection创建信道TCP

Connection销毁信道缓冲区中的数据读取上来了回调去用协议处理器解析字节流得到结构化的请求再分发给相应的业务回调函数业务回调函数中做增删查然后构建响应报文给客户端返回过去

三.模块详细划分

准确的说是虚拟机数据管理模块因为一台服务器上只有一个虚拟机。

包含以下子模块

以上的四种数据都要持久化管理所以数据管理包含内存和磁盘两方面管理

路由交换模块

生产者把消息发布给交换机交换机决定放入哪些队列这个决定就由路由交换模块提供的算法来完成。

路由交换算法要结合交换机的类型以及消息中的

routing

这里的消费者是指订阅了某个消息队列的对象一个用户可能通过消费客户端订阅了多个队列所以虽然这些订阅都来自同一客户端但在我服务端看来有多个消费者。

服务端为什么要管理消费者是因为当有消息发布到队列中就需要推送给订阅该队列消息的客户端所以要把消费者管理起来

网络模块

信道是比连接粒度更细的通信通道一个连接中有一个或多个信道客户端关闭通信关闭的是信道而不是连接信道关闭后就要把客户端的一个或多个订阅取消连接管理模块

Connection

消费者管理模块——消息订阅客户端才会用到信道管理模块连接管理模块