SpringBoot ActiveMQ 整合使用

gaara 发布于2019-08-15 13:54 / 3053人阅读

摘要：介绍它是出品，最流行的，能力强劲的开源消息总线。是一个完全支持和规范的实现，尽管规范出台已经是很久的事情了，但是在当今的应用中间仍然扮演着特殊的地位。相关文章整合使用整合使用关注我转载请务必注明原创地址为安装同之前一样，直接在里面玩吧。

介绍 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 文件



    4.0.0

    com.zhisheng
    activemq
    0.0.1-SNAPSHOT
    jar

    activemq
    Demo project for Spring Boot ActiveMQ

    
        org.springframework.boot
        spring-boot-starter-parent
        1.5.9.RELEASE
         
    

    
        UTF-8
        UTF-8
        1.8
    

    
        
            org.springframework.boot
            spring-boot-starter-web
        

        
            org.springframework.boot
            spring-boot-starter-test
            test
        

        
            org.springframework.boot
            spring-boot-starter-activemq
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin

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 不知道高出多少倍了，可见其性能并不高的。

GPU云服务器云服务器 springboot整合webrtc springboot整合mongodb activeMQ? ActiveMQ

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/68392.html

SpringBoot ActiveMq JmsTemplate 异步发送、非持久化

摘要：异步发送不会在受到的确认之前一直阻塞方法。方法成功返回意味着所有的持久消息都以被写到二级存储中。总结默认情况，非持久化消息事务内的消息均采用异步发送对于持久化消息采用同步发送。 ActiveMq事务 ActiveMq事务的作用就是在发送、接收处理消息过程中，如果出现问题，可以回滚。 ActiveMq异步/同步发送以下摘抄自https://blog.csdn.net/songhai.....

AprilJ 2019-08-16 14:02 评论0 收藏0
SpringBoot RocketMQ 整合使用和监控

摘要：前提通过前面两篇文章可以简单的了解和安装，今天就将和整合起来使用。然后我运行之前的整合项目，查看监控信息如下总结整篇文章讲述了与整合和监控平台的搭建。 showImg(https://segmentfault.com/img/remote/1460000013232432?w=1920&h=1277); 前提通过前面两篇文章可以简单的了解 RocketMQ 和安装 RocketMQ...

Jacendfeng 2019-08-16 11:03 评论0 收藏0
写这么多系列博客，怪不得找不到女朋友

摘要：前提好几周没更新博客了，对不断支持我博客的童鞋们说声抱歉了。熟悉我的人都知道我写博客的时间比较早，而且坚持的时间也比较久，一直到现在也是一直保持着更新状态。 showImg(https://segmentfault.com/img/remote/1460000014076586?w=1920&h=1080); 前提好几周没更新博客了，对不断支持我博客的童鞋们说声：抱歉了！。自己这段时...

JerryWangSAP 2019-08-16 11:11 评论0 收藏0
JMS 在 SpringBoot 中的使用

摘要：本文主要讲述消息服务在中的使用。所以需要一个监听容器工厂的概念，即接口，它会引用上面创建好的与的连接工厂，由它来负责接收消息以及将消息分发给指定的监听器。为了消费消息，订阅者必须保持运行的状态。 JMS 在 SpringBoot 中的使用摘要：本文属于原创，欢迎转载，转载请保留出处：https://github.com/jasonGeng88/blog> 本文所有服务均采用doc...

Michael_Ding 2019-08-14 18:43 评论0 收藏0
限时订单实现方案（DelayQueue、ActiveMq）

摘要：一在各种电商网站下订单后会保留一个时间段，时间段内未支付则自动将订单状态设置为已过期。并修改这些数据的状态为已过期。因此以上方式实际开发中基本不予采用。时间到期了才会发送这条消息到消息队列中。一、在各种电商网站下订单后会保留一个时间段，时间段内未支付则自动将订单状态设置为已过期。(原文链接 ) showImg(https://segmentfault.com/img/bVbv9BX?...

hosition 2019-08-19 10:24 评论0 收藏0