Active MQ (四) Spring JMS 整合

1. Spring JMS整合类图

2. 程序

applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">


<bean name="actualJMSConnFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
  <property name="jndiName" value="java:comp/env/jms/NormalConnectionFactory"/>
</bean>

<bean name="queueSendTo" class="org.springframework.jndi.JndiObjectFactoryBean">
  <property name="jndiName" value="java:comp/env/jms/queue/sender"/>
</bean>

<bean name="queueReceiveFrom" class="org.springframework.jndi.JndiObjectFactoryBean">
  <property name="jndiName" value="java:comp/env/jms/queue/receiver"/>
</bean>


<bean name="jmsConnFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
  <property name="targetConnectionFactory" ref="actualJMSConnFactory"/>
</bean>

<bean name="sender" class="org.springframework.jms.core.JmsTemplate">
  <property name="connectionFactory" ref="jmsConnFactory"/>
  <property name="defaultDestination" ref="queueSendTo"/>
</bean>

<bean name="receiver" class="org.springframework.jms.core.JmsTemplate">
  <property name="connectionFactory" ref="jmsConnFactory"/>
  <property name="defaultDestination" ref="queueReceiveFrom"/>
  <property name="receiveTimeout" value="3000"/>
</bean>


<bean name="jmsSender" class="springJMS.JMSSender">
  <property name="sender" ref="sender"/>
</bean>

<bean name="jmsReceiver" class="springJMS.JMSReceiver">
  <property name="receiver" ref="receiver"/>
</bean>


<bean name="appContext" class="springJMS.AppContext"/>

</beans>

JMSSender

package springJMS;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class JMSSender {

private JmsTemplate sender;

/**
* @return the sender
*/
public JmsTemplate getSender() {
return sender;
}

/**
* @param sender the sender to set
*/
public void setSender(JmsTemplate sender) {
  this.sender = sender;
}

public void send(final String msg) {
  sender.send(new MessageCreator() {
   public Message createMessage(Session session) throws JMSException {
    return session.createTextMessage(msg);
   }
  });
}

}

JMSReceiver

package springJMS;

import javax.jms.Message;

import org.springframework.jms.core.JmsTemplate;

public class JMSReceiver {

private JmsTemplate receiver;

/**
* @return the receiver
*/
public JmsTemplate getReceiver() {
return receiver;
}

/**
* @param receiver the receiver to set
*/
public void setReceiver(JmsTemplate receiver) {
this.receiver = receiver;
}

public Message receive() {
return receiver.receive();
}

}

AppContext

package springJMS;

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;

public class AppContext implements ApplicationContextAware {

private static ApplicationContext appContext;

public static Object getBean(String name) {
  return appContext.getBean(name);
}

public void setApplicationContext(ApplicationContext applicationContext)
   throws BeansException {
  appContext = applicationContext;
}

}

springJMS.jsp

<%@ page language="java" pageEncoding="UTF-8"%>
<jsp:directive.page import="springJMS.JMSSender"/>
<jsp:directive.page import="springJMS.AppContext"/>
<jsp:directive.page import="springJMS.JMSReceiver"/>
<jsp:directive.page import="javax.jms.Message"/>
<jsp:directive.page import="javax.jms.TextMessage"/>

<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
JMSSender sender = (JMSSender) AppContext.getBean("jmsSender");
JMSReceiver receiver = (JMSReceiver) AppContext.getBean("jmsReceiver");
%>

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
    <base href="<%=basePath%>">

    <title>JMS Queue Test</title>
<meta http-equiv="pragma" content="no-cache">
<meta http-equiv="cache-control" content="no-cache">
<meta http-equiv="expires" content="0">
<meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
<meta http-equiv="description" content="This is my page">

</head>

<body>
<%sender.send("Nice to meet u!"); %>
<%="Send : Nice to meet u!" %><br>
<%
  Message message = receiver.receive();
  if (message instanceof TextMessage) {
%>
  <%="Receive : " + ((TextMessage) message).getText() %>
<%
  }
%>
</body>

</html>

3.测试

开启MQ，创建对应的QUEUE，运行http://orange5458.iteye.com/admin/blogs/988495

的消息处理器，启动TOMCAT，进入springJMS.jsp，刷新。

4.参考资料

Spring开发者手册 http://orange5458.iteye.com/admin/blogs/981099