一个JMS应用实例

一个JMS应用实例（代码来自试验项目）

功能描述

顾客在一个电子商务网站如果决定购买某一商品，则进入"展示购物篮商品"页面（ShowQuoteServlet.java），点击"Submit Order"按钮下订单，此项操作将调用

（下订单）

CartBean.java（购物篮对象）的purchase()方法，在该方法中将实例化一个订单对象（Order），产生一个Order ID，然后将Order ID通过sendMessage()方法（亦即MessageSender.java类的同名方法）作为一条"消息"发送给JMS服务器，然后，由"订单处理"（OrderProcessorBean.java）消息驱动Bean进行接受，处理完转帐等事宜后，将该订单的标志字段设为"approved"，从而完成一次交易。顾客将看到如下的成功信息：

（购买成功）


代 码

1、"展示购物篮商品"页面（ShowQuoteServlet.java）

… …
/*
*如果顾客点击"Submit Order"按钮
*/
if (request.getParameter("Order") != null) {
/*
* 将购物篮转化为订单，完成付款功能（应用JMS）
*/
String orderId = cart.purchase();
/*
* 将orderID放入 request中以便JSP 能够得到
*/
request.setAttribute("orderID", orderId );
/*
* 清除购物篮，以便顾客能购继续购物
*/
cart.clear();
/*
* 转向成功页
*/
this.getServletContext().getRequestDispatcher("/receipt.jsp").forward(request, response);
return;
}
… …

2、CartBean.java（购物篮对象）的purchase()方法和sendMessage()方法

… …
/**
* 购买购物篮中的商品。
购物篮对象将在数据库里创建一个
* 订单。
*
* @返回 Order ID
*/
public String purchase() {
try {
/*
* 锁定 order home 对象
*/
OrderHome home=getOrderHome();
/*
* 创建order
*/
String orderID = makeUniqueID();
Order order=home.create(orderID, owner,"unverified", subTotal,taxes);
/*
* 创建 orderlineitems（订购商品列表）对象
*/
Vector orderItems=addOrderLineItems(order);
/*
* 将orderlineitems存入Order
*/
order.setLineItems(orderItems);
/*
* 发送JMS消息到topic
*/
sendMessage(orderID);
/*
* 返回 order ID
*/
return orderID;
} catch (Exception e) {
throw new EJBException(e);
}
}

/*
*
*发送JMS消息到topic
*@param JMS message, 在这里是 orderId
*/
private void sendMessage(String message) throws Exception{
try{
MessageSender sender=new MessageSender();
sender.sendMessage(message);
}catch(Exception ex){
throw ex;
}
}
… …

3、MessageSender.java类

package examples;
import java.io.*;
import java.util.*;
import javax.transaction.*;
import javax.naming.*;
import javax.jms.*;
/*
*
* 这个类发送JMS Text message 到topic
*/
public class MessageSender{
/*
* 定义 JNDI context factory。
*/
public final static String JNDI_FACTORY="WebLogic.jndi.WLInitialContextFactory";
/*
* 定义 JMS connection factory JNDI 名。
*/
public final static String JMS_FACTORY="jasmine.examples.jms.TopicConnectionFactory";
/*
* 定义JMS topic JNDI 名。
*/
public final static String TOPIC="jasmine.examples.jms.orderProcess";
/*
* 定义Server URL
*/
public final static String URL="t3://localhost:7001";
/*
* 定义JMS connection factory
*/
protected TopicConnectionFactory tconFactory;
/*
* 定义JMS topic connection
*/
protected TopicConnection tcon;
/*
* 定义 JMS topic session
*/
protected TopicSession tsession;
/*
* 定义 JMS topic publisher
*/
protected TopicPublisher tpublisher;
/*
* 定义 JMS topic
*/
protected Topic topic;
/*
* 定义 JMS TextMessage
*/
protected TextMessage msg;
/*
*
* 为发送messages 到一个JMS Topic
* 创建所有必要的对象。
*
* @param ctx JNDI initial context
* @param topicName name of topic
* @exception NamingExcpetion if problem occurred with the JNDI context interface
* @exception JMSException if JMS fails to initialize due to internal error
*
*/
public void init(Context ctx, String topicName)
throws NamingException, JMSException{
/*
* 锁定 Topic connection factory JNDI
*/
tconFactory = (TopicConnectionFactory) ctx.lookup(JMS_FACTORY);
/*
* 创建一个 topic connection factory
*/
tcon = tconFactory.createTopicConnection();
/*
* 创建一个 topic session
*/
tsession = tcon.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
/**
* 锁定Topic JNDI
*/
topic = (Topic) ctx.lookup(topicName);
/**
* 创建一个 publisher
*/
tpublisher = tsession.createPublisher(topic);
/**
* 创建Textmessage
*/
msg = tsession.createTextMessage();
tcon.start();
}
/**
* 创建所有必要的JMS 对象同时发送一个message 到一个JMS topic.
* @params message message to be sent
* @exception JMSException if JMS fails to send message due to internal error
*
*/
public void sendMessage(String message) throws JMSException {
try{
InitialContext ctx= getInitialContext(URL);
init(ctx,TOPIC);
send(message);
}catch(Exception ex){
throw new JMSException( ex.getMessage());
}finally{
close();
}
}
/**
* 发送一个message 到一个JMS topic。
*
* @params message message to be sent
*/
public void send(String value)
throws JMSException {
msg.setText(value);
tpublisher.publish(msg);
}
/**
* 关闭 JMS 对象。
*
* @exception JMSException if JMS fails to close objects due to internal error
*/
public void close()
throws JMSException {
tpublisher.close();
tsession.close();
tcon.close();
}
/**
* 返回应用服务器初始化环境上下文信息。
*/
protected static InitialContext getInitialContext(String url)
throws NamingException {
Hashtable env = new Hashtable();
env.put(Context.INITIAL_CONTEXT_FACTORY, JNDI_FACTORY);
env.put(Context.PROVIDER_URL, url);
env.put("WebLogic.jndi.createIntermediateContexts", "true");
return new InitialContext(env);
}
/**
* main() 方法。用于测试该类。
*
* @param args WebLogic Server URL
* @exception Exception if operation fails
*/
public static void main(String[] args)
throws Exception{
if (args.length != 1) {
System.out.println("Usage: java examples.jms.topic.TopicSend WebLogicURL");
return;
}
InitialContext ic = getInitialContext(args[0]);
MessageSender sender = new MessageSender();
sender.init(ic, TOPIC);
sender.send("123456");
sender.close();
}
}

