Spring整合MQ配置是什么

Spring整合MQ配置是什么，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQTopic; import org.apache.activemq.pool.PooledConnectionFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jms.core.JmsTemplate; import org.springframework.jms.listener.*; import org.springframework.jms.support.converter.SimpleMessageConverter; import org.springframework.scheduling.annotation.EnableAsync; import org.springframework.scheduling.annotation.EnableScheduling; import javax.jms.*; @Configuration @EnableAsync @EnableScheduling public class MQConfig {     /**      * 配置队列消息模板      * @param jmsFactory      * @return      */     @Bean     public JmsTemplate queueTemplate(@Autowired ConnectionFactory jmsFactory,                                    @Autowired ActiveMQQueue activeMQQueue) {         var template = new JmsTemplate(jmsFactory);         template.setDefaultDestination(activeMQQueue);         template.setMessageConverter(new SimpleMessageConverter());         return template;     }     /**      * 配置主题消息模板      * @param jmsFactory      * @param activeMQTopic      * @return      */     @Bean     public JmsTemplate topicTemplate(@Autowired ConnectionFactory jmsFactory,                                    @Autowired ActiveMQTopic activeMQTopic) {         var template = new JmsTemplate(jmsFactory);         template.setDefaultDestination(activeMQTopic);         template.setMessageConverter(new SimpleMessageConverter());         return template;     }     /**      * 配置消息生产者      * @return      */     @Bean     public PooledConnectionFactory JmsFactory() {         return new PooledConnectionFactory();     }     /**      * 配置队列消息      * @return      */     @Bean     public ActiveMQQueue activeMQQueue() {         return new ActiveMQQueue();     }     /**      * 配置主题消息      * @return      */     @Bean     public ActiveMQTopic activeMQTopic() {         return new ActiveMQTopic();     }     /**      * 配置监听器      * @return      */     @Bean     public MessageListener messageListener() {         MessageListener messageListener = new MessageListener() {             @Override             public void onMessage(Message message) {                 if (null != message && message instanceof TextMessage) {                     try {                         ((TextMessage) message).getText();                     } catch (JMSException e) {                         e.printStackTrace();                     }                 }             }         };         return messageListener;     }     /**      * 配置监听容器      * @param jmsFactory      * @param activeMQQueue      * @param messageListener      * @return      */     @Bean     public DefaultMessageListenerContainer jmsContainer(@Autowired ConnectionFactory jmsFactory,                                                         @Autowired ActiveMQQueue activeMQQueue,                                                         @Autowired MessageListener messageListener) {         DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();         container.setConnectionFactory(jmsFactory);         container.setDestination(activeMQQueue);         container.setMessageListener(messageListener);         return container;     } }

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.jms.core.JmsTemplate; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import javax.jms.TextMessage; @Service public class MQ {     @Autowired@Qualifier("queueTemplate")     private JmsTemplate queueTemplate;     @Autowired@Qualifier("topicTemplate")     private JmsTemplate topicTemplate;     @Async     public void queueProducer(){         queueTemplate.send(session -> {             TextMessage textMessage = session.createTextMessage("*****");             return textMessage;         });     }     @Async     public void queueConsumer(){         queueTemplate.receiveAndConvert();     }     @Async     public void topicProducer(){         topicTemplate.send(session -> {             TextMessage textMessage = session.createTextMessage("*****");             return textMessage;         });     }     @Async     public void topicConsumer(){         topicTemplate.receiveAndConvert();     } }

关于Spring整合MQ配置是什么问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注亿速云行业资讯频道了解更多相关知识。