基于jms数据清分

《基于jms数据清分》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、-基于JMS的数据清分1JMS概述JMS是一个标准的应用编程接口（API），用来建立厂商中立的异步通信机制。从这个意义上说，JMS类似于JDBC和JNDI，例如就JDBC来说，它要求有一个底层的数据库提供者，JMS则要求有一个支持JMS标准的底层异步通信中间件提供者，一般称为面向消息的中间件（Message-OrientedMiddleware，MOM）。MOM是一种支持应用程序通过交换消息实现异步通信的技术。在某种程度上，异步通信有点象是人们通过email进行通信；类似地，同步通信的程序就象是人们通过电话进行通信。在异步通

2、信过程中，程序的结合方式是宽松的，换句话说，异步通信的程序并不直接相互联系，而是通过称为队列（Queue）或主题（Topic）的虚拟通道联系。JMS有两种通信方式：第一种是端对端通信（Point-to-Point，P2P）方式，第二种是出版/订阅（Publish/Subscribe，Pub/Sub）方式。1.1P2P方式P2P消息传递又可以按照推（Push）和拉（Pull）两种方式运作。在P2P拉方式中，程序通过称为队列的虚拟通道通信：在通信会话的发送方，发送程序把一个消息"放入"队列，在接收方，接收程序定期扫描队列，寻找它

3、希望接收和处理的消息。和推方式相比，拉方式的消息传递效率较低，因为它需要周而复始地检查消息是否到达，这个过程会消耗一定的资源。另外必须注意的一点是，当接收方发现一个需要处理的消息时，它就会"提取"消息，从效果上看等于从队列删除了消息。　　因此，即使有多个接收程序在处理同一个队列，对于某一特定的消息来说，总是只有一个接收者。JMS程序可以使用多个队列，每一个队列可以由多个程序处理，但是只有一个程序才会收到某个特定的消息。　　在P2P推方式的消息传递中，发送程序的工作原理也一样，它把消息发送到队列，但接收程序的工作原理有所不同。

4、接收程序实现了一个Listener接口，包括实现了该接口中的onMessage回调方法，在J2EE环境中监听队列接收消息的任务交给了容器，每当一个新的消息达到队列，容器就调用onMessage方法，将消息作为参数传递给onMessage方法。.---P2P通信最重要的特点（不管是推还是拉）是：每一个消息总是只由一个程序接收。一般而言，P2P程序在通信过程中参与的活动较多，例如，发送程序可以向接收程序指出应答消息应当放入哪一个队列，它还可以要求返回一个确认或报告消息。1.1Pub/Sub方式在Pub/Sub通信方式中，程序之间

5、通过一个主题（Topic）实现通信。在消息发送方，生产消息的程序向主题发送消息；在接收方，消息的消费程序向感兴趣的主题订阅消息。当一个消息到达主题，所有向该主题订阅的消费程序都会通过onMessage方法的参数收到消息。　　这是一种推式的消息传递机制。可以设想，会有一个以上的消费程序收到同一消息的副本。相比之下，程序在Pub/Sub通信过程中参与的活动较少，当生产者程序向某个特定的队列发送消息，它不知道到底会有多少程序接收到该消息（可能有多个，可能没有）。2数据清分2.1清分模式清分程序从总公司把数据按各分公司分类，分别发送

6、给各个分公司，分公司接收处理数据后反馈给总公司，如下图：总公司分公司A分公司B分公司N在数据清分中，对于某一笔数据来说，只发送给某个地方，也就是说一个消息只有一个消费者；从这个意义上来说P2P方式更适合做数据清分。如果数据是单向的传输，即只从总公司发送给分公司，那么只需要每个公司一个队列就可以实现，总公司配置“反馈队列”，分公司配置“消息队列”，如下图：.---总公司分公司反馈队列消息队列如果数据是双向的，即分公司也要发送数据给总公司，那么每个公司都需要配置两个队列，如下图：总公司分公司反馈队列消息队列消息队列反馈队列我们的

7、实现的程序支持双向方式，我们称之为ssjms，后面文档中的部署例子是双向方式的。1.1ssjms介绍ssjms实现了双向消息发送机制，程序包中提供了发送消息的API，消息的接受采用MDB（消息EJB）来自动处理，下图是文件的结构。src是源代码目录，resource是ejb的配置文件，test是发送消息的测试例子。1.1.1发送消息com.sinosoft.jms.core.Producer类提供了发送消息方法sendMessage.---。以下是发送消息的例子，在test目录中可以找到。packagecom.sinosof

8、t.jms.core.examples;importjava.util.Properties;importjavax.jms.JMSException;importjavax.naming.NamingException;importcom.sinosoft.jms.core.Log;im