SpringBoot ActiveMQ 整合使用
2018-01-31 22:08
661 查看
介绍 ActiveMQ
它是 Apache 出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持 JMS1.1 和 J2EE 1.4 规范的 JMS Provider 实现,尽管 JMS 规范出台已经是很久的事情了,但是 JMS 在当今的J2EE应用中间仍然扮演着特殊的地位。—— 摘自百度百科,偷了个懒。相关文章
1、SpringBoot Kafka 整合使用2、SpringBoot RabbitMQ 整合使用
关注我
转载请务必注明原创地址为:http://www.54tianzhisheng.cn/2018/01/27/SpringBoot-ActiveMQ/
安装 ActiveMQ
同之前一样,直接在 Docker 里面玩吧。命令也是一行解决: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/ 查看控制台,
解释下上面图片中控制台这些按钮的基本信息:
Home:查看 ActiveMQ 的常见信息
Queues:查看 ActiveMQ 的队列信息
Topics:查看 ActiveMQ 的主题信息
Subscribers:查看主题的订阅者信息
Connections:查看 ActiveMQ 客户端的连接信息
Network:查看 ActiveMQ 的网络信息
Scheduled:查看 ActiveMQ 的定时任务
Send:用于通过表单方式向队列或者主题发送具体的消息
整合
IDEA 创建 SpringBoot 项目,因为 SpringBoot 已经内置了对 ActiveMQ 的支持,所以直接引入依赖spring-boot-starter-activemq就行。整体项目结构如下:
1、pom.xml 文件
<?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
spring.activemq.broker-url=tcp://localhost:61616 spring.activemq.user=admin spring.activemq.password=admin
3、发送消息类
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、消息接收类
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 不一样,它会在我们需要的时候动态的创建。
运行
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
比 RabbitMQ 发送 10000 条消息耗时 215 ms 不知道高出多少倍了,可见其性能并不高的。
相关文章推荐
- 学习activemq(2)Spring boot整合activemq jms
- Activemq API使用(不整合spring)
- Activemq API使用(整合spring)
- spring-boot集成activeMQ(二)-使用ActiveMQ Server
- SpringBoot RocketMQ 整合使用和监控
- SpringBoot RocketMQ 整合使用和监控
- spring boot整合activemq rabbitmq
- Spring Cloud Edgware新特性之九:Sleuth使用MQ方式整合Zipkin
- springboot-10-前端页面整合, thymeleaf, freemarker, jsp 模板使用
- Spring ActiveMQ整合+注解消息监听
- Spring ActiveMQ整合实例
- SpringBoot整合Spring Data JPA、MySQL、Druid并使用Mockito实现单元测试
- spring整合activemq发送MQ消息[Topic模式]实例,activemqmq
- 学习cassandra(1)入门,使用场景(写多读少)和搭建启动使用,整合Spring boot
- Spring Boot轻易使用MQ
- spring activeMQ 整合(二): 重发机制(消息发送失败后的重新发送)
- 使用myeclipse搭建SpringBoot框架,整合thymeleaf模板和mybatis
- SpringBoot学习:整合shiro(身份认证和权限认证),使用EhCache缓存
- activemq spring整合 以及虚拟主题设置
- spring boot与fastdfs的整合使用