ActiveMQ的作用总结(应用场景及优势)以及springboot+activeMq 实战

业务场景说明:

消息队列在大型电子商务类网站,如京东、淘宝、去哪儿等网站有着深入的应用,

队列的主要作用是消除高并发访问高峰,加快网站的响应速度。

在不使用消息队列的情况下,用户的请求数据直接写入数据库,在高并发的情况下,会对数据库造成巨大的压力,同时也使得系统响应延迟加剧。

在使用队列后,用户的请求发给队列后立即返回,

(例如: 当然不能直接给用户提示订单提交成功,京东上提示:您“您提交了订单,请等待系统确认”),

再由消息队列的消费者进程从消息队列中获取数据,异步写入数据库。

由于消息队列的服务处理速度远快于数据库,因此用户的响应延迟可得到有效改善。

图解说明:

1.   消息队列说明

消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题。

实现高性能,高可用,可伸缩和最终一致性架构。是大型分布式系统不可缺少的中间件。

目前在生产环境,使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ等。

2.    消息队列应用场景

消息队列在实际应用中常用的使用场景。异步处理,应用解耦,流量削锋和消息通讯四个场景。

2.1.     异步处理

场景说明:用户注册后,需要发注册邮件和注册短信。传统的做法有两种1.串行的方式;2.并行方式。

(1)串行方式:将注册信息写入数据库成功后,发送注册邮件,再发送注册短信。以上三个任务全部完成后,返回给客户端。

(2)并行方式:将注册信息写入数据库成功后,发送注册邮件的同时,发送注册短信。以上三个任务完成后,返回给客户端。与串行的差别是,并行的方式可以提高处理的时间。

假设三个业务节点每个使用50毫秒钟,不考虑网络等其他开销,则串行方式的时间是150毫秒,并行的时间可能是100毫秒。

因为CPU在单位时间内处理的请求数是一定的,假设CPU1秒内吞吐量是100次。

则串行方式1秒内CPU可处理的请求量是7次(1000/150)。并行方式处理的请求量是10次(1000/100)。

小结:如以上案例描述,传统的方式系统的性能(并发量,吞吐量,响应时间)会有瓶颈。如何解决这个问题呢?

引入消息队列,将不是必须的业务逻辑,异步处理。改造后的架构如下:

按照以上约定,用户的响应时间相当于是注册信息写入数据库的时间,也就是50毫秒。

注册邮件,发送短信写入消息队列后,直接返回,因此写入消息队列的速度很快,基本可以忽略,

因此用户的响应时间可能是50毫秒。所以基于此架构改变后,系统的吞吐量提高到每秒20 QPS。比串行提高了3倍,比并行提高了两倍。

2.2.    应用解耦

场景说明:用户下单后,订单系统需要通知库存系统。传统的做法是,订单系统调用库存系统的接口。如下图:

传统模式的缺点:

1)  假如库存系统无法访问,则订单减库存将失败,从而导致订单失败;

2)  订单系统与库存系统耦合;

如何解决以上问题呢?引入应用消息队列后的方案,如下图:

  • 1:订单系统:用户下单后,订单系统完成持久化处理,将消息写入消息队列,返回用户订单下单成功,请等待物流配送。
  • 2:库存系统:订阅下单的消息,采用拉/推的方式,获取下单信息,库存系统根据下单信息,进行库存操作。
  • 3:假如:在下单时库存系统不能正常使用。也不影响正常下单,
  • 因为下单后,订单系统写入消息队列就不再关心其他的后续操作了。实现订单系统与库存系统的应用解耦。

2.3.    流量削锋

流量削锋也是消息队列中的常用场景,一般在秒杀或团抢活动中使用广泛。

应用场景:秒杀活动,一般会因为流量过大,导致流量暴增,应用容易挂掉。为解决这个问题,一般需要在应用前端加入消息队列。

  1. 可以控制活动的人数.
  2. 可以缓解短时间内高流量压垮应用;

  1. 用户的请求,服务器接收后,首先写入消息队列。假如消息队列长度超过最大数量,则直接抛弃用户请求或跳转到错误页面;
  2. 秒杀业务根据消息队列中的请求信息,再做后续处理。

2.4.    消息通讯

消息通讯是指,消息队列一般都内置了高效的通信机制,因此也可以用在纯的消息通讯。比如实现点对点消息队列,或者聊天室等。

点对点通讯:

客户端A和客户端B使用同一队列,进行消息通讯。

聊天室通讯:

客户端A,客户端B,客户端N订阅同一主题,进行消息发布和接收。实现类似聊天室效果。

以上实际是消息队列的两种消息模式,点对点或发布订阅模式。

点对点和发布订阅的区别:

点对点与发布订阅最初是由JMS定义的。这两种模式主要区别或解决的问题就是发送到队列的消息能否重复消费(多订阅)

