Springboot Activemq整合过程代码图解
这篇文章主要介绍了SpringbootActivemq整合过程代码图解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
Springboot+Activemq整合
1导入整合所需要的依赖：
org.springframework.boot spring-boot-starter-activemq
2创建application.properties文件
spring.activemq.broker-url=tcp://127.0.0.1:61616 spring.activemq.user=admin spring.activemq.password=admin server.port=8080 queue=myqueue
3.自定义配置文件QueueConfig读取配置文件的队列名，根据队列名字创建一个Queue
packagecom.example.demo;
importjavax.jms.Queue;
importorg.apache.activemq.ActiveMQConnectionFactory;
importorg.apache.activemq.command.ActiveMQQueue;
importorg.springframework.beans.factory.annotation.Value;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.jms.config.DefaultJmsListenerContainerFactory;
importorg.springframework.jms.core.JmsTemplate;
@Configuration
publicclassQueueConfig{
@Value("${queue}")
privateStringqueue;
@Bean
publicQueuelogQueue(){
returnnewActiveMQQueue(queue);
}}
4.创建生产者，可以直接使用提供的模板JmsMessagingTemplate进行消息的发送：
packagecom.example.demo.producter;
importjavax.jms.Queue;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.jms.core.JmsMessagingTemplate;
importorg.springframework.stereotype.Component;
importcom.example.demo.SpringbootActivemqApplication;
@Component
publicclassProducter{
@Autowired
privateJmsMessagingTemplatejmsMessagingTemplate;
@Autowired
privateQueuequeue;
privatestaticLoggerlogger=LoggerFactory.getLogger(
Producter
.class);publicvoidsend(){Stringstr="生产者生产数据："+System.currentTimeMillis();jmsMessagingTemplate.convertAndSend(queue,str);logger.info("生产者数据:{}",str);}}
5.启动类：
packagecom.example.demo; importorg.springframework.beans.factory.annotation.Autowired; importorg.springframework.boot.SpringApplication; importorg.springframework.boot.autoconfigure.SpringBootApplication; importorg.springframework.context.ApplicationListener; importorg.springframework.context.event.ContextRefreshedEvent; importorg.springframework.scheduling.annotation.EnableScheduling; importcom.example.demo.producter.Producter; importcom.example.demo.producter.consumer.Consumer; @SpringBootApplication @EnableScheduling publicclassSpringbootActivemqApplicationimplementsApplicationListener{ @Autowired publicProducterproducter; @Autowired publicConsumerconsumer; publicstaticvoidmain(String[]args){ SpringApplication.run(SpringbootActivemqApplication.class,args); //onApplicationEvent方法在启动springboot的时候会运行该方法,可根据项目实际情况选择合适调用消息发送方法 } @Override publicvoidonApplicationEvent(ContextRefreshedEventevent){ producter.send(); } }
6.启动项目,控制台输出内容：
7.创建消费者，创建消费者比较容易，只需要监听队列就可以：
packagecom.example.demo.producter.consumer;
importorg.springframework.jms.annotation.JmsListener;
importorg.springframework.stereotype.Component;
@Component
publicclassConsumer{
@JmsListener(destination="${queue}")
publicvoidreceive(Stringmsg){
System.out.println("监听器收到msg:"+msg);
}
}
8.最后结果：
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。