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/ )
谢谢！！
|
本类阅读TOP10