springboot与activeMQ入门（1）

说明：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，代码如下

@Configuration public class Config { @Bean(name = "queue2") public Queue queue2(){ return new ActiveMQQueue("active.queue2"); } @Bean(name = "queue1") public Queue queue1(){ return new ActiveMQQueue("active.queue1"); } }

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