快速生成网站,wordpress带用户,北京企业网站开发公司哪家好,wordpress 调整 行距2019独角兽企业重金招聘Python工程师标准 1.参考文献 Spring集成ActiveMQ配置Spring JMS异步发收消息 ActiveMQ2.环境 在前面的一篇 ActiveMQ入门实例中我们实现了消息的异步传送#xff0c;这篇博文将如何在spring环境下集成ActiveMQ。如果要在spring下集成Act… 2019独角兽企业重金招聘Python工程师标准 1.参考文献 Spring集成ActiveMQ配置Spring JMS异步发收消息 ActiveMQ 2.环境 在前面的一篇 ActiveMQ入门实例中我们实现了消息的异步传送这篇博文将如何在spring环境下集成ActiveMQ。如果要在spring下集成ActiveMQ那么就需要将如下jar包导入项目 本文有两篇参考文献因此有两个实例项目结构如下图所示 3.实例1 信息发送者HelloSender.java package edu.sjtu.erplab.springactivemq;import javax.jms.JMSException;import javax.jms.Session;import javax.jms.Destination;import javax.jms.Message;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 HelloSender {/** * param args * jmsTemplate和destination都是在spring配置文件中进行配制的 * Sender只使用了配置文件中的jmsFactoryjmsTemplate还有destination这三个属性*/public static void main(String[] args) { ApplicationContext applicationContext new ClassPathXmlApplicationContext(applicationContext-jms.xml); JmsTemplate template (JmsTemplate) applicationContext.getBean(jmsTemplate); Destination destination (Destination) applicationContext.getBean(destination); template.send(destination, new MessageCreator() {public Message createMessage(Session session) throws JMSException {return session.createTextMessage(发送消息Hello ActiveMQ Text Message2); } }); System.out.println(成功发送了一条JMS消息); }} 信息接受者ProxyJMSConsumer.java package edu.sjtu.erplab.springactivemq;import javax.jms.Destination;import javax.jms.TextMessage;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;import org.springframework.jms.core.JmsTemplate;/** * JMS消费者 * 消息题的内容定义 * 消息对象 接收消息对象后 接收到的消息体* p */public class ProxyJMSConsumer {public ProxyJMSConsumer() { }private JmsTemplate jmsTemplate;public JmsTemplate getJmsTemplate() {return jmsTemplate; }public void setJmsTemplate(JmsTemplate jmsTemplate) {this.jmsTemplate jmsTemplate; }/** * 监听到消息目的有消息后自动调用onMessage(Message message)方法*/public void recive() { ApplicationContext applicationContext new ClassPathXmlApplicationContext(applicationContext-jms.xml); Destination destination (Destination) applicationContext.getBean(destination);while (true) {try { TextMessage txtmsg (TextMessage) jmsTemplate .receive(destination);if (null ! txtmsg) { System.out.println([DB Proxy] txtmsg); System.out.println([DB Proxy] 收到消息内容为: txtmsg.getText()); } elsebreak; } catch (Exception e) { e.printStackTrace(); } } }} 客户端JMSTest.java package edu.sjtu.erplab.springactivemq;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class JMSTest {/** * param args*/public static void main(String[] args) { ApplicationContext applicationContext new ClassPathXmlApplicationContext(applicationContext-jms.xml); ProxyJMSConsumer proxyJMSConsumer (ProxyJMSConsumer) applicationContext.getBean(messageReceiver); proxyJMSConsumer.recive(); System.out.println(初始化消息消费者); }} Spring配置文件applicationContext-jms.xml ?xml version1.0 encodingUTF-8?beans xmlnshttp://www.springframework.org/schema/beans xmlns:xsihttp://www.w3.org/2001/XMLSchema-instance xmlns:contexthttp://www.springframework.org/schema/context xsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd default-autowirebyName!-- 配置connectionFactory --bean idjmsFactory classorg.apache.activemq.pool.PooledConnectionFactory destroy-methodstopproperty nameconnectionFactorybean classorg.apache.activemq.ActiveMQConnectionFactoryproperty namebrokerURLvaluetcp://127.0.0.1:61616/value/property/bean/propertyproperty namemaxConnections value100/property/bean!-- Spring JMS Template --bean idjmsTemplate classorg.springframework.jms.core.JmsTemplateproperty nameconnectionFactoryref localjmsFactory //propertyproperty namedefaultDestinationName valuesubject /!-- 区别它采用的模式为false是p2p为true是订阅 --property namepubSubDomain valuetrue //bean!-- 发送消息的目的地一个队列 --bean iddestination classorg.apache.activemq.command.ActiveMQTopic!-- 设置消息队列的名字 --constructor-arg index0 valuesubject //beanbean idmessageReceiver classedu.sjtu.erplab.springactivemq.ProxyJMSConsumer!--classedu.sjtu.erplab.springactivemq.ProxyJMSConsumer--property namejmsTemplate refjmsTemplate/property/bean/beans 测试方法首先运行JMSTest然后运行HelloSender。 4.实例2 消息发送者 Sender package edu.sjtu.erplab.springactivemq2;import javax.jms.JMSException;import javax.jms.MapMessage;import javax.jms.Message;import javax.jms.Session;import org.springframework.jms.core.JmsTemplate;import org.springframework.jms.core.MessageCreator;public class Sender {private JmsTemplate jmsTemplate;//getter and setter public JmsTemplate getJmsTemplate() {return jmsTemplate; }public void setJmsTemplate(JmsTemplate jmsTemplate) {this.jmsTemplate jmsTemplate; }public void sendInfo() { jmsTemplate.send(new MessageCreator() {public Message createMessage(Session session) throws JMSException { MapMessage message session.createMapMessage(); message.setString(lastName, ppp);return message; } }); }} 消息发送客户端SenderTest package edu.sjtu.erplab.springactivemq2;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class SenderTest {public static void main(String[] args) {// TODO 自动生成方法存根 ApplicationContext context new ClassPathXmlApplicationContext(applicationContext.xml); Sender sender (Sender) context.getBean(sender); sender.sendInfo(); }} 消息接收者Receiver package edu.sjtu.erplab.springactivemq2;import javax.jms.JMSException;import javax.jms.MapMessage;import org.springframework.jms.core.JmsTemplate;import org.springframework.jms.support.JmsUtils;public class Receiver {private JmsTemplate jmsTemplate;//getter and setter public JmsTemplate getJmsTemplate() {return jmsTemplate; }public void setJmsTemplate(JmsTemplate jmsTemplate) {this.jmsTemplate jmsTemplate; }/** * 构造函数*/public Receiver() { }public String receiveMessage() { String my ; MapMessage message (MapMessage) jmsTemplate.receive();try { my message.getString(lastName); } catch (JMSException e) {throw JmsUtils.convertJmsAccessException(e); }return my; }} 消息接收客户端ReceiverTest package edu.sjtu.erplab.springactivemq2;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class ReceiverTest {public static void main(String[] args) {// TODO 自动生成方法存根 ApplicationContext context new ClassPathXmlApplicationContext(applicationContext.xml); Receiver receiver (Receiver) context.getBean(receiver); System.out.print(receiver.receiveMessage()); }} Spring配置文件applicationContext.xml ?xml version1.0 encodingUTF-8?beansxmlnshttp://www.springframework.org/schema/beans xmlns:xsihttp://www.w3.org/2001/XMLSchema-instance xsi:schemaLocationhttp://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd!--创建连接工厂--bean idconnectionFactory classorg.apache.activemq.ActiveMQConnectionFactoryproperty namebrokerURL valuetcp://localhost:61616/property/bean!-- 声明ActiveMQ消息目标,目标可以是一个队列也可以是一个主题ActiveMQTopic--bean iddestination classorg.apache.activemq.command.ActiveMQQueueconstructor-arg index0 valueedu.sjtu.erplab.springactivemq2/constructor-arg/bean!----bean idjmsTemplate classorg.springframework.jms.core.JmsTemplateproperty nameconnectionFactory refconnectionFactory/propertyproperty namedefaultDestination refdestination/propertyproperty namereceiveTimeout value600/property/beanbean idsender classedu.sjtu.erplab.springactivemq2.Senderproperty namejmsTemplate refjmsTemplate/property/beanbean idreceiver classedu.sjtu.erplab.springactivemq2.Receiverproperty namejmsTemplate refjmsTemplate/property/bean/beans 转载于:https://my.oschina.net/zhanghaiyang/blog/606519
