基于JMS的数据汇集系统的研究与实现
来源：网络 更新时间：2014-11-27
摘要在深入研究JMS异步消息处理机制的基础上，利用JMS为分布在不同系统中的气象数据的汇集提供了一个可行的方案，解开了应用程序间的耦合，并增强了应用程序的可扩展性和可靠性。
关键词消息、JMS、点对点、发布/订阅、数据汇集、气象
现如今，越来越多的企业、单位面临着各种各样的数据集成和系统整合，CORBA、DCOM、RMI等RPC中间件技术也应运而生，但由于采用RPC同步处理技术，在性能、健壮性、可扩展性上都存在着诸多缺点。而基于消息的异步处理模型采用非阻塞的调用特性，发送者将消息发送给消息服务器，消息服务器在合适的时候再将消息转发给接收者；发送和接收是异步的，发送者无需等待，二者的生命周期也可以不必相同，而且发送者可以将消息间接传给多个接收者，大大提高了程序的性能、可扩展性及健壮性，这使得异步处理模型在分布式应用上比起同步处理模型更具有吸引力。
本文详细介绍了Java中的异步处理机制――基于JMS的异步消息处理技术，并结合实例讨论了基于JMS的气象系统数据汇集系统的设计与实现。
Java消息服务－JMS
JMS是由包括SunMicrosystems和IBM等在内的几个公司合作设计的一个面向消息的中间件（MOM）API。JMS定义了Java中访问消息中间件的接口，但JMS只是接口，并没有给予实现，实现JMS接口的消息中间件称为JMS提供者（JMSProvider）。JMS的目的是应用程序能在异步情况下可靠地传输和接受消息。从编程的角度来看，JMS可以被当作一个容器管理的资源，与JDBC连接类似。正如你可以通过JDBC去访问许多不同的关系数据库一样，你可以通过JMS访问独立于厂商的消息服务系统。
JMS主要包括三个部分――JMS提供者（JMSProvider）、消息发送者（MessageProducer）和消息接收者（MessageConsumer）。简单的说，JMS提供者是指实现JMSAPI接口的消息系统，是消息的中转站；消息发送者是指消息的创造和发送者，是消息的发源地；消息接收者是指接收消息的应用程序，是消息最终的目的地。
JMS消息是异步处理的，消息发送者可以发送一个消息而无须等待响应。消息发送者将消息发送到一条虚拟的通道(主题或队列)上，消息接收者则订阅或是监听该通道。一条消息可能最终转发给一个或多个消息接收者，这些接收者都无需对消息发送者做出回应。
1、JMS消息的组成
在J2EE1.4后，JMSAPI不再区分在点对点域和发布/订阅域中创建的消息。JMS消息由以下三部分组成（如图1.1所示）：
消息头（header）――JMS消息头包含了许多字段，它们是消息发送后由JMS提供者或消息发送者产生，用来表示消息、设置优先权和失效时间等等，并且为消息确定路由。
属性（property）――由消息发送者产生，用来添加删除消息头以外的附加信息。
消息体（body）――由消息发送者产生，JMS中定义了5种消息体：ByteMessage、MapMessage、ObjectMessage、StreamMessage和TextMessage。
2、JMS消息传递模式
JMS支持两种消息传递模式――点对点模式（P2P）和发布/订阅模式（Publish/Subscribe）。这两种都是人们熟知的push模式，消息的发送者是活动的发起人，而接收者则是被动的接收消息。在JMS中，这些消息传递模式被称为消息域（messagedomain）。
2.1JMS点对点消息域
在点对点模式中，发送者和接收者对消息传送的目的地址达成一致，即所谓的队列（queue）。消息队列位于JMS提供者中，消息发送者向一个消息队列发送消息，消息接收者可以在消息发送后的任何时刻从这个队列中（被动地）接收消息，在接收者确认之前消息一直保存在消息队列中直到过期。点对点模式的结构图如图1.2所示：
