当前页面位置: » 丰搜网 » 文档中心 » 详细内容
基于jms的数据汇集系统的研究与实现
摘要 在深入研究jms异步消息处理机制的基础上，利用jms为分布在不同系统中的气象数据的汇集提供了一个可行的方案，解开了应用程序间的耦合，并增强了应用程序的可扩展性和可靠性。
关键词 消息、jms、点对点、发布/订阅、数据汇集、气象
现如今，越来越多的企业、单位面临着各种各样的数据集成和系统整合，corba、dcom、rmi等rpc中间件技术也应运而生，但由于采用rpc同步处理技术，在性能、健壮性、可扩展性上都存在着诸多缺点。而基于消息的异步处理模型采用非阻塞的调用特性，发送者将消息发送给消息服务器，消息服务器在合适的时候再将消息转发给接收者；发送和接收是异步的，发送者无需等待，二者的生命周期也可以不必相同，而且发送者可以将消息间接传给多个接收者，大大提高了程序的性能、可扩展性及健壮性，这使得异步处理模型在分布式应用上比起同步处理模型更具有吸引力。
本文详细介绍了java中的异步处理机制――基于jms的异步消息处理技术，并结合实例讨论了基于jms的气象系统数据汇集系统的设计与实现。
java消息服务－jms
jms是由包括sun microsystems和ibm等在内的几个公司合作设计的一个面向消息的中间件（mom）api。jms定义了java 中访问消息中间件的接口，但jms 只是接口，并没有给予实现，实现jms 接口的消息中间件称为jms提供者（jms provider）。jms的目的是应用程序能在异步情况下可靠地传输和接受消息。从编程的角度来看，jms可以被当作一个容器管理的资源，与jdbc连接类似。正如你可以通过jdbc去访问许多不同的关系数据库一样，你可以通过jms访问独立于厂商的消息服务系统。
jms主要包括三个部分――jms提供者（jms provider）、消息发送者（message producer）和消息接收者（message consumer）。简单的说，jms提供者是指实现jms api接口的消息系统，是消息的中转站；消息发送者是指消息的创造和发送者，是消息的发源地；消息接收者是指接收消息的应用程序，是消息最终的目的地。
jms消息是异步处理的，消息发送者可以发送一个消息而无须等待响应。消息发送者将消息发送到一条虚拟的通道(主题或队列)上，消息接收者则订阅或是监听该通道。一条消息可能最终转发给一个或多个消息接收者，这些接收者都无需对消息发送者做出回应。
1、jms消息的组成
在j2ee1.4后，jms api不再区分在点对点域和发布/订阅域中创建的消息。jms消息由以下三部分组成（如图1.1所示）：
消息头（header）――jms消息头包含了许多字段，它们是消息发送后由jms提供者或消息发送者产生，用来表示消息、设置优先权和失效时间等等，并且为消息确定路由。
属性（property）――由消息发送者产生，用来添加删除消息头以外的附加信息。
消息体（body）――由消息发送者产生，jms中定义了5种消息体：bytemessage、mapmessage、objectmessage、streammessage和textmessage。
2、jms消息传递模式
jms支持两种消息传递模式――点对点模式（p2p）和发布/订阅模式（publish/subscribe）。这两种都是人们熟知的push模式，消息的发送者是活动的发起人，而接收者则是被动的接收消息。在jms中，这些消息传递模式被称为消息域（message domain）。
2.1 jms点对点消息域
在点对点模式中，发送者和接收者对消息传送的目的地址达成一致，即所谓的队列（queue）。消息队列位于jms提供者中，消息发送者向一个消息队列发送消息，消息接收者可以在消息发送后的任何时刻从这个队列中（被动地）接收消息，在接收者确认之前消息一直保存在消息队列中直到过期。点对点模式的结构图如图1.2所示：
jms点对点消息域具有以下特点：
·每条消息能而且只能被一个接收者接收。
·每条消息或者被接收者从队列中取走，或者被 jms提供者在超时的情况下删除。
·消息产生的时候接收者不一定要存在，接收者可以在消息产生后的任何时间里取走消息。
·接收者不能请求一个消息。
·接收者必须在收到消息后发出确认信息。
2.2 jms发布/订阅消息域
在发布/订阅模式下，发送者被称为发布者（publisher），一个消息可已有很多接收者，这些接收者被称为订阅者（subscriber）。发布/订阅模式采用与点对点模式完全不同的消息发送模式。在发布/订阅模式下，发布者给一个主题（topic）发送消息，多个订阅者在订阅的时候可以订阅他们感兴趣的主题。一个主题可以被多个订阅者订阅，一个订阅者也可以订阅多个主题。一个主题的消息只被发给该主题的所有订阅者。订阅者只能接收它订阅的主题中的消息，并且，在默认情况下，订阅者在消息发送的时候必须是活动的，并随时准备接收消息，否则它将错过该消息。为了避免这种时间依赖性jms api允许订阅者创建持久订阅。发布/订阅模式的结构图如图1.3所示：
jms发布/订阅消息域具有以下特点：
·每一条消息由一个发布者创建而由0个或多个订阅者接收它。
·消息立刻被分发给现有的订阅者。
·订阅者必须在消息发送的时候存在以接收消息。
·持久订阅允许订阅者接收它处于非活动状态时由发布者向主题发送的消息。
·订阅者必须在接收到消息后发出确认信息。
