Enterprise JavaBeans Distilled
作者: Tnk Luo
第五次:
消息驱动Bean
这个系列好久才回来了,不好意思。让我们继续往下看。这一期,让我们看看消息驱动Bean相关的内容。
这接下来的几部分内容,我主要以翻译,《Enterprise JavaBeans》,3rd中的第13章为主。
其网址如下:
http://www.oreilly.com/catalog/entjbeans3/chapter/ch13.html
《Enterprise JavaBeans》,第三版
第13章 消息驱动Bean
译者: Tnk Luo
本章内容包括两部分:充当资源的JMS 和 消息驱动Bean。第一部分给出Java消息服务(JMS)介绍和充当资源的角色,即JMS对任何EJB可用(包括会话Bean、实体Bean和消息驱动Bean)。对JMS不熟悉的读者在深入第二部分内容之前,应该阅读第一份部分的内容。
如果您已经对JMS很熟悉,则可以直接跳到第二部分内容,其中对新的EJB类型(消息驱动Bean)作了大概的介绍。消息驱动Bean是由消息分发者(message delivery)激活的异步Bean。在EJB 2.0规范中给出要求,即产品厂商需要支持基于JMS的消息驱动Bean,一种从某topic或queue中接收JMS消息,并处理分发给它们的这些消息的企业Bean。
默认情况下,所有的EJB 2.0产品厂商必须支持一个JMS供应者。大部分EJB 2.0产品厂商都内置了一个JMS供应者,但也可支持其他的JMS供应者。不管EJB 2.0产品厂商是如何提供JMS服务的,如果想支持消息驱动Bean,则它必须至少支持一个JMS供应者。这种对JMS的强制做法所带来的好处在于,EJB开发者能有一个可操作的JMS供应者,从而使得它可以发送和接收消息。
充当资源的JMS
JMS,一种独立于厂商的标准API,也是J2EE平台的部分内容,能用于访问企业消息系统。企业消息系统(又名,面向消息的中间件,(译者注:简称MOM))提供了在网络环境中软件应用之间交换消息的便利。JMS类似于JDBC:JDBC是用于访问多种不同RDBMS的API,而JMS则提供了独立于产品厂商、对企业消息系统的访问。现如今有很多企业消息产品支持JMS,其中包括IBM的MQSeries、BEA的WebLogic JMS服务、Sun公司的iPlanet Message Queue、Progress的SonicMQ等等。使用JMS API发送或接收消息的软件在不同JMS产品厂商间是可移植的。
使用JMS的Java应用称之为,JMS客户。同时,处理消息的路由、分发的消息系统称之为,JMS供应者。JMS应用是由多个JMS客户和一个JMS供应者(一般情况下)构成的业务系统。
发送和接收消息的JMS客户分别称之为生产者(producer)和消费者(consumer)。当然,单个的JMS客户可以同时是生产者和消费者。当使用术语消费者和生产者时,本书分别指接收和发送消息的JMS客户。
在EJB中,所有类型的企业Bean都能使用JMS发送消息到不同的目的地(destination)。其他的Java应用或消息驱动Bean可以消费这些消息。JMS使得在使用消息服务的EJB中发送消息更容易,其中这里的消息服务有时候称之为消息中介(message broker)或消息路由器(message router)。其中,消息中介已经存在很多年,最早、最为广泛使用的当然是IBM的MQSeries,但JMS还是比较新的东西,因为它被设计成在Java应用间分发不同消息的目的。
使用JMS重新实现TravelAgent EJB
在这里我们来修改第12章开发的EJB,TravelAgent,使得它可以用JMS来通知其他的Java应用,预定已经完成。下面的代码给出了如何修改bookPassage()方法,从而使得EJB,TravelAgent能够发送基于TicketDO对象中给出的描述信息的简单文本消息:
public TicketDO bookPassage(CreditCardDO card, double price)
throws IncompleteConversationalState {
if (customer == null || cruise == null || cabin == null) {
throw new IncompleteConversationalState();
}
try {
ReservationHomeLocal resHome = (ReservationHomeLocal)
jndiContext.lookup("java:comp/env/ejb/ReservationHomeLocal");
ReservationLocal reservation =
resHome.create(customer, cruise, cabin, price, new Date());
Object ref = jndiContext.lookup
("java:comp/env/ejb/ProcessPaymentHomeRemote");
ProcessPaymentHomeRemote ppHome = (ProcessPaymentHomeRemote)
PortableRemoteObject.narrow(ref, ProcessPaymentHomeRemote.class);
ProcessPaymentRemote process = ppHome.create();
process.byCredit(customer, card, price);
TicketDO ticket = new TicketDO(customer,cruise,cabin,price);
//新添加的内容
String ticketDescription = ticket.toString();
TopicConnectionFactory factory = (TopicConnectionFactory)
jndiContext.lookup("java:comp/env/jms/TopicFactory");
Topic topic = (Topic)
jndiContext.lookup("java:comp/env/jms/TicketTopic");
TopicConnection connect = factory.createTopicConnection();
TopicSession session = connect.createTopicSession(true,0);
TopicPublisher publisher = session.createPublisher(topic);
TextMessage textMsg = session.createTextMessage();
textMsg.setText(ticketDescription);
publisher.publish(textMsg);
connect.close();
return ticket;
} catch(Exception e) {
throw new EJBException(e);
}
}
为了能够发送消息,添加了很多新代码。然而,尽管从表面上看很复杂,但JMS概念并不是这样的。
待续。。。。。。。。
(作者其它文章:http://www.csdn.net/develop/author/netauthor/worldheart/ )
谢谢!!