基于corba的java消息服务中间件的设计与优化.doc

《基于corba的java消息服务中间件的设计与优化.doc》由会员上传分享，免费在线阅读，更多相关内容在学术论文-天天文库。

1、基于CORBA的JAVA消息服务中间件的设计与优化摘要CROBA、DCOM等RPC中间件在大规模的分布计算应用中有其局限性。而Java消息服务在异步通信、松散耦合和多对多通信等方面提供了强有力的支持。本文介绍了CJMQ——个基于CORBA的多线程Java消息服务中间件，描述了CJMQ的体系结构，讨论了消息派发机制的优化设计，并且对当前CJMQ的实现进行了性能评价和分析。关键字Java消息服务；消息中间件；CORBA中图分类号TP393文献标识码A1引言当前，CORBA、DCOM,RMI等RPC中间件技术已广泛应用于各个领域。但是面对规模和复杂度都越来越高的分布式系统

2、，这些技术也显示出其局限性：同步通信：客户发出调用后，必须等待服务对象完成处理并返回结果后才能继续执行；客户和服务对象的生命周期紧密耦合：客户进程和服务对象进程都必须正常运行；如果由于服务对象崩溃或者网络故障导致客户的请求不可达，客户会接收到异常；点对点通信：客户的一次调用只发送给某个单独的目标对象。面向消息的中间件较好的解决了以上问题。发送者将消息发送给消息服务器，消息服务器将消息存放在若干队列中在合适的时候再将消息转发给接收者。这种模式下，发送和接收是异步的，发送者无需等待；二者的生命周期未必相同：发送消息的时候接收者不一定运行，接收消息的时候发送者也不一定运行

3、；一对多通信：对于一个消息可以有多个接收已有的M0M系统包括IBM的MQSeries、Microsoft的MSMQ和BEA的MessageQ等。由于没有一个通用的标准，这些系统很难实现互操作和无缝连接。JavaMessageService是SUN提出的旨在统一各种MOM系统接口的规范，它包含点对点和发布/订阅两种消息模型，提供可靠消息传输、事务和消息过滤等机制。我们的工作是利用C0RBA的开放、跨平台和跨语言的特性，以其作为底层通信机制，设计和实现一个开放、高性能的JMS中间件CJMQ。CJMQ支持点对点和发布/订阅两种消息模型，同时支持同步、异步通信机制，提供持久

4、消息、优先级、可靠消息传输保证和持久订阅。本文首先简要介绍了JMS接口规范，然后详细描述了CJMQ的体系结构以及对消息派发机制的优化措施，最后对CJMQ进行了性能分析与评价。JAVA消息服务JMS是SUN定义的一个纯接口规范而没有任何具体实现，它的标准API使应用程序可以不依赖某个具体的MOM系统1说明了JMS的主要概念一个JMS应用由JMS消息服务、JMS客户、消息、目标和连接工厂两种管理对象所组成。JMS消息服务提供了两种消息模型：PTP模型和pub/sub模型，如图1所示。在PTP模型中，消息被发往特定的消息队列，然后由消息服务再发往接收者。PTP模型的特点是

5、：每个消息仅有一个接收者；接收者成功处理消息后要发出应答。在pub/sub模型中，消息被发往基于某个主题的消息队列，而接收者必须先在它感兴趣的主题队列发出订阅请求，消息服务根据接收者的订阅情况来决定是否将消息发往接收者。这种模型的特点是：每个消息也许有多个接收者；接收者可以采取持久订阅机制。持久订阅指的是接收者要求收到所有发往某个Topic的消息即使该接收者没有和JMS服务器保持连接。服务器保留这些信息直到该接收者应答或者这些消息过期。JMS消息由三部分组成：消息头、属性和消息体。所有的消息都有相同的头部，包含了优先级、生存期、可靠性等QoS信息以及路由信息。服务器

6、将依据这些信息对消息进行处理。属性是用户定义的名字值对，可用来进行消息过滤和路由或者由应用程序自己进行处理。消息体包含要传送的具体消息，JMS定义了五类消息：Text、Map、0bject、Stream、BytesoJMS的传输模式分为持久模式和非持久模式。持久模式指示JMS服务器要将消息保存在数据库中，以防止由于服务器崩溃造成的消息丢失。JMS规范要求持久性消息的传送要保证一次且仅有一次语义，即消息既不能丢失也不能发送两次。非持久模式传送消息更有效率，因为不必将消息保存在数据库中。JMS规范要求非持久性消息的传送要保证至多一次语义，即消息可以丢失但是不能发送两次。

7、CJMQ的系统结构CJMQ的外部体系结构如图2所示，CJMQ提供了三种AH以满足管理、Java应用和C++应用的需要，它们的通信协议采用标准的CORBAII0P协议以保证CJMQ的开放型以及和其他系统的互操作性。由于OMG会逐步扩展各种语言向CORBA的映射，因此CJMQ也会增加支持其他语言的客户端API。CJMQ有一个数据存储层，用以存储持久消息、系统配置参数、连接信息等数据，它可以通过JDBC访问SQLServer、Oracle、Sybase等关系数据库。3.2CJMQ的内部体系结构3显示了CJMQ消息服务的内部主要结构。客户应用程序通过调用CJMQ提供的J