4、"订单处理"（OrderProcessorBean.java）消息驱动Bean


package examples;import javax.ejb.*;
import javax.jms.*;
import javax.naming.*;
import javax.rmi.PortableRemoteObject;
/**
* 此消息驱动（message-driven） bean接受JMS messages
* 以便实现购买过程。届时将执行order processing。
*/
public class OrderProcessorBean implements MessageDrivenBean, MessageListener {
protected MessageDrivenContext ctx;
/**
* 这是消息驱动（message-driven）beans 拥有的一个商业方法。
* 在此我们执行真正的order processing
*/

public void onMessage(Message msg) {
TextMessage tm = (TextMessage) msg;
try {
String orderID = tm.getText();
Context ctx = new InitialContext();
OrderHome home = (OrderHome)
PortableRemoteObject.narrow(
ctx.lookup("OrderHome"), OrderHome.class);
Order order = home.findByPrimaryKey(orderID);
/*
* 在此我们可以执行其他的任务：
*
* - 检查用户的信用卡credit并进行划帐操作。
*
* - 检查库存确保商品可卖。
*
* - 检查送货的相关信息。
*
* - 发送email认证信息
*
* 在此例中，我们将仅仅把 order的 status 改变为
* "approved".
*/
order.setStatus("approved");
}
catch (Exception e) {
e.printStackTrace();
throw new EJBException(e);
}
}
/**
* 使该bean 实例与一个特别的context发生联系。
* 我们可以在此 Context 中查询到环境信息。
*/
public void setMessageDrivenContext(MessageDrivenContext ctx) {
this.ctx = ctx;
}
/**
* 在生命周期的初始服务器container将调用此方法。
* 我们将做一些初始化工作。
*/
public void ejbCreate() {
System.err.println("ejbCreate()");
}
/**
* 服务器container调用此方法清除Bean。
*/
public void ejbRemove() {
System.err.println("ejbRemove()");
}
}

5、"订单处理"（OrderProcessorBean.java）消息驱动Bean的配置文件代码
① ejb-jar.xml
<ejb-jar></ejb-jar><enterprise-beans></enterprise-beans>
… …
<message-driven></message-driven>
<ejb-name></ejb-name>OrderProcessor
<ejb-class></ejb-class>examples.OrderProcessorBean
<transaction-type> </transaction-type> Container
<message-driven-destination></message-driven-destination>
<destination-type></destination-type>javax.jms.Topic

… …
… …

② WebLogic-ejb-jar.xml
<weblogic-ejb-jar></weblogic-ejb-jar>… …
<weblogic-enterprise-bean></weblogic-enterprise-bean><ejb-name></ejb-name>OrderProcessor
<message-driven-descriptor></message-driven-descriptor> <pool></pool> <max-beans-in-free-pool></max-beans-in-free-pool>100 <initial-beans-in-free-pool></initial-beans-in-free-pool>10
<destination-jndi-name></destination-jndi-name>jasmine.examples.jms.orderProcess

<jndi-name></jndi-name>OrderProcessorBean

… …