Springboot中如何整合Activemq

本篇内容介绍了"Springboot中如何整合Activemq"的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

1 导入整合所需要的依赖：

      org.springframework.boot      spring-boot-starter-activemq    

2 创建application.properties文件

spring.activemq.broker-url=tcp://127.0.0.1:61616spring.activemq.user=adminspring.activemq.password=adminserver.port=8080queue=myqueue

3.自定义配置文件QueueConfig 读取配置文件的队列名，根据队列名字创建一个Queue

package com.example.demo;import javax.jms.Queue;import org.apache.activemq.ActiveMQConnectionFactory;import org.apache.activemq.command.ActiveMQQueue;import org.springframework.beans.factory.annotation.Value;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.jms.config.DefaultJmsListenerContainerFactory;import org.springframework.jms.core.JmsTemplate;@Configurationpublic class QueueConfig {  @Value("${queue}")  private String queue;  @Bean  public Queue logQueue() {    return new ActiveMQQueue(queue);  }}

4.创建生产者，可以直接使用提供的模板JmsMessagingTemplate 进行消息的发送：

package com.example.demo.producter;import javax.jms.Queue;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.jms.core.JmsMessagingTemplate;import org.springframework.stereotype.Component;import com.example.demo.SpringbootActivemqApplication;@Componentpublic class Producter {  @Autowired  private JmsMessagingTemplate jmsMessagingTemplate;  @Autowired  private Queue queue;  private static Logger logger = LoggerFactory.getLogger(Producter .class); public void send() { String str = "生产者生产数据：" + System.currentTimeMillis(); jmsMessagingTemplate.convertAndSend(queue, str); logger.info("生产者数据:{}", str); } }

5.启动类：

package com.example.demo;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.context.ApplicationListener;import org.springframework.context.event.ContextRefreshedEvent;import org.springframework.scheduling.annotation.EnableScheduling;import com.example.demo.producter.Producter;import com.example.demo.producter.consumer.Consumer;@SpringBootApplication@EnableSchedulingpublic class SpringbootActivemqApplication implements ApplicationListener {  @Autowired  public Producter producter;  @Autowired  public Consumer consumer;  public static void main(String[] args) {    SpringApplication.run(SpringbootActivemqApplication.class, args);    //onApplicationEvent方法 在启动springboot的时候 会运行该方法,可根据项目实际情况 选择合适调用消息发送方法  }  @Override  public void onApplicationEvent(ContextRefreshedEvent event) {    producter.send();  }}

6.启动项目,控制台输出内容：

7.创建消费者，创建消费者比较容易，只需要监听队列就可以：

package com.example.demo.producter.consumer;import org.springframework.jms.annotation.JmsListener;import org.springframework.stereotype.Component;@Componentpublic class Consumer {  @JmsListener(destination = "${queue}")  public void receive(String msg) {    System.out.println("监听器收到msg:" + msg);  }}

8.最后结果：

"Springboot中如何整合Activemq"的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站，小编将为大家输出更多高质量的实用文章！