spring 集成ActiveMQ 采用 jms onMessage 异步消费

你的名字 2022-04-11 09:50 256阅读 0赞

1. ActiveMQ 地址，用户，密码 的配置信息,failover做MQ服务的异常切换

MQ_USERNAME=user
    MQ_PASSWORD=password
    MQ_BROKEURL=failover:(tcp://198.13.135.106:8103,tcp://198.13.135.107:8103)

2.ActiveMQ  的spring  xml配置

<bean id="pc" class="cn.util.PropertiesUtil">
    		<property name="locations">
    			<list>
    				<value> classpath:config.properties    </value>
    			</list>
    		</property>
    		<property name="ignoreUnresolvablePlaceholders" value="true" />
    	</bean>
    	
    	<bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
    		<property name="brokerURL" value="${MQ_BROKEURL}" />
    		<property name="userName" value="${MQ_USERNAME}" />
    		<property name="password" value="${MQ_PASSWORD}" />
    	</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>QD</value>
    		</constructor-arg>
    	</bean>
    	<bean id="myMessageListener" class="cn.listener.MyMessageListener"/>
    
    
    	
    	<bean id="messageListenerContainer"
    		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    		<property name="connectionFactory" ref="connectionFactory" />
    		<property name="destination" ref="queueDestination" />
    		<property name="messageListener" ref="myMessageListener" />
    	</bean>

3. MessageListener 重写onMessage()方法

public class MyMessageListener implements MessageListener {
        private static final Logger logger = Logger.getLogger(MyMessageListener .class);
    
    
        @Override
        public void onMessage(Message message) {
            try {
                if (null != message) {
                    if (message instanceof TextMessage) {
                        TextMessage textMessage = (TextMessage) message;
                        String text = textMessage.getText();
                        logger.info("监听到消息 : " + text);
                    }
                }
            } catch (Exception e) {
                logger.error("操作消息队列的信息异常" + e.getLocalizedMessage());
            }
        }
    }