点对点: 
消息生产者生产消息发送到queue中,然后消息消费者从queue中取出并且消费消息。这里要注意: 
消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。 
Queue支持存在多个消费者,但是对一个消息而言,只会有一个消费者可以消费。 
发布/订阅 
消息生产者(发布)将消息发布到topic中,同时有多个消息消费者(订阅)消费该消息。和点对点方式不同,发布到topic的消息会被所有订阅者消费。

注:发布订阅模式适用于1个消息生产者,多个消费者场景,首先启动消息订阅方,在消息发布方开始执行后,接收该消息进行处理。在ActiveMQ管理界面会动态跟进消息产生-消费(入队、出队)情况;以及生产者个数,消费者个数

//项目实战

1.引入依赖

<!-- 整合消息队列ActiveMQ -->      <dependency>              <groupId>org.springframework.boot</groupId>              <artifactId>spring-boot-starter-activemq</artifactId>          </dependency>        <!-- 如果配置线程池则加入 -->        <dependency>              <groupId>org.apache.activemq</groupId>              <artifactId>activemq-pool</artifactId>          </dependency>

2.启动类加上

@SpringBootApplication //一个注解顶下面3个@EnableJms //可加可不加,建议加上public class XdclassApplication {

public static void main(String[] args) {      SpringApplication.run(XdclassApplication.class, args);   }}3.注入activeMq的对象(省的每一次使用都new ,以后再使用直接去spring容器中拿就行了@Autowired)
@Componentpublic class CreatBean {        //消息队列的pub_sub模式    @Bean    public Topic topic() {        return new ActiveMQTopic("video.topic");    }    //消息队列的点对点模式    @Bean    public Queue queue() {        return new ActiveMQQueue("common.queue");    }    //自定义同时开启pub_sub和点对点模式,因为activeMQ 默认只支持一种模式    @Bean    public JmsListenerContainerFactory<?> jmsListenerContainerTopic(ConnectionFactory activeMQConnectionFactory) {        DefaultJmsListenerContainerFactory bean = new DefaultJmsListenerContainerFactory();        bean.setPubSubDomain(true);        bean.setConnectionFactory(activeMQConnectionFactory);        return bean;    }}4.配置文件
#整合jms测试,安装在别的机器,防火墙和端口号记得开放spring.activemq.broker-url=tcp://XX.XX.XX.XX:61616

#集群配置#spring.activemq.broker-url=failover:(tcp://localhost:61616,tcp://localhost:61617)

spring.activemq.user=adminspring.activemq.password=admin#下列配置要增加依赖(activeMq连接池)spring.activemq.pool.enabled=truespring.activemq.pool.max-connections=100

#activeMq 默认是支持点对点模式的,开启下面第二行注释就支持 pub_sub模式了,但是又不支持点对点了,要想两个模式都支持#注释下面的代码,看第二步中的自定义jms工厂#default point to point# spring.jms.pub-sub-domain=true
4.生产者代码a.service
@Servicepublic class ProducerServiceImpl implements ProducerService{

@Autowired   private JmsMessagingTemplate jmsTemplate; //用来发送消息到broker的对象

//发送消息,destination是发送到的队列,message是待发送的消息   @Override   public void sendMessage(Destination destination, String message) {      System.out.println("OrderConsumer发送的报文为:123");      jmsTemplate.convertAndSend(destination, message);

}

//发送消息,destination是发送到的队列,message是待发送的消息   @Override   public void sendMessage(final String message) {      jmsTemplate.convertAndSend( message);

}

//=======发布订阅相关代码=========

@Autowired   private Topic topic;

@Override   public void publish(String msg) {       System.out.println("pubsub 报文发送成功");      this.jmsTemplate.convertAndSend(this.topic, msg);

}

}
b.controller
@RestController@RequestMapping("/api/v1")public class OrderController {

@Autowired   private ProducerService producerService;

@Autowired   private Queue queue;   @GetMapping("order")   public Object order(String msg){      producerService.sendMessage(queue, msg);

return JsonData.buildSuccess();   }   @GetMapping("pabsub")   public Object pabsub(String msg){      producerService.publish(msg);      return JsonData.buildSuccess();   }}
6.消费者  点对点的消费者:
@Componentpublic class OrderConsumer {

@JmsListener(destination="common.queue")   public void receiveQueue(String text){      System.out.println("OrderConsumer收到的报文为OrderConsume:"+text);   }}pub_sub的消费者:
@Componentpublic class TopicSub {   @JmsListener(destination="video.topic", containerFactory="jmsListenerContainerTopic")   public void receive1(String text){      System.out.println("video.topic 消费者:receive1="+text);   }

@JmsListener(destination="video.topic", containerFactory="jmsListenerContainerTopic")   public void receive2(String text){      System.out.println("video.topic 消费者:receive2="+text);   }

 //containerFactory="jmsListenerContainerTopic"  这里要标明自定义的jms工厂
   @JmsListener(destination="video.topic", containerFactory="jmsListenerContainerTopic")   public void receive3(String text){      System.out.println("video.topic 消费者:receive3="+text);   }}
 

