MQ消息中间件通用框架研究及设计开发

MQ消息中间件通用框架研究及设计开发

现代很多遗留传统系统使用CORBA、DCOM、RMI等RPC中间件技术进行数据集成和系统整合，此种架构具有如下的局限性：①同步通信；②生命周期紧密耦合；③点对点通信；④复杂度高N*（N-1）/2；⑤开发维护成本高。

因此随着业务的发展，业务系统也越来越复杂，面临着各种各样的数据集成和系统整合。系统之间的交互日趋复杂，所以迫切需要推出消息中间件来降低业务系统和功能模块相互交互的复杂度，降低业务系统和功能模块间的耦合，为业务系统和功能模块之间的交互提供统一的、健壮的、可扩展的、可靠的、高可用的底层传输服务。

消息中间件就是应运松偶合的概念而产生的，主要以队列和发布订阅为消息传输机制，以异步的方式将消息可靠的传输到消费端的一种基础产品。

MQ（Message Queue）消息中间件作为一个基础传输中间件已经问世好多年的历史了，他主要应用于分布式系统中，在分布式系统中，存在着许多异构环境、不同的开发语言和不同的传输协议，所以要实现这些系统之间的通信是一个相当复杂的工程。消息中间件就是为了解决这些问题，把这些问题从应用中分离出来，形成一个专门的底层系统软件，使分布式环境对我们应用开发人员来说是透明的。

消息中间件在整个软件应用集成系统中可以具有如下的优点：①异步通信；

②生命周期松耦合；③复杂性低N；④开发维护成本低；⑤可提供可靠的传输。这个特点可以说是消息中间件的立足之本，对于应用来说，只要成功把数据提交给消息中间件，那么关于数据可靠传输的问题就由消息中间件来负责；⑥可实现不重复传输。也就是断点续传功能，特别适合网络不稳定的环境，节约网络资源；

⑦消息驱动。收到消息后主动通知消息接收方；⑧支持事务。应用程序可以把一些数据更新组合成一个工作单元，这些更新通常是逻辑相关的，为了保障数据完整性，所有的更新必须同时成功或者同时失败（撤消）。

1 Active MQ

我们给予的消息基于Apache的ActiveMQ提供消息服务，ActiveMQ外界一致认为是最成熟最稳定的开源MQ产品，其性能不亚于SonicMQ等商业产品。目前版本是5.3.0，在下一个版本中将加入AIO，性能将会得到再次提升。

MQ通用框应用于下列场景更具优越性：①耗时操作：邮件发送/短消息发送；②系统解耦：系统A与系统B存在交互，如果A挂了，但B可以继续使用；

③日志。

2 程序开发结构