简单大体说明RabbitMQ的使用（简单版）

灰太狼 2023-09-23 21:48 137阅读 0赞

1.  # MQ中为什么选择RabbitMQ #

批量消费消息： prefetch 批量取 concurrency 并发数量

时效性最高： TTL（time to live）一条消息在队列中的最大存活时间，可以丢弃，或者发送到死信队列中去进行进一步的处理

死信队列：消息被拒绝，消息过期，队列达到最大长度

延迟队列 = TTL + 延时时间

优点：

并发量并不需要很大，QPS万级

管理界面完善

社区活跃

功能比较全

缺点：

并发量不够大

1.  # RabbitMQ的使用场景 #

异步 削峰填谷 解耦

## 2.1 RabbitMQ的发送消息方式 ##

direct

fanout

topic

# 3. RabbitMQ常见的问题 #

3.1 rabbitMQ 实现机制，了解吗，为什么这么快？

\-采用AMQP协议，通过channel信道进行数据的交互，是建立在tcp连接中的虚拟连接，这样可以减少创建，销毁带来的性能损耗

\-（官方）通道协议对于多线程来说是安全的，进入通道的请求是序列化的，每次只有一个线程能够在通道上运行命令，倾向于每一个线程使用一个channel，而不是多个线程共享一个channel。所以Consumer在处理消息的时候是单线程的，解决方案：将消息转发给业务线程池处理

\-对于消费者来说一个线程对应一个channel

\-缓存channel池的方案

3.2 rabbit mq 多个消费者A、多个生产者B；如果我A发送消息给消费者，需要告诉B停止处理消息，该怎么做？

\-待定

3.3 不丢消息：

\-生产者采用confirm模

\-MQ进行持久化：交换机持久化 队列持久化 消息持久化

\-消费者采用ack模式

3.4 顺序消费:

\-将同一个订单或者编号的消息hash到同一个队列，用一个消费者去消费

如果消费者端用多线程消费，就没办法保证顺序性了吗？

3.5 重复消费：

\-数据库的唯一索引

\-将id缓存到redis中，消费的时候先查

3.6 消息堆积怎么处理：

\--是系统架构问题，就要考虑增大消费者的数量

\--定位找出具体的原因，可能是代码bug，或者性能优化问题

3.7 生产环境上RabbitMQ阻塞了怎么处理

\-[生产RabbitMQ队列阻塞该如何处理？ - 知乎 (zhihu.com)][RabbitMQ_ - _ _zhihu.com]

3.8 MQ挂了怎么办

\-镜像集群模式，创建的queue的元数据和消息实体都会同步到多个实例的queue里

\-HA mode同步方式

\--all：镜像同步到集群队列的所有节点

\--exactly ：按个数同步到集群中的一个或者多个节点

\--nodes ：具体的节点名称

镜像中的Master挂了之后，最老的mirror会被提升为新的master，但是如果这个mirror跟旧的Master并未完成数据的同步，那么就会出现数据的丢失。

rabbitMq提供了ha-promote-on-shutdown（正常关闭），ha-promote-on-failure（异常关闭）俩个参数让用户决策是保证队列的可用性还是数据的一致性。when-synced意味着只有当mirror与master完成数据同步了，才会提升为新的master；always表示，无论什么情况下最老的mirror都会被提升为新的master

3.9 消费者消费模式：

\-推push模式

一般使用channel.basicConsume方式，如果生存者产生的消息量超过了消费者能承受的量，就会撑爆消费者，可以通过channel.basicQos（500）来限流，前提是建立了channel，prefench参数的设置

\-拉pull模式

一般使用basicGet（）方法，每次只能获取一条消息，不能批量（不推荐使用）

[RabbitMQ_ - _ _zhihu.com]: https://zhuanlan.zhihu.com/p/252722388

发表评论取消回复

表情：

评论列表（有 0 条评论，137人围观）

还没有评论，来说两句吧...

相关阅读

相关 git使用的简单说明

以下地址可以在你使用git时提供极大的帮助。 [https://git-scm.com/book/zh/v1][https_git-scm.com_book_zh_v1]

今天药忘吃喽~/ 2023年10月17日 16:42/ 0 赞/ 72 阅读

相关 RabbitMQ简单使用

1.安装： [win10安装RabbitMQ][win10_RabbitMQ] 2.使用 2.0 pom <dependency>

分手后的思念是犯贱/ 2023年10月05日 10:43/ 0 赞/ 69 阅读

相关简单大体说明RabbitMQ的使用（简单版）

1. MQ中为什么选择RabbitMQ 批量消费消息： prefetch 批量取 concurrency 并发数量时效性最高： TTL（time to live）一

灰太狼/ 2023年09月23日 21:48/ 0 赞/ 138 阅读

相关 TestFlight使用简单说明

一、开发者操作流程简单说明：１、注册一个账户；２、管理组成员：点击首页的Team按钮，开始进行成员管理； [![Screen shot 2011-05-18 at

谁践踏了优雅/ 2022年06月18日 11:13/ 0 赞/ 790 阅读

相关 rabbitMQ(二) java简单使用rabbitMQ

前言：在这里我将用java来简单的实现rabbitMQ。下面我们带着下面问题来一步步的了解和学习rabbitMQ。 1：如果消费者连接中断，这期间我们应该怎么办 2：如何做

亦凉/ 2022年06月02日 05:08/ 0 赞/ 323 阅读

相关 rabbitMQ的简单使用

文章目录 direct模式：直来直往，指哪到哪儿配置：生产者：消费者：

女爷i/ 2022年04月05日 14:14/ 0 赞/ 329 阅读

相关 git 简单使用说明

文章目录安装基本使用拉取代码提交代码到本地库推送代码到远程库分支基本操作查看分支

左手的ㄟ右手/ 2022年01月20日 14:53/ 0 赞/ 558 阅读

相关 Spring使用Rabbitmq (简单使用)

1、pom.xml jar包引用 ![ContractedBlock.gif][] ![ExpandedBlockStart.gif][] 1 <depende

我不是女神ヾ/ 2022年01月07日 08:11/ 0 赞/ 474 阅读

相关 TortoiseHg简单的入门使用说明

参考资料： [互普的 TortoiseHg使用说明\_百度文库][TortoiseHg] [Mercurial(Hg)基本操作 - Tim Gong - 博

不念不忘少年蓝@/ 2021年12月20日 03:41/ 0 赞/ 316 阅读

相关 rabbitMQ简单使用测试

1.连接rabbitMQ jar包: springboot整合rabbitMQ  <dependency>

Bertha 。/ 2021年11月09日 04:36/ 0 赞/ 486 阅读