ActiveMQ的jms&springjms使用步骤

超、凢脫俗 2022-05-16 08:44 148阅读 0赞

jms的使用步骤   9步

### （点对点模式：生产者） ###

//1.创建连接工厂
    	ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
    	//2.获取连接
    	Connection connection = connectionFactory.createConnection();
    	//3.启动连接
    	connection.start();
    	//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)
    	Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);		
    	//5.创建队列对象
    	Queue queue = session.createQueue("test-queue");
    	//6.创建消息生产者
    	MessageProducer producer = session.createProducer(queue);
    	//7.创建消息
    	TextMessage textMessage = session.createTextMessage("欢迎来到神奇activeMQ世界");
    	//8.发送消息
    	producer.send(textMessage);
    	//9.关闭资源
    	producer.close();
    	session.close();
    	connection.close();

### （点对点模式：消费者） ###

//1.创建连接工厂
    	ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
    	//2.获取连接
    	Connection connection = connectionFactory.createConnection();
    	//3.启动连接
    	connection.start();
    	//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)
    	Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    	//5.创建队列对象
    	Queue queue = session.createQueue("test-queue");
    	//6.创建消息消费
    	MessageConsumer consumer = session.createConsumer(queue);
    	
    	//7.监听消息
    	consumer.setMessageListener(new MessageListener() {
    		public void onMessage(Message message) {
    			TextMessage textMessage=(TextMessage)message;
    			try {
    				System.out.println("接收到消息："+textMessage.getText());
    			} catch (JMSException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    	});	
    	//8.等待键盘输入
    	System.in.read();	
    	//9.关闭资源
    	consumer.close();
    	session.close();
    	connection.close();

执行后看到控制台输出

![70][]

\-------------------------------------------------------------------------------------------------------------------------------------------------------------------------

### （发布/订阅模式：生产者） ###

//1.创建连接工厂
    	ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
    	//2.获取连接
    	Connection connection = connectionFactory.createConnection();
    	//3.启动连接
    	connection.start();
    	//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)
    	Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    	//5.创建主题对象
    	Topic topic = session.createTopic("test-topic");
    	//6.创建消息生产者
    	MessageProducer producer = session.createProducer(topic);
    	//7.创建消息
    	TextMessage textMessage = session.createTextMessage("欢迎来到神奇的品优购世界");
    	//8.发送消息
    	producer.send(textMessage);
    	//9.关闭资源
    	producer.close();
    	session.close();
    	connection.close();

###  ![70 1][] ###

### （发布/订阅模式：消费者） ###

//1.创建连接工厂
    	ConnectionFactory connectionFactory=new ActiveMQConnectionFactory("tcp://192.168.25.135:61616");
    	//2.获取连接
    	Connection connection = connectionFactory.createConnection();
    	//3.启动连接
    	connection.start();
    	//4.获取session  (参数1：是否启动事务,参数2：消息确认模式)
    	Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    	//5.创建主题对象
    	//Queue queue = session.createQueue("test-queue");
    	Topic topic = session.createTopic("test-topic");
    	//6.创建消息消费
    	MessageConsumer consumer = session.createConsumer(topic);
    	
    	//7.监听消息
    	consumer.setMessageListener(new MessageListener() {
    		public void onMessage(Message message) {
    			TextMessage textMessage=(TextMessage)message;
    			try {
    				System.out.println("接收到消息："+textMessage.getText());
    			} catch (JMSException e) {
    				// TODO Auto-generated catch block
    				e.printStackTrace();
    			}
    		}
    	});
    	//8.等待键盘输入
    	System.in.read();
    	//9.关闭资源
    	consumer.close();
    	session.close();
    	connection.close();

------------------------------------------------------------------------------------------------------------------------------------------------------------------------

# Spring整合JMS #

1.在src/main/resources下创建spring配置文件applicationContext-jms-producer.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core"
    	xmlns:jms="http://www.springframework.org/schema/jms"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans   
    		http://www.springframework.org/schema/beans/spring-beans.xsd
    		http://www.springframework.org/schema/context   
    		http://www.springframework.org/schema/context/spring-context.xsd">
    	   
          
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  
    	    <property name="brokerURL" value="tcp://192.168.3.171:61616"/>  
    	</bean>
    	   
          
    	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">  
    	  
    	    <property name="targetConnectionFactory" ref="targetConnectionFactory"/>  
    	</bean>  
    		   
          
    	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">  
    	      
    	    <property name="connectionFactory" ref="connectionFactory"/>  
    	</bean>      
          
    	<bean id="queueSolrDestination" class="org.apache.activemq.command.ActiveMQQueue">  
    	    <constructor-arg value="pinyougou_queue_solr"/>  
    	</bean>    
    	
    	<bean id="queueSolrDeleteDestination" class="org.apache.activemq.command.ActiveMQQueue">  
    	    <constructor-arg value="pinyougou_queue_solr_delete"/>  
    	</bean>  
    	
    	
    	<bean id="topicPageDestination" class="org.apache.activemq.command.ActiveMQTopic">  
    	    <constructor-arg value="pinyougou_topic_page"/>  
    	</bean>  
    	
    	
    	<bean id="topicPageDeleteDestination" class="org.apache.activemq.command.ActiveMQTopic">  
    	    <constructor-arg value="pinyougou_topic_page_delete"/>  
    	</bean>
    	
    </beans>

2.在src/main/resources下创建spring配置文件applicationContext-jms-consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:amq="http://activemq.apache.org/schema/core"
    	xmlns:jms="http://www.springframework.org/schema/jms"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans   
    		http://www.springframework.org/schema/beans/spring-beans.xsd
    		http://www.springframework.org/schema/context   
    		http://www.springframework.org/schema/context/spring-context.xsd">
    	
          
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">  
    	    <property name="brokerURL" value="tcp://192.168.3.171:61616"/>  
    	</bean>
    	   
          
    	<bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">  
    	  
    	    <property name="targetConnectionFactory" ref="targetConnectionFactory"/>  
    	</bean>  
    	
          
    	<bean id="topicPageDestination" class="org.apache.activemq.command.ActiveMQTopic">  
    	    <constructor-arg value="pinyougou_topic_page"/>  
    	</bean>    
    	
    	<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    		<property name="connectionFactory" ref="connectionFactory" />
    		<property name="destination" ref="topicPageDestination" />
    		<property name="messageListener" ref="pageListener" />
    	</bean>
    	  
    	<bean id="topicPageDeleteDestination" class="org.apache.activemq.command.ActiveMQTopic">  
    	    <constructor-arg value="pinyougou_topic_page_delete"/>  
    	</bean>    
    	
    	<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    		<property name="connectionFactory" ref="connectionFactory" />
    		<property name="destination" ref="topicPageDeleteDestination" />
    		<property name="messageListener" ref="pageDeleteListener" />
    	</bean>
    </beans>

创建一个类  继承MessageListener接口（名字和消息监听容器中配置的相同）

package com.pinyougou.page.service.impl;
    
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.MessageListener;
    import javax.jms.TextMessage;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import com.pinyougou.page.service.ItemPageService;
    
    
    @Component
    public class PageListener implements MessageListener {
    
    	@Autowired
    	private ItemPageService itemPageService;
    	
    	@Override
    	public void onMessage(Message message) {
    		// TODO Auto-generated method stub
    		
    		TextMessage textMessage = (TextMessage) message;
    		
    		try {
    			String text = textMessage.getText();
    			System.out.println("接收到消息"+ text);
    			boolean b = itemPageService.genItemHtml(Long.parseLong(text));
    			System.out.println("网页生成结果"+b);
    			
    		} catch (JMSException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    
    	}
    
    }

[70]: /images/20220516/e7b767357b6541d7b97b141c68d64cad.png
[70 1]: /images/20220516/8150186451cb45448b0837739a6ff7cb.png