和风细雨

世上本无难事,心以为难,斯乃真难。苟不存一难之见于心,则运用之术自出。

使用Spring2.0发送和接受JMS消息

1.JmsQueueSender类,用于发送消息
package com.sitinspring.springjms;

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

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.JmsTemplate102;
import org.springframework.jms.core.MessageCreator;

public class JmsQueueSender {

    
private JmsTemplate jmsTemplate;

    
private Queue queue;

    
public void setConnectionFactory(ConnectionFactory cf) {
        
this.jmsTemplate = new JmsTemplate102(cf, false);
    }


    
public void setQueue(Queue queue) {
        
this.queue = queue;
    }


    
public void simpleSend() {
        
this.jmsTemplate.send(this.queue, new MessageCreator() {
            
public Message createMessage(Session session) throws JMSException {
                
return session.createTextMessage("hello queue world");
            }

        }
);
    }

    
    
public static void main(String[] args){
        
        ApplicationContext appContext 
= new FileSystemXmlApplicationContext("spring-jms.xml");

        JmsQueueSender jmsSender 
= (JmsQueueSender)appContext.getBean("jmsQueueSender");        
        jmsSender.simpleSend();
    }

}


2.ExampleListener,用于接受消息,他是一个Message Driven Pojo.
package com.sitinspring.springjms;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

public class ExampleListener implements MessageListener {

    
public void onMessage(Message message) {
        
//org.springframework.jms.listener.DefaultMessageListenerContainer102
        if (message instanceof TextMessage) {
            System.out.print(
"I have received a msg:");
            
try {
                System.out.println(((TextMessage) message).getText());
            }
 catch (JMSException ex) {
                
throw new RuntimeException(ex);
            }

        }
 else {
            
throw new IllegalArgumentException(
                    
"Message must be of type TextMessage");
        }

    }

}

3.配置文件spring-jms.xml,所有配置均在其中.
值得注意的是标有102处,如果你使用的是DefaultMessageListenerContainer,你将为异常所困扰.
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
    
<!-- JMS 配置-->
    
<bean id="jmsQueueSender"
        
class="com.sitinspring.springjms.JmsQueueSender">
        
<property name="connectionFactory" ref="connectionFactory" />
        
<property name="queue" ref="destination" />
    
</bean>    

    
<!-- and this is the attendant message listener container -->
    
<bean id="listenerContainer"
        
class="org.springframework.jms.listener.DefaultMessageListenerContainer102">        
        
<property name="connectionFactory" ref="connectionFactory" />
        
<property name="concurrentConsumers" value="5" />
        
<property name="destination" ref="destination" />
        
<property name="messageListener" ref="messageListener" />
    
</bean>
    
    
<!-- this is the Message Driven POJO (MDP) -->
    
<bean id="messageListener" class="com.sitinspring.springjms.ExampleListener" />

    
<bean id="connectionFactory"
        
class="org.springframework.jndi.JndiObjectFactoryBean">
        
<property name="jndiName">
            
<value>MyJMSConnectionFactory</value>
        
</property>
        
<property name="jndiTemplate">
            
<ref local="jndiTemplate"></ref>
        
</property>
    
</bean>

    
<bean id="destination"
        
class="org.springframework.jndi.JndiObjectFactoryBean">
        
<property name="jndiName">
            
<value>MyJMSQueue</value>
        
</property>
        
<property name="jndiTemplate">
            
<ref local="jndiTemplate"></ref>
        
</property>
    
</bean>

    
<bean id="jmsTemplate"
        
class="org.springframework.jms.core.JmsTemplate">
        
<property name="connectionFactory">
            
<ref local="connectionFactory" />
        
</property>
        
<property name="defaultDestination">
            
<ref local="destination" />
        
</property>
    
</bean>

    
<!-- JNDI 配置 -->
    
<bean id="jndiTemplate"
        
class="org.springframework.jndi.JndiTemplate">
        
<property name="environment">
            
<props>
                
<prop key="java.naming.factory.initial">
                    weblogic.jndi.WLInitialContextFactory
                
</prop>
                
<prop key="java.naming.provider.url">
                    t3:
//localhost:7001
                </prop>
                
<prop key="java.naming.factory.url.pkgs">
                    weblogic.jndi.factories
                
</prop>
            
</props>
        
</property>
    
</bean>
</beans>


程序下载(程序用到的jar请自行添加,主要是Weblogic.jar和Spring.jar及jakatar commons的一些包):
http://www.blogjava.net/Files/sitinspring/SpringJMS20070910171622.rar

参考资料下载:
Spring2.0的参考手册(两个文件下载到同一目录再解压)
http://www.blogjava.net/Files/junglesong/spring2.0_ref.part1.rar
http://www.blogjava.net/Files/junglesong/spring2.0_ref.part2.rar

posted on 2008-02-22 12:16 和风细雨 阅读(659) 评论(0)  编辑  收藏


只有注册用户登录后才能发表评论。


网站导航: