zoukankan      html  css  js  c++  java
  • ActiveMQ与spring整合

    第一步:引用相关的jar包

                    <dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-jms</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework</groupId>
    			<artifactId>spring-context-support</artifactId>
    		</dependency>
        
    

    第二步:配置Activemq整合spring

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	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-4.2.xsd
    	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
    	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
    	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
    
    	<!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供 -->
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    		<property name="brokerURL" value="tcp://192.168.25.168:61616" />
    	</bean>
    	<!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->
    	<bean id="connectionFactory"
    		class="org.springframework.jms.connection.SingleConnectionFactory">
    		<!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->
    		<property name="targetConnectionFactory" ref="targetConnectionFactory" />
    	</bean>
    	<!-- 配置生产者 -->
    	<!-- Spring提供的JMS工具类,它可以进行消息发送、接收等 -->
    	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    		<!-- 这个connectionFactory对应的是我们定义的Spring提供的那个ConnectionFactory对象 -->
    		<property name="connectionFactory" ref="connectionFactory" />
    	</bean>
    	<!--这个是队列目的地,点对点的 -->
    	<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
    		<constructor-arg>
    			<value>spring-queue</value>
    		</constructor-arg>
    	</bean>
    	<!--这个是主题目的地,一对多的 -->
    	<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
    		<constructor-arg value="topic" />
    	</bean>
    </beans>
    
    @Test
    	public void testQueueProducer() throws Exception {
    		// 第一步:初始化一个spring容器
    		ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml");
    		// 第二步:从容器中获得JMSTemplate对象。
    		JmsTemplate jmsTemplate = applicationContext.getBean(JmsTemplate.class);
    		// 第三步:从容器中获得一个Destination对象
    		Queue queue = (Queue) applicationContext.getBean("queueDestination");
    		// 第四步:使用JMSTemplate对象发送消息,需要知道Destination
    		jmsTemplate.send(queue, new MessageCreator() {
    			
    			@Override
    			public Message createMessage(Session session) throws JMSException {
    				TextMessage textMessage = session.createTextMessage("spring activemq test");
    				return textMessage;
    			}
    		});
    	}
    

      

    <?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"
    	xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
    	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-4.2.xsd
    	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd
    	http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
    	http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">
    
    	<!-- 真正可以产生Connection的ConnectionFactory,由对应的 JMS服务厂商提供 -->
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    		<property name="brokerURL" value="tcp://192.168.25.168:61616" />
    	</bean>
    	<!-- Spring用于管理真正的ConnectionFactory的ConnectionFactory -->
    	<bean id="connectionFactory"
    		class="org.springframework.jms.connection.SingleConnectionFactory">
    		<!-- 目标ConnectionFactory对应真实的可以产生JMS Connection的ConnectionFactory -->
    		<property name="targetConnectionFactory" ref="targetConnectionFactory" />
    	</bean>
    	<!--这个是队列目的地,点对点的 -->
    	<bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">
    		<constructor-arg>
    			<value>spring-queue</value>
    		</constructor-arg>
    	</bean>
    	<!--这个是主题目的地,一对多的 -->
    	<bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">
    		<constructor-arg value="topic" />
    	</bean>
    	<!-- 接收消息 -->
    	<!-- 配置监听器 -->
    	<bean id="myMessageListener" class="cn.e3mall.search.listener.MyMessageListener" />
    	<!-- 消息监听容器 -->
    	<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    		<property name="connectionFactory" ref="connectionFactory" />
    		<property name="destination" ref="queueDestination" />
    		<property name="messageListener" ref="myMessageListener" />
    	</bean>
    </beans>
    

      

    public class MyMessageListener implements MessageListener {
    
    	@Override
    	public void onMessage(Message message) {
    		
    		try {
    			TextMessage textMessage = (TextMessage) message;
    			//取消息内容
    			String text = textMessage.getText();
    			System.out.println(text);
    		} catch (JMSException e) {
    			e.printStackTrace();
    		}
    

      

  • 相关阅读:
    富文本
    管理员状态
    分页
    tp。3.2中的模板基础
    get和post之间的区别
    RegExp
    获取各种类型的节点
    节点的层次关系
    创建元素节点
    JavaScript 正则
  • 原文地址:https://www.cnblogs.com/zhoucx66/p/9316875.html
Copyright © 2011-2022 走看看