引言
代码已提交至Github，有兴趣的同学可以下载来看看：https://github.com/ylw-github/SpringBoot-ActiveMQ-Demo
在上一篇博客《ActiveMQ -安装&入门案例》中，里面的入门案例其实是ActiveMQ点对点的模式了，本文主要来讲解一下Active的发布订阅模式。
1.生产者
1.添加mave依赖：
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.1.RELEASE</version> </parent> <!-- 管理依赖 --> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Finchley.M7</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <!-- SpringBoot整合Web组件 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- SpringBoot Activemq --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> </dependencies> <!-- 注意： 这里必须要添加， 否者各种依赖有问题 --> <repositories> <repository> <id>spring-milestones</id> <name>Spring Milestones</name> <url>https://repo.spring.io/libs-milestone</url> <snapshots> <enabled>false</enabled> </snapshots> </repository> </repositories>
2.配置application.yml文件：
server: port: 8080 spring: activemq: broker-url: tcp://192.168.162.131:61616 user: admin password: admin kafka: template: default-topic: queue: springboot-queue topic: spring-topic
3.主题生产者TopicProducer：
@Component public class TopicProducer { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @Autowired private Topic topic; @Scheduled(fixedDelay = 5000) public void send() { String msg = System.currentTimeMillis() + ""; System.out.println("采用发布订阅方式,生产者向消费者发送内容:" + msg); jmsMessagingTemplate.convertAndSend(topic, msg); } }
4.主题配置：
import javax.jms.Topic; @Component public class TopicConfig { @Value("${topic}") private String topicName; @Bean public Topic topic() { return new ActiveMQTopic(topicName); } }
5.启动类：
@SpringBootApplication @EnableScheduling public class App { public static void main(String[] args) { SpringApplication.run(App.class, args); } }
2.消费者
1.添加maven依赖：
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.0.1.RELEASE</version> </parent> <!-- 管理依赖 --> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Finchley.M7</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <!-- SpringBoot整合Web组件 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- SpringBoot Activemq --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> <!--fastjson --> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.49</version> </dependency> </dependencies> <!-- 注意： 这里必须要添加， 否者各种依赖有问题 --> <repositories> <repository> <id>spring-milestones</id> <name>Spring Milestones</name> <url>https://repo.spring.io/libs-milestone</url> <snapshots> <enabled>false</enabled> </snapshots> </repository> </repositories>
2.配置文件：
server: port: 8081 spring: activemq: broker-url: tcp://192.168.162.131:61616 user: admin password: admin #### 开启发布订阅 jms: pub-sub-domain: true topic: spring-topic queue: springboot-queue
3.主题消费者：
import org.springframework.jms.annotation.JmsListener; import org.springframework.stereotype.Component; @Component public class TopicConsumer { @JmsListener(destination = "spring-topic") public void receive(String msg) { System.out.println("发布与订阅消费者接受，生产者内容:" + msg); } }
3.测试
step1.启动ActiveMQ服务：
/usr/local/apache-activemq-5.15.10/bin/activemq start
step2.浏览器访问：http://192.168.162.131:8161/admin（账号：admin、密码：admin），可以看到ActiveMQ服务开启成功。
step3.启动生产者和消费者项目，在生产者控制台可以看到：
消费者控制台可以看到：
