数据消息中间件介绍 DMQ

《数据消息中间件介绍 DMQ》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、Asiainfo-Linkage,Inc.,数据消息中间件介绍DMQCUCSRD1-UAP-PSO数据消息中间件介绍修订文档历史记录日期版本说明作者2012-10-24V0.1创建吴学良2012-11-01V0.2吴学良2012-11-15V0.3增加3.3到3.6内容吴学良机密ÓAsiainfo-Linkage,Inc.,2012第13页共13页数据消息中间件介绍1背景目前几个流行的消息中间件产品分析：uApache的ActiveMq我们的几个产品都在使用，存在几个方面问题：使用复杂、维护不方便，容易出故障等，比如，Ø需要熟悉JMX规范，了解各种接口定义；Ø产品提供的w

2、eb监控页面不直观，需要做深入了解后，才明白。Ø监控mq内部运行情况，需要根据提供的接口进行代码开发；uIBM的MQ不仅收费，而且使用更复杂，bug多，且不稳定。服务开通系统以前使用过，后来放弃使用。u微软MSMQ，从网络上大众使用的反馈也不好，不稳定。所以计划自己开发一个简单的队列处理器，简称：DMQ。2目标希望解决：1.提供稳定的消息中间件；2.使用简单，部署、配置很容易；3.更方便维护，通过简单的sql语句即可查询、操作队列数据，以及页面展示等；4.可以根据业务优先级定义，分配不同的队列，并按优先级获取队列数据；5.为今后消息中间件使用提供产品复用3功能实现结合BS

3、S等业务系统具体情况：有数据库、使用人员都熟悉数据库等，因此，创建队列数据到自己的数据库中。方便队列数据的查询、监控以及队列数据维护。机密ÓAsiainfo-Linkage,Inc.,2012第13页共13页数据消息中间件介绍1.1目前MQ使用情况1.1.1BSS-OCS接口平台1.1.2UIP平台机密ÓAsiainfo-Linkage,Inc.,2012第13页共13页数据消息中间件介绍1.1设计目标目标：一个jar，一个tns，一个sql，即可提供一个MQ1、使用tns数据库配置；2、可以定义获取队列数据规则：a.队列优先等级。根据业务优先级划分队列，比如：挂失、调账

4、、业务订购等划分不同优先级的队列；b.入队时间优先级3、可以定义队列消息生存时间；4、消亡后的队列消息处理方式：删除、放入历史表；5、取队列数据接口返回值类型：a.对象，一个队列记录对应的java对象b.应用流水号c.消息消息内容1.2业务流程机密ÓAsiainfo-Linkage,Inc.,2012第13页共13页数据消息中间件介绍其中“反向回执”根据具体应用场景确定是否存在。1.1.1生产者模块外围通过调用组件给出的接口对所需要同步的消息进行优先级处理，并保存至数据库供消费模块消费。Ø外围系统接入时，通过接口告知DMQ启动加载配置文件至内存。Ø外围系统请求业务操作，生

5、产者模块根据配置的消息优先级将消息入库。Ø外围系统调用接口轮询，生产者模块根据配置策略返回消息回执。1.1.2消费者模块生产者模块根据业务配置的优先级策略，把请求消息写入到消息队列后，消费者模块主要做一下操作：Ø消费者模块到消息队列表里，根据消息队列表里的应用类型，消息队列状态（见队列表）等读取消息队列表的请求消息，并修改消息状态；Ø根据业务并发标识来逻辑判断同一个号码同时做不同的业务操作，业务优先级的高低，然后消费者模块根据业务队列的优先级和配置的对应权重比处理不同请求消息，并回执应答给消息队列；Ø机密ÓAsiainfo-Linkage,Inc.,2012第13页共13

6、页数据消息中间件介绍根据应用类型的单向和双向传递标识，如果消费者模块需要写入回执应答消息，则把反调响应消息写入消息队列，并修改消息状态。Ø消费者模块还需要考虑到，一次读取消息队列里最大接收数，读取不到消息，采用什么时间机制继续读取，消费者如果应答超时，应重新读取消息，以保证消息的正常和正确处理，在接收和发送消息处理中，记录相关情况，并记入日志。1.1优先级策略设计大致顺序是：消息放入队列-à根据业务的优先级配置队列à按照优先级的处理高低，配置分发策略的权重比，保证优先级高的队列，得到权重相对大的业务消息分配，比如，缴费，开户，查询三个业务，优先级是由高到低，设置的权重比是

7、3:2:1,当多个请求消息进来，保证优先级高的缴费和依次的开户，查询可以在某一个时间内比如1分钟按照这个权重比分配来处理。需要建立分发策略配置表或在配置文件里进行队列和权重比的配置，具体的配置表结构为：（仅作参考）createtableTD_M_QUEUE_DISTRIBUTE//分发策略配置表(CHANNELTYPEVARCHAR2(30)notnull,BUSINESSTYPEVARCHAR2(30)notnull,DISTRIBUTEQUEUEVARCHAR2(30)notnull,LOADFACTORVARCHAR2(