Spring Boot系列文章(四):SpringBoot ActiveMQ 整合使用

busan-night-scene-1747130_1920

介绍 ActiveMQ

它是 Apache 出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现,尽管 JMS 规范出台已经是很久的事情了,但是 JMS 在当今的J2EE应用中间仍然扮演着特殊的地位。—— 摘自百度百科,偷了个懒。

SpringBoot 系列文章

相关文章

1、SpringBoot Kafka 整合使用

2、SpringBoot RabbitMQ 整合使用

安装 ActiveMQ

同之前一样,直接在 Docker 里面玩吧。命令也是一行解决:

1
docker run -d -p 8161:8161 -p 61616:61616 -e ACTIVEMQ_ADMIN_LOGIN=admin -e ACTIVEMQ_ADMIN_PASSWORD=admin --name activemq webcenter/activemq

简单解释下:

  • 8186: 表示 ActiveMQ 控制台端口号,它和 RabbitMQ 一样都是有控制台的,可以登陆控制台进行操作的
  • 61616 : 表示 ActiveMQ 所监听的 TCP 端口号,应用程序可通过该端口号与 ActiveMQ 建立 TCP 连接
  • CTIVEMQ_ADMIN_LOGIN :登陆控制台的用户名
  • ACTIVEMQ_ADMIN_PASSWORD :登陆控制台的密码

执行后,可在浏览器输入 http://localhost:8161/ 查看控制台,

Snip20180124_1

Snip20180124_2

解释下上面图片中控制台这些按钮的基本信息:

  • Home:查看 ActiveMQ 的常见信息
  • Queues:查看 ActiveMQ 的队列信息
  • Topics:查看 ActiveMQ 的主题信息
  • Subscribers:查看主题的订阅者信息
  • Connections:查看 ActiveMQ 客户端的连接信息
  • Network:查看 ActiveMQ 的网络信息
  • Scheduled:查看 ActiveMQ 的定时任务
  • Send:用于通过表单方式向队列或者主题发送具体的消息

整合

IDEA 创建 SpringBoot 项目,因为 SpringBoot 已经内置了对 ActiveMQ 的支持,所以直接引入依赖 spring-boot-starter-activemq 就行。整体项目结构如下:

Snip20180124_3

1、pom.xml 文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<groupId>com.zhisheng</groupId>
<artifactId>activemq</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>activemq</name>
<description>Demo project for Spring Boot ActiveMQ</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.9.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

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

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

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

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

2、配置文件 application.properties

1
2
3
spring.activemq.broker-url=tcp://localhost:61616
spring.activemq.user=admin
spring.activemq.password=admin

3、发送消息类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
package com.zhisheng.activemq.client;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;

@Component
public class ActiveMQClient {

@Autowired
private JmsTemplate jmsTemplate;

public void send(String message) {
jmsTemplate.convertAndSend("zhisheng", message);
}
}

同样,和 RabbitMQ 类似,不多说了。

4、消息接收类

1
2
3
4
5
6
7
8
9
10
11
12
package com.zhisheng.activemq.server;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class ActiveMQServer {
@JmsListener(destination = "zhisheng")
public void receive(String message) {
System.out.println("收到的 message 是:" + message);
}
}

5、注意

这个队列是不需要我们提前定义好的,它和 RabbitMQ 不一样,它会在我们需要的时候动态的创建。

运行

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package com.zhisheng.activemq;

import com.zhisheng.activemq.client.ActiveMQClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.util.StopWatch;

import javax.annotation.PostConstruct;

@SpringBootApplication
public class ActivemqApplication {

@Autowired
ActiveMQClient client;

@PostConstruct
public void init() {
StopWatch stopWatch = new StopWatch();
stopWatch.start();
for (int i = 0; i < 10000; i++) {
client.send("发送消息----zhisheng-----");
}
stopWatch.stop();
System.out.println("发送消息耗时: " + stopWatch.getTotalTimeMillis());
}

public static void main(String[] args) {
SpringApplication.run(ActivemqApplication.class, args);
}
}

发送一万条消息运行后需要的时间挺久的:73180 ms

Snip20180124_4

比 RabbitMQ 发送 10000 条消息耗时 215 ms 不知道高出多少倍了,可见其性能并不高的。

关注我

mark

最后

转载请务必注明原创地址为:http://www.54tianzhisheng.cn/2018/01/27/SpringBoot-ActiveMQ/

×

纯属好玩

扫码支持
扫码打赏,你说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

文章目录
  1. 1. 介绍 ActiveMQ
  2. 2. 相关文章
  3. 3. 安装 ActiveMQ
  4. 4. 整合
  5. 5. 运行
  6. 6. 关注我
  7. 7. 最后