一、与spring整合实现ptp的同步接收消息
pom.xml:
org.springframework spring-jms 4.3.7.RELEASE org.apache.activemq activemq-pool 5.9.0
spring-jms.xml:
ConnectionFactory是用于产生到JMS服务器的链接的，Spring为我们提供了多个ConnectionFactory，有SingleConnectionFactory和CachingConnectionFactory。SingleConnectionFactory对于建立JMS服务器链接的请求会一直返回同一个链接，并且会忽略Connection的close方法调用。CachingConnectionFactory继承了SingleConnectionFactory，所以它拥有SingleConnectionFactory的所有功能，同时它还新增了缓存功能，它可以缓存Session、MessageProducer和MessageConsumer。这里我们使用CachingConnectionFactory来作为示例。
消息生产者：
= ClassPathXmlApplicationContext("spring-jms.xml"=(JmsTemplate) context.getBean("jmsTemplate"=(Destination) context.getBean("queueDestination" Message createMessage(Session session) session.createTextMessage("Hello spring JMS"消费者：
package com.jalja.org.jms.spring;import javax.jms.Destination;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.jms.core.JmsTemplate;public class SpringJmsReceive {public static void main(String[] args) {
ApplicationContext context=new ClassPathXmlApplicationContext("spring-jms.xml");
JmsTemplate jmsTemplate=(JmsTemplate) context.getBean("jmsTemplate");
Destination queueDestination=(Destination) context.getBean("queueDestination");
String msg=(String) jmsTemplate.receiveAndConvert(queueDestination);
System.out.println(msg);
}
}二、PTP的异步调用
我们在spring中直接配置异步接收消息的监听器，这样就相当于在spring中配置了消费者，在接受消息的时候就不必要启动消费者了。
spring-jms.xml:
生产者往指定目的地Destination发送消息后，接下来就是消费者对指定目的地的消息进行消费了。那么消费者是如何知道有生产者发送消息到指定目的地Destination了呢？这是通过Spring为我们封装的消息监听容器MessageListenerContainer实现的，它负责接收信息，并把接收到的信息分发给真正的MessageListener进行处理。每个消费者对应每个目的地都需要有对应的MessageListenerContainer。对于消息监听容器而言，除了要知道监听哪个目的地之外，还需要知道到哪里去监听，也就是说它还需要知道去监听哪个JMS服务器，这是通过在配置MessageConnectionFactory的时候往里面注入一个ConnectionFactory来实现的。所以我们在配置一个MessageListenerContainer的时候有三个属性必须指定，一个是表示从哪里监听的ConnectionFactory；一个是表示监听什么的Destination；一个是接收到消息以后进行消息处理的MessageListener。Spring一共为我们提供了两种类型的MessageListenerContainer，SimpleMessageListenerContainer和DefaultMessageListenerContainer。
SimpleMessageListenerContainer：SimpleMessageListenerContainer会在一开始的时候就创建一个会话session和消费者Consumer，并且会使用标准的JMS MessageConsumer.setMessageListener()方法注册监听器让JMS提供者调用监听器的回调函数。它不会动态的适应运行时需要和参与外部的事务管理。兼容性方面，它非常接近于独立的JMS规范，但一般不兼容Java EE的JMS限制。
DefaultMessageListenerContainer：在大多数情况下我们还是使用的DefaultMessageListenerContainer，跟SimpleMessageListenerContainer相比，DefaultMessageListenerContainer会动态的适应运行时需要，并且能够参与外部的事务管理。它很好的平衡了对JMS提供者要求低、先进功能如事务参与和兼容Java EE环境。
消息生产者：
public static void main(String[] args) {
ApplicationContext context=new ClassPathXmlApplicationContext("spring-jms.xml");
JmsTemplate jmsTemplate=(JmsTemplate) context.getBean("jmsTemplate");
Destination queueDestination=(Destination) context.getBean("queueDestination");
System.out.println("异步调用执行开始");
jmsTemplate.send(queueDestination, new MessageCreator(){
@Overridepublic Message createMessage(Session session) throws JMSException {return session.createTextMessage("Hello spring JMS");
}
});
System.out.println("异步调用执行结束");
}消息监听器：MyMessageListener
public class MyMessageListener implements MessageListener{
@Overridepublic void onMessage(Message message) {
TextMessage msg= (TextMessage) message;try {
System.out.println("你好："+msg.getText());
} catch (JMSException e) {
e.printStackTrace();
}
}
}启动消息生产者 监听器的执行结果是：
异步调用执行开始 异步调用执行结束 你好：Hello spring JMS
三、发布订阅 同步接收
spring-jms.xml:
生产者：
public static void main(String[] args) {
ApplicationContext context=new ClassPathXmlApplicationContext("spring-jms.xml");
JmsTemplate jmsTemplate=(JmsTemplate) context.getBean("jmsTemplate");
Destination topicDestination=(Destination) context.getBean("topicDestination");
jmsTemplate.send(topicDestination, new MessageCreator(){
@Overridepublic Message createMessage(Session session) throws JMSException {return session.createTextMessage("Hello spring JMS topicDestination");
}
});
}消费者：
public class SpringJmsSubscriber {public static void main(String[] args) {
ApplicationContext context=new ClassPathXmlApplicationContext("spring-jms.xml");
JmsTemplate jmsTemplate=(JmsTemplate) context.getBean("jmsTemplate");
Destination topicDestination=(Destination) context.getBean("topicDestination");
String msg=(String) jmsTemplate.receiveAndConvert(topicDestination);
System.out.println(msg);
}
}
