Enterprise JavaBeans Distilled (8)

类别:Java 点击:0 评论:0 推荐:

Enterprise JavaBeans Distilled

 

作者: Tnk Luo

 

第九次:

 

消息驱动Bean(续)

使用哪个消息模型?

这两种模型背后的基本原理在JMS规范中。JMS是用于访问现存消息系统,而提供公共API的方式出现的。在现如今的概念阶段,一些消息厂商提供了点对点模型支持,而另一些提供对发布-订阅模型支持。所以,JMS需要提供支持两种模型的API才能赢得业界的广泛支持。JMS 1.0.2规范部要求JMS供应者支持两种模型。然而,EJB 2.0厂商需要提供对两种消息模型的支持。

几乎任何事情都可用pub/sub模型完成,或用点对点完成。反之亦然。以此类推,类似于开发者的编程语言选择。理论上,能够用Pascal写的应用也可以用C完成。用C++能完成的任何事情,也能用Java做。在某些情形下,都有一定的选择,或者取决于对那种模型的熟悉程度罢了。

在大部分情况下,模型的选择取决于模型各自不同的优点。对于发布-订阅而言,任何数目的订阅者都能监听某个topic,并都能够收到相同消息的拷贝。比如,考虑发布者广播了股票报价这样一种情况。如果任何特定的订阅者当前没有连接,并错过了很好的报价,发布者不会去关注。相比之下,点对点Session很可能倾向于另一端特定应用的一对一对话。在这种情形下,每条消息都值要紧。

另外,消息所代表数据信息的范围和多样性也是一个因素。使用pub/sub时,消息是基于特定topic提供的过滤功能来分发到消费者的。即使当消息是用于和某个已知的应用建立一对一对话,使用多个topic的pub/sub来隔离不同类型的消息也是pub/sub的优势所在。每种消息类型能单独通过各自的消费者和onMessage()监听器来处理。

当仅仅想让特定接收者处理一次给定消息时,点对点更加方便。这也许是这两种模型最关键的区别:p2p保证仅仅有一个消费者处理每条消息。当消息需要依次单独处理时,这一点尤为重要。

实体和会话Bean不该接收消息

    JmsClient_1用于消费TravelAgent EJB生产的消息。那么,其他的实体,或会话Bean也能接收哪些消息吗?答案是肯定的,但那可不是好办法。

实体和会话Bean会对来自EJB客户的Java RMI调用作出响应,但不能编写为,类似消息驱动Bean一样,对JMS消息的响应。这意味着,不可能写消息驱动的会话,或实体Bean。EJB的这种对JMS消息响应的局限性,使得消息驱动Bean为什么会在EJB 2.0中引入的原因。消息驱动Bean被设计成消费来自topic或queue的消息。消息驱动Bean补充了以前EJB中的不足,我们将在下一节给出如何编写它们的例子。

    开发实体或会话Bean来消费来自业务方法的JMS消息时可能的,但是这个方法必须首先被EJB客户调用。比如,调用Hypothetical EJB中的业务方法,其中设置了JMS session并试着查看来自queue的消息:

public class HypotheticalBean implements javax.ejb.SessionBean {

    InitialContext jndiContext;

 

    public String businessMethod() {

 

        try{

 

            QueueConnectionFactory factory = (QueueConnectionFactory)

                jndiContext.lookup("java:comp/env/jms/QueueFactory");

 

            Queue topic = (Queue)

                jndiContext.lookup("java:comp/env/jms/Queue");

 

            QueueConnection connect = factory.createQueueConneciton();

            QueueSession session = connect.createQueueSession(true,0);

            QueueReceiver receiver = session.createReceiver(queue);

 

            TextMessage textMsg = (TextMessage)receiver.receive();

       

            connect.close();

           

            return textMsg.getText();

 

        } catch(Exception e) {

            throws new EJBException(e);

        }

 

    }

    ...

}

消息消费者,QueueReceiver,用于取得queue中的消息。尽管程序设计正确,但这是很危险的操作,因为对QueueReceiver.receive()的调用将诸塞当前线程,直到消息可用为止。如果消息不会发送到接收者的queue中,该线程将一直被诸塞。换句话说,如果没有消息发送到这个queue中,QueueReceiver将一直等待下去。

当然也有一些择中的办法,使得receive()方法变得更安全。比如,receive(long timeout)给出了等待时间,一旦超过了这个时间,如果消息还没到达,QueueReceiver将停止诸塞当前线程,并放弃该消息。同时,也有receiveNoWait()方法,它会检查消息,如果没有等待,则返回null,因此避免了线程诸塞。

    尽管这些receive()方法更安全,但仍然是危险的操作。不能够保证receive()方法预期运行、或者程序员的失误(比如,使用了错误的receive()方法),等等这些所带来的风险都是很大的。另外,消息驱动Bean提供了强有力、简单的企业Bean ,并专门为消费JMS消息而设计的。本书建议不要试着在实体,或会话Bean 中消费消息。

JMS更多内容

    JMS(包括一般意义上的企业消息),代表了分布式计算中一种强有力的典范。用本人的观点理解,Java消息服务和EJB自身同等重要,在使用JMS开发之前一定要理解它。

    尽管本章给出了JMS的总体概述,但只是给出足够的材料为下一节讨论消息驱动Bean打下基础。JMS具有很多的特性和细节,以至于本书不可能包含内容广泛的JMS。为理解JMS以及如何使用它,需要读者独立研究它。JMS的详细材料,《Java消息服务》,Richard Monson-Haefel和David Chappell(O’Reilly)。花时间学习JMS是很值得的。

 

待续。。。。。。。。

 

    (作者其它文章:http://www.csdn.net/develop/author/netauthor/worldheart/ )

 

     谢谢!!

 

本文地址:http://com.8s8s.com/it/it18077.htm