其他分享
首页 > 其他分享> > springboot整合ActiveMQ1(基本使用)

springboot整合ActiveMQ1(基本使用)

作者:互联网

说明:acitveMQ 版本为:5.9.1,springboot 版本为 2.0.3

一. 下载安装(windows)

  官方下载地址:点我跳转,选择 windows 安装包下载,然后解压,解压后运行 bin 目录下的activemq.bat启动服务,无报错即可启动成功。默认管理地址为:localhost:8161/admin,默认管理员账号密码为admin/admin

二. springboot 整合

1. 创建 springboot 项目

  创建 springboot web 项目,加入 spring-boot-starter-activemq 依赖。

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

  然后编辑配合文件,加上一个配置:61616 为 activeMQ 的默认端口,暂时不做其他配置,使用默认值。

spring:  activemq:    broker-url: tcp://localhost:61616

2. 创建生产者消费者

  springboot 中 activeMQ 的默认配置为生产-消费者模式,还有一种模式为发布-订阅模式后面再讲。项目目录如下:

图片

  首先编写配置类 Config.java,代码如下

  1. @Configuration

  2. public class Config {

  3.    @Bean(name = "queue2")

  4.    public Queue queue2(){

  5.        return new ActiveMQQueue("active.queue2");

  6.    }


  7.    @Bean(name = "queue1")

  8.    public Queue queue1(){

  9.        return new ActiveMQQueue("active.queue1");

  10.    }

  11. }

上面的代码建立了两个消息队列 queue1,queue2,分别由 queue1 和 queue2 这两个 Bean 注入到 Spring 容器中。程序运行后会在 activeMQ 的管理页面->queue 中看到如下:

图片

  生产者 Producer.java 代码如下:

  1. @RestController

  2. public class Producer {

  3.    @Autowired

  4.    private JmsMessagingTemplate jmsMessagingTemplate;

  5.    @Autowired()

  6.    @Qualifier("queue2")

  7.    private Queue queue2;

  8.    @Autowired()

  9.    @Qualifier("queue1")

  10.    private Queue queue1;


  11.    @GetMapping("/queue2")

  12.    public void sendMessage1(String message){

  13.            jmsMessagingTemplate.convertAndSend(queue2,"I'm from queue2:"+message);

  14.    }


  15.    @GetMapping("/queue1")

  16.    public void sendMessage2(String message){

  17.        jmsMessagingTemplate.convertAndSend(queue1,"I'm from queue1:"+message);

  18.    }

  19. }

上面的类创建了两个 GET 接口,访问这两个接口分别向 queue1 和 queue2 中发送消息。

消费者 Comsumer.java 代码如下:

  1. @Component //将该类注解到Spring 容器中

  2. public class Comsumer {

  3.    //接受消息队列1消息

  4.    @JmsListener(destination = "active.queue1") //监听active.queue1消息队列

  5.    public void readActiveQueue11(String message){

  6.        System.out.println(1+message);

  7.    }


  8.    //接受消息队列1消息

  9.    @JmsListener(destination = "active.queue1")

  10.    public void readActiveQueue12(String message){

  11.        System.out.println(2+message);

  12.    }


  13.    //接受消息队列2消息

  14.    @JmsListener(destination = "active.queue2")

  15.    public void readActiveQueue21(String message){

  16.        System.out.println(1+message);

  17.    }


  18.    //接受消息队列2消息

  19.    @JmsListener(destination = "active.queue2")

  20.    public void readActiveQueue22(String message){

  21.        System.out.println(2+message);

  22.    }

  23. }

上面的代码定义了 4 个消费者,每两个消费一个消息队列。

3. 运行

  启动项目后分别向/queue1?message=niihao,/queue2?message=nihaoa 发送 http 请求,然后我们可以在控制台中看到如下输出:

2I'm from queue2:nihaoa1I'm from queue2:nihaoa2I'm from queue1:nihao1I'm from queue1:nihao

消息都成功被消费者消费,从打印结果也可看出生产者消费者的一个特点:一个消息只会被一个消费者消费。同时在管理页面中可以看到:

图片

每个消息队列有两个消费者,队列进入了三个消息,出了三个消息,说明消息都被消费掉了,如果注释掉消费者代码,再次运行,然后发送消息就会发现 MessagesEnqueued 数量大于 MessagesDequeued,然后再让消费者上线会立即消费掉队列中的消息。


标签:ActiveMQ1,springboot,queue1,queue2,队列,消息,整合,message,public
来源: https://blog.51cto.com/u_15127618/2758271