Springboot整合activeMq

Posted jsnan

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Springboot整合activeMq相关的知识,希望对你有一定的参考价值。

1.maven依赖

 <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-activemq</artifactId>
 </dependency>

2.properties.yml配置

spring:
  activemq:
    broker-url: tcp://ip:61616
    user: admin
    password: admin
queue: queue_name

3.创建一个队列

/**
 * 创建一个队列
 */
@Configuration
public class QueueConfig {

    @Value("${queue}")
    private String queueName;

    @Bean
    public Queue queue(){
        return new ActiveMQQueue(queueName);
    }
}

4.创建生产者

/**
 * 生产者
 */
@Component
@EnableScheduling
public class Producer {


    @Autowired
    JmsMessagingTemplate jmsMessagingTemplate;


    @Autowired
    private Queue queue;

    private int i = 0;

    //定时器每隔5秒向activmq服务器发送一条消息
    @Scheduled(fixedDelay = 5000)
    public void send(){
        i ++;
        jmsMessagingTemplate.convertAndSend(queue, "第"+i+"条数据");
    }

}

5.创建消费者

/**
 * 消费者
 */
@Component
public class Consumer {

    @JmsListener(destination = "${queue}")
    public void receive(String msg){
        System.out.println("消费者"+msg);
    }
    
}

6.运行程序即可在控制台看到数据接收记录

 

以上是关于Springboot整合activeMq的主要内容,如果未能解决你的问题,请参考以下文章

一文讲解SpringBoot整合ActiveMQ,这样学习不香吗?(附代码)

SpringBoot整合ActiveMQ

Springboot+Activemq整合

SpringBoot2.0源码分析:整合ActiveMQ分析

spring boot整合activeMQ

SpringBoot 整合 ActiveMq