码迷,mamicode.com
首页 > 编程语言 > 详细

SpringJMS解析1-使用示例

时间:2016-11-22 20:38:37      阅读:169      评论:0      收藏:0      [点我收藏+]

标签:xmla   mqc   generate   cti   nfa   property   int   ring   row   

Spring配置文件:

<?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 id="connectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
      <property name="brokerURL">
        <value>tcp://localhost:61616</value>
      </property>
    </bean>
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
       <property name="connectionFactory">
         <ref bean="connectionFactory"/>
       </property>
    </bean>
    <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
      <constructor-arg index="0">
        <value>HelloWorldTopic</value>
      </constructor-arg>
    </bean>
</beans>

发布者:

package ch13.JMS;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
public class HelloWorldSenderPS  {
    public static void main(String[] args) throws Exception{
        ApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] {"ch13/JMS/applicationContext-PS.xml"});
        JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
        Destination destination = (Destination) context.getBean("destination");
        for (int i = 0; i < 2; i++) {
            System.out.println("Sending Message: Foo"+i);
            jmsTemplate.convertAndSend(destination,"Foo "+i);
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }    
        }
    }
}

这里我们使用了convertAndSend的方式进行发送,这个方法将一个String转换成一个TextMessage实例,并发送他道指定的destination---这一切完全都是自动的,如果不这样,我们就必须通过以下冗长的代码:

jmsTemplate.send(destination, new MessageCreator() {
    public Message createMessage(Session session) throws JMSException {
        return session.createTextMessage("11");
    }
});

Spring使用一个MessageConvert接口的实现类来把一个java对象转换到一个可发送的消息实例,当使用receiveAndConvert()方法接受一个消息时候,Spring使用MessageConvert来进行相反地操作,转换一个消息实例到一个java对象。

接收者:

package ch13.JMS;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.TextMessage;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jms.core.JmsTemplate;
public class HelloWorldReciverPS  {  
   public static void main(String args[]){   
       ApplicationContext context=new ClassPathXmlApplicationContext(
                new String[]{"ch13/JMS/applicationContext-PS.xml"});
        JmsTemplate jmsTemplate=(JmsTemplate)context.getBean("jmsTemplate");
        Destination destination=(Destination)context.getBean("destination");
       while(true){    
         TextMessage msg=(TextMessage)jmsTemplate.receive(destination);
         try {
            System.out.println("Recieved:"+msg.getText());
        } catch (JMSException e) {
            System.out.println(e.getMessage());
        }
       }
            
   } 
}

测试结果:

发送端出现:

Sending Message: Foo0

Sending Message: Foo1

接收端出现:

Recieved:Foo0
Recieved:Foo1

 

SpringJMS解析1-使用示例

标签:xmla   mqc   generate   cti   nfa   property   int   ring   row   

原文地址:http://www.cnblogs.com/wade-luffy/p/6090737.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!