基于AMQP的消息中间件的设计和实现

发布时间：2021-09-08 07:42

　　伴随着分布式技术的快速发展,消息中间件已成为各类分布式系统的重要组件,得到广泛应用。消息中间件实现了分布式应用间的时间、空间以及流程解耦,做到消息发送方与接收方完全独立,实现了模块间的松耦合。借助消息中间件,开发者无需关注消息传递的具体细节,只需专注于自身业务逻辑的实现。消息中间件在满足消息传输需求的同时降低开发的难度。本文在遵循高级消息队列协议的基础上,设计并实现了一个消息中间件。本文的主要工作包括:（1）在高级消息队列协议的基础上,设计并实现了消息代理和中间件客户端。中间件客户端提供消息发送与消息接收的接口,消息代理接收并对消息进行路由,最终将消息推送至对应的接收者。（2）对中间件的可靠性进行设计。本文针对消息流转过程进行设计,在高级消息队列协议的基础上引入了明确的消息应答机制,保证了消息在消息生产过程和消息消费过程的可靠性。此外,通过在消息代理间进行数据同步,使数据在多节点冗余,保证了消息在消息代理存储过程的可靠性。（3）对中间件的高可用性进行设计。本文为消除单点故障带来的影响,引入双机主备与双机互备架构,并结合数据同步机制与自动故障转移机制,实现了消息中间件的高可用。此外,通过... 

【文章来源】：东南大学江苏省 211工程院校 985工程院校 教育部直属院校

【文章页数】：65 页

【学位级别】：硕士

【部分图文】：

点对点模式

持久化订阅是指如果订阅者订阅了某个主题,除非主动取消该订阅,否则将一直存在该订阅关系。在订阅者重新上线后,订阅者将接到服务停止期间所有订阅关系所对应的所有消息,不会错过消息。发布/订阅模式如图2-2所示。2.1.2 消息中间件的应用场景

AMQP可分为两层:功能层及传输层。功能层定义了按照功能的进行分类的一系列命令,主要用于被应用程序调用时所需的业务逻辑。传输层则是确定了数据传输格式,使中间件能与应用程序使用二进制流进行交互。只要不改变功能层相关协议,开发者可以任意替换传输层。AMQP的分层如图2-3所示。2.2.1 AMQP模型元素

【参考文献】：
期刊论文
[1]基于Zookeeper的分布式ICE中间件研究[J]. 冯战胜,张激,彭宏,刘颖娜.  计算机系统应用. 2018(12)
[2]基于ZooKeeper的一种分布式系统架构设计与实现[J]. 陈天伟,彭凌西.  通信技术. 2018(01)
[3]基于高性能消息管理机制的物联网中间件设计方法[J]. 王冰,陈庭贵.  计算机工程与应用. 2017(16)
[4]基于消息中间件的非结构化数据同步[J]. 魏东琦,江宝得,谷建华,贺旭光.  西安工业大学学报. 2017(03)
[5]基于消息通信的分布式系统最终一致性平台[J]. 徐进,黄勃,冯炯.  计算机应用. 2017(04)
[6]开源消息中间件复杂并发连接控制的研究与实现[J]. 吕德奎,崔艳军.  网络安全技术与应用. 2016(12)
[7]一种优化的Kafka消费者/客户端负载均衡算法[J]. 王郑合,王锋,邓辉,柳翠寅,张晓丽.  计算机应用研究. 2017(08)
[8]分布式数据库同步中间件系统的设计与研究[J]. 王珏,孟晓蕊.  现代电子技术. 2016(09)
[9]基于RabbitMQ的异步全双工消息总线的实现[J]. 鱼朝伟,詹舒波.  软件. 2016(02)
[10]发布/订阅模式测控消息中间件系统设计[J]. 王重楠,王宗陶,鲍忠贵,邢宏伟.  计算机应用. 2015(03)

硕士论文
[1]基于RocketMQ的高可用分布式融合通信消息系统的设计与实现[D]. 颜睿陽.中国科学院大学(中国科学院沈阳计算技术研究所) 2018
[2]基于ZooKeeper的配置中心系统设计与实现[D]. 董龙成.西安电子科技大学 2018



本文编号：3390402