PPTMQ.pptx 比较内容 Kafka RabbitMQ  定位 设计定位 系统间的数据流管道，实时数据处理 用于实时的，对可靠性要求较高的消息传递上 　 例如：常规的消息系统、网站活 例如：订单，交易，充值，流计 性跟踪，监控数据 基础对比 成熟度 成熟:日志领域成熟 成熟 所属社区／公司  Apache Mozilla Public License 社区活跃度  高  高 API完备性  高  高 文档完备性  高  高 开发语言 Sc

RabbitMQ 延迟队列-非常非常实用 一、使用场景 ​ 目前常见的应用软件都有消息的延迟推送的影子，应用也极为广泛，例如： ​ 淘宝七天自动确认收货，自动评价功能等。在我们签收商品后，物流系统会在七天后延时发送一个消息给支付系统，通知支付系统将款打给商家，这个过程持续七天，就是使用了消息中间件的延迟推送功能；相应的，自动评价也是类似的。 ​ 12306 购票支付确认页面。我们在选好票点击确定跳转的页面中往往都会有倒计时，代表着 30 分钟内订单不确认的话将会自动取消订单。

版本对应关系 https://www.rabbitmq.com/which-erlang.html docker 启动 rabbitmq docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin imageid 有两个版本的mq安装包和对应的erlang安装包，任选其一 链接：https://pan.ba

136.rabbitmq 的使用场景有哪些？ MQ是一个互联网架构中常见的解耦利器。 什么时候不使用MQ？ 上游实时关注执行结果   什么时候使用MQ？ 1）数据驱动的任务依赖 2）上游不关心多下游执行结果 3）异步返回执行时间长 136.rabbitmq 有哪些重要的角色？ 生产者：消息的创建者，负责创建和推送数据到消息服务器 消费者：消息的接收方，用于处理数据和确认消息 代理：就是RabbitMQ本身，用于扮演快递的角色，本身并不生产消息 137.rabbi

搭建环境：springBoot + maven + RabbitMQ 3.8.14 + Erlang 23.2.7 注意：安装时rabbitMq和erlang版本号必须对应，以免引起不必要的bug。 1、应用场景 应用解耦：当要调用远程系统时候，当存在订单系统和库存系统时，订单系统下单，库存系统需要收到订单后库存减一，这时候如果系统宕机，会造成订单丢失，吧订单消息发入mq，库存系统再去mq消费，就能解决这一问题。 异步消费：传统的模式：用户下单—>邮件发送—>短信提醒，三

一、为什么使用消息队列 1.使用同步的通信方式来解决多个服务之间的通信 同步的通信方式会存在性能和稳定性的问题 2.使用异步的通信方式 针对于同步的通信方式来说，异步的方式，可以让上游快速成功，极大提高了系统的吞吐量，而且在分布式系统中，通过下游服务多个服务的分布式事务的保障，也能保障业务执行之后的最终一致性。 二、什么是消息队列 三、消息队列的流派 目前消息队列中间件选型有很多种 rabbitMQ rocketMQ：阿里内部的一个大神，根据kafka内部原理手写的一个消

RabbitMQ工作原理 RabbitMQ图形化界面 点击add创建队列 D:代表持久态队列，随着rabbitmq服务的重启或宕机，队列依然存在，消息也会得到持久化 点击创建的队列queue1 overview：队列的基本运行状况 consumer:消费者 bindings：绑定交换机和队列的关系，默认绑定默认交换机 publish messages：往队列发送消息 get messages：获取消息，nack 消息预览；ack消息消费后应答，队列会移除消息 move

原文网址：RabbitMQ--消息堆积/消息积压--解决方案_IT利刃出鞘的博客-CSDN博客 简介         本文介绍如何处理RabbitMQ消息堆积。         对于消息队列（MQ）来说，消息丢失/消息重复/消费顺序/消息堆积是比较常见的问题，都属于消息异常，这几个问题比较重要，面试中也会经常问到。 消息堆积原因 消息堆积即消息没及时被消费，是生产者生产消息速度快于消费者消费的速度导致的。 消费者消费慢可能是因为：本身逻辑耗费时间较长、阻塞了。 预防措施 生产者

RabbitMQ 1 啥是MQ MQ（message queue），按词组解释的意思就是消息队列 MQ是在消息的传输过程中保存消息的容器 队列遵循FIFO也就是先入先出规则（先进来的水先出去） 它是典型的：生产者、消费者模型 消息的生产和消费都是异步的 MQ是一种跨进程的通讯机制，用于上下游系统传递消息 RabbitMQ使用AMQP（高级消息队列协议Advanced Message Queuing Protocol） MQ是一种对上下游系统“逻辑解偶+物理解偶”的消息通讯服务

RabbitMQ是最流行的开源消息队列系统，实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。 RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。采用该技术，我们可以实现异步处理、流量削峰、系统解耦； RabbitMQ概念与机制 RabbitMQ中的概念模型: Broker:消息中间件实例,可能是单个节点也可能是运行在多节点集群上的逻辑实体 消息(Message):

一、Linux部署RabbitMQ （一）环境 1.rabbitmq1：192.168.163.128 [root@rabbitmq1 ~]# hostnamectl set-hostname client 2.rabbitmq2：192.168.163.132 [root@rabbitmq2 ~]# hostnamectl set-hostname haproxy 3.rabbitmq3：192.168.163.135 [root@rabbitmq3~]#  ho

我：这里不太熟悉诶。让我想一下：假设A和B通过消息队列通信，A发了2条消息m1和m2，这两条消息有依赖关系，必须先消费m1再消费m2。结果m2先到达，m1后到达。那么B可能先接收到m2，后接收到m1，这个时候应该怎么办？ 首先，B接收到消息的顺序跟A发出的顺序以及队列中的顺序没有关系。消息到达队列的先后顺序没法保证，队列将消息投递出去以后接收消息的顺序也没法保证。所以，消费者B必须保证业务的正确性，无论生产者怎么发消息，队列怎么投递消息，消费者都必须意识到：接收到的消息是无序的，必须做好处