ActiveMQ整合Spring——接收消息

布满荆棘的人生 2022-05-27 09:56 220阅读 0赞

需要的jar包，同上篇文章：

新建spring-activemq.xml，配置如下（配置与发送消息稍有不同）：

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
    	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    	xmlns:context="http://www.springframework.org/schema/context"
    	xsi:schemaLocation="http://www.springframework.org/schema/beans
         http://www.springframework.org/schema/beans/spring-beans.xsd 
         http://code.alibabatech.com/schema/dubbo 
         http://code.alibabatech.com/schema/dubbo/dubbo.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.25.134:61616" />
    	</bean>
    	
    	<bean id="connectionFactory"
    		class="org.springframework.jms.connection.SingleConnectionFactory">
    		
    		<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.search.service.MyMessageListener" />
    	
    	<bean
    		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    		<property name="connectionFactory" ref="connectionFactory" />
    		<property name="destination" ref="topicDestination" />
    		<property name="messageListener" ref="myMessageListener" />
    	</bean>
    
    
    </beans>

新建一个类，实现MessageListsener接口：

package cn.search.service;
    
    import java.io.IOException;
    
    import javax.jms.JMSException;
    import javax.jms.Message;
    import javax.jms.MessageListener;
    import javax.jms.TextMessage;
    
    import org.apache.solr.client.solrj.SolrServerException;
    import org.apache.solr.client.solrj.impl.CloudSolrServer;
    import org.apache.solr.common.SolrDocument;
    import org.apache.solr.common.SolrInputDocument;
    import org.springframework.beans.factory.annotation.Autowired;
    
    import com.e3mall.search.SearchItem;
    
    import cn.search.mapper.ISearchMapper;
    
    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 (Exception e) {
    			// TODO: handle exception
    		}
    
    	}
    
    }