原文地址:https://www.cnblogs.com/xiaowangbangzhu/p/10329153.html

时间: 2024-11-07 18:48:05

ActiveMQ的作用总结(应用场景及优势)以及springboot+activeMq 实战的相关文章

消息中间件activemq的使用场景介绍(结合springboot的示例)

一.消息队列概述 消息队列中间件是分布式系统中重要的组件,主要解决应用耦合,异步消息,流量削锋等问题.实现高性能,高可用,可伸缩和最终一致性架构.是大型分布式系统不可缺少的中间件. 目前在生产环境,使用较多的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ等. 二.消息队列应用场景 以下介绍消息队列在实际应用中常用的使用场景.异步处理,应用解耦,流量削锋和消息通讯四个场景.本篇使用ActiveMQ+SpringBoot来模拟这四个场景. 2.

JAVAEE——宜立方商城09:Activemq整合spring的应用场景、添加商品同步索引库、商品详情页面动态展示与使用缓存

1. 学习计划 1.Activemq整合spring的应用场景 2.添加商品同步索引库 3.商品详情页面动态展示 4.展示详情页面使用缓存 2. Activemq整合spring 2.1. 使用方法 第一步:引用相关的jar包. <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jms</artifactId> </dependency> &l

Springboot activemq 对象传递

86. Spring Boot集成ActiveMQ[从零开始学Spring Boot] 博客分类: 从零开始学Spring Boot [视频&交流平台] àSpringBoot视频 http://study.163.com/course/introduction.htm?courseId=1004329008&utm_campaign=commission&utm_source=400000000155061&utm_medium=share à SpringCloud视频

Springboot+Activemq整合

Springboot+Activemq整合 1 导入整合所需要的依赖: <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId> </dependency> 2 创建 application.properties文件 spring.activemq.broker-url=t

ASP.NET Web网站中App_Code文件夹的作用及使用场景

原文地址:Web Site项目和ASP.NET Web Application中App_Code文件夹的作用作者:宾的宾 我现在要建一个ASP.NET的网站了,不难吧,开始动手.如下图: 这种方法建立Web Site项目,使用过的开发者都知道,如果需要新建一个类,例如DataBase.cs.此类只服务于web页面,不适于放入网站自身类库中,因此希望其独立存在于类库之外,只是用于在web应用程序中被web页面调用.这样一来此类最好不要通过形成dll文件,并将其放入bin文件夹以供web页面调用.但

数据库中索引的作用及运用场景

作用:提高数据的查询速度 第一,通过创建唯一性索引,可以保证数据库表中每一行数据的唯一性. 第二,可以大大加快 数据的检索速度,这也是创建索引的最主要的原因. 第三,可以加速表和表之间的连接,特别是在实现数据的参考完整性方面特别有意义. 第四,在使用分组和排序 子句进行数据检索时,同样可以显著减少查询中分组和排序的时间. 第五,通过使用索引,可以在查询的过程中,使用优化隐藏器,提高系统的性能. 常见的需要用到索引的情况: 1,在经常需要搜索的列上,可以加快搜索的速度: 2,在作为主键的列上,强制

Vuex的工作流程,以及它的作用,使用场景

vuex的工作流程: 1.在vue组件里面,通过dispatch来触发actions提交修改数据的操作. 2.然后再通过actions的commit来触发mutations来修改数据. 3.mutations接收到commit的请求,就会自动通过Mutate来修改state(数据中心里面的数据状态)里面的数据. 4.最后由store触发每一个调用它的组件的更新 Vuex的作用:项目数据状态的集中管理,复杂组件(如兄弟组件.远房亲戚组件)的数据通信问题. 原文地址:https://www.cnbl

docker入门-docker应用场景和优势

一.什么是docker Docker是一个使用 Go 语言开发的,并且开源的应用容器引擎,基于LXC(Linux Container)内核虚拟化技术实现,提供一系列更强的功能,比如镜像.Dockerfile等: Docker理念是将应用及依赖包打包到一个可移植的容器中,可发布到任意Linux发行版的Docker引擎上,使用沙箱机制运行程序,程序之间相互隔离: Docker采用C/S架构,Dcoker daemon作为服务端接受来自客户端请求,并处理这些请求,比如创建.运行容器等;客户端为用户提供

简述 gevent模块的作用和应用场景。

当一个greenlet遇到IO操作时,比如访问网络,就自动切换到其他的greenlet,等到IO操作完成, 再在适当的时候切换回来继续执行.由于IO操作非常耗时,经常使程序处于等待状态, 有了gevent为我们自动切换协程,就保证总有greenlet在运行,而不是等待IO. 由于切换是在IO操作时自动完成,所以gevent需要修改Python自带的一些标准库, 这一过程在启动时通过monkey patch完成: 原文地址:https://www.cnblogs.com/Rivend/p/1207