SpringBoot ActiveMQ 整合使用

介绍 ActiveMQ

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

安装 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 连接
  • CTIVEMQADMINLOGIN :登陆控制台的用户名
  • ACTIVEMQADMINPASSWORD :登陆控制台的密码

执行后,可在浏览器输入 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:61616spring.activemq.user=adminspring.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;@Componentpublic 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;@Componentpublic 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;@SpringBootApplicationpublic 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 不知道高出多少倍了,可见其性能并不高的。

本文分享自微信公众号 - zhisheng(zhisheng_blog)

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2018-01-31

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏用户2442861的专栏

Thrift交流(一)简单的Thrift

http://blog.csdn.net/arjick/article/details/13293073

12010
来自专栏Java3y

Druid数据库连接池就是这么简单

前言 本章节主要讲解Druid数据库连接池,为什么要学Druid数据库连接池呢?? 我的知识储备数据库连接池有两种->C3P0,DBCP,可是现在看起来并不够用...

608110
来自专栏安富莱嵌入式技术分享

【RL-TCPnet网络教程】第9章 RL-TCPnet网络协议栈移植(uCOS-III)

本章教程为大家讲解RL-TCPnet网络协议栈的uCOS-III操作系统移植方式,学习了第6章讲解的底层驱动接口函数之后,移植就比较容易了,主要是添加库文件、配...

12430

使用NGINX反向代理部署Spring Boot应用

Spring Boot通过大量的默认配置,让使用Spring框架进行开发变得方便快捷,从而使得Java开发人员专注于程序原型设计。本文介绍如何创建一个简单的Sp...

1.4K30
来自专栏一个会写诗的程序员的博客

《Spring Boot极简教程》第8章 Spring Boot集成Groovy,Grails开发第8章 Spring Boot集成Groovy,Grails开发小结参考资料

本章介绍Spring Boot集成Groovy,Grails开发。我们将开发一个极简版的pms(项目管理系统)。

21220
来自专栏大数据互联网思维

SpringCloud学习2-Springboot监控模块+

学习一项新技术最大的困难是什么? 是资料。让人高兴的是找到了一本系统学习Spring Cloud的教程,《Spring Cloud微服务实战》, 接下来的学习目...

13700
来自专栏乐沙弥的世界

[INS-20802] Oracle Net Configuration Assistant failed

        [INS-20802] Oracle Net Configuration Assistant failed。在安装Oracle 11g R2时出...

50640
来自专栏Ryan Miao

gradle中使用嵌入式(embedded) tomcat, debug 启动

在gradle项目中使用embedded tomcat。 最开始部署项目需要手动将web项目打成war包,然后手动上传到tomcat的webapp下,然后启动t...

58090
来自专栏JadePeng的技术博客

jenkins X实践系列(2) —— 基于jx的DevOps实践

jx是云原生CICD,devops的一个最佳实践之一,目前在快速的发展成熟中。最近调研了JX,这里为第2篇,使用已经安装好的jx来实践CICD,旨在让大家了解基...

79220
来自专栏杨建荣的学习笔记

Oracle 12.2中的一个参数说明(r12笔记第76天)

之前花了些时间做了Oracle 10g,11g,12c参数的差别,其中有一个参数很有意思,在不同版本代表的含义还有所差别。就是sec_case_sens...

32380

扫码关注云+社区

领取腾讯云代金券