189 8069 5689
Spring整合MQ配置是什么，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
创新互联自2013年起，是专业互联网技术服务公司，拥有项目网站设计、成都网站设计网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元松江做网站,已为上家服务,为松江各地企业和个人服务,联系电话:13518219792
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配置是什么问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注创新互联行业资讯频道了解更多相关知识。