二、RabbitMQ的特点
=============
1、被设计为一个通用的消息代理服务，支持点对点、请求-回复、发布-订阅等模式。
2、专注于消息的一致性、可靠性和稳定性。
3、对Java、.net、node.js、PHP等多语言有着非常好的支持，并且有丰富的插件来提供功能扩展，没有做不到只有想不到。
4、支持同步或异步消息通信，支持分布式部署和多节点集群部署，能提供2万/秒的消息分发能力，性能上不敌kafka。
三、RabbitMQ的相关概念
===============
通常我们谈到队列服务，会有三个概念：发消息者、队列、收消息者，RabbitMQ在这个基本概念之上，多做了一层抽象，在发消息者和队列之间加入了交换器exchange，这样发消息者和队列就没有直接联系，转而编程发消息者把消息给交换器，交换器根据调度策略再把消息给队列。
黄色的圈圈就是我们的消息推送服务，将消息推送到中间方框里面，也就是RabbitMQ服务器，然后经过服务器里面的交换机、队列等各种关系将数据处理入列，最终右边的蓝色圈圈消费者获取对应监听的消息。
那么，其中比较重要的概念就有四个，分别是：虚拟主机、交换机、队列和绑定。
虚拟主机：一个虚拟主机持有一组交换机、队列和绑定。为什么需要多个虚拟主机呢？很简单， RabbitMQ 当中，用户只能在虚拟主机的粒度进行权限控制。因此，如果需要禁止A组访问B组的交换机、队列、绑定，必须为A和B分别创建一个虚拟主机、每一个 RabbitMQ 服务器都有一个默认的虚拟主机“/”。 交换机：Exchange用于转发消息，但是它不会做存储，如果没有queue bind到Exchange的话，它会直接丢掉Producer发送过来的消息。这里有一个比较重要的概念：路由键。消息到交换机的时候，交换机转发到对应的队列中，那么究竟转发到哪个队列，就要根据该路由键。 绑定：也就是交换机需要和队列相绑定，这其中如上图所示，是多对多的关系。
交换机（Exchange）
交换机的功能主要是接收消息并转发到绑定的队列，交换机不存储消息，在启用ack模式后，交换机找不到队列会返回错误。交换机有四种类型：Direct 、Topic、Headers、Fanout
Direct ：direct类型的行为是“先匹配再投送”，即在绑定时设定一个routing_key，消息的routing_key匹配时，才会被交换机投送到绑定的队列中去。 Topic：按规则转发消息（最灵活） Headers：设置header attribute参数类型的交换机（基本不用） Fanout：转发消息到所有绑定队列
1、Direct Exchange是RabbitMQ默认的交换机模型，也是最简单的模型，根据key全文匹配去寻找队列。
第一个 X - Q1 就有一个 binding key，名字为 orange； X - Q2 就有 2 个 binding key，名字为 black 和 green。当消息中的 路由键 和 这个 binding key 对应上的时候，那么就知道了该消息去到哪一个队列中。
Ps：为什么 X 到 Q2 要有 black，green，2个 binding key呢，一个不就行了吗？ - 这个主要是因为可能又有 Q3，而Q3只接受 black 的信息，而Q2不仅接受black 的信息，还接受 green 的信息。
2、Topic Exchange
Topic Exchange转发消息主要是根据通配符。在这种交换机下，队列和交换机的绑定会定义一种路由模式，那么，通配符就要在这种路由模式和路由键之间匹配后交换机才能转发消息。
在这种交换机模式下：
（1）路由键必须是一串字符，用句号隔开，比如说agreements.us，或者agreements.eu.stockholm等。
（2）路由模式必须包含一个星号（*），主要用于匹配路由键指定位置的一个单词，比如说，一个路由模式是这样的： agreements…b.*， 那么就只能匹配路由键是这样子的：第一个单词是agreements，第四个单词是b。井号就表示相当于一个或多个单词，例如一个匹配模式是 agreements.eu.berlin.#，那么，以agreements.eu.berlin 开头的路由键都是可以的。
具体代码发送的时候还是一样，第一个参数表示交换机，第二个参数表示routing key，第三个参数即消息。如下：
rabbitTemplate.convertAndSend(“testTopicExchange”,“key1.a.c.key2”, " this is RabbitMQ!");
topic 和 direct 类似, 只是匹配上支持了”模式”, 在”点分”的 routing_key 形式中, 可以使用两个通配符:
*表示一个词
#表示零个或多个词
3、Header Exchange
headers 也是根据规则匹配, 相较于 direct 和 topic 固定地使用 routing_key , headers 则是一个自定义匹配规则的类型. 在队列与交换器绑定时, 会设定一组键值对规则, 消息中也包括一组键值对( headers 属性), 当这些键值对有一对, 或全部匹配时, 消息被投送到对应队列。
4、 Fanout Exchange
Fanout Exchange 消息广播的模式，不管路由键或者是路由模式，会把消息发给绑定给它的全部队列，如果配置了routing_key会被忽略。
四、rabbitmq有哪些重要组件？
==================
1、ConnectionFactory(连接管理器)
应用程序与RabbitMQ之间建立连接的管理器。
2、Channel(信道)
消息推送使用的通道。
3、RoutingKey(路由键)
用于把生产者的数据分配到交换器上。
4、Exchange(交换器)
用于接受、分配消息。
5、BindKey(绑定键)
用于把交换器的消息绑定到队列上
6、Queue(队列)
用于存储生产者的消息。
五、RabbitMQ的适用场景
===============
1、异步处理
场景说明：用户注册后，需要发送注册邮件和注册短信。
传统的做法有两种，①串行的方式；②并行的方式；
（1）串行方式
将注册信息写入数据库后，发送注册邮件，再发送注册短信，以上三个动作顺序完成后才返回给客户端。
这种方式的问题是发送注册邮件和发送注册短信不是必须的，它只是一个通知，而这种做法让客户端等待没有必要等待的东西，影响用户体验。
（2）并行方式
将注册信息写入数据库后，发送邮件的同时，发送短信，以上三种操作都完成后，返回给客户端，并行的方式能缩短处理的时间。
假设三种业务节点分别使用50ms，串行方式就是150ms，并行方式就是100ms。
虽然并行已经缩短了处理时间，但是前面说过，邮件和短信不是必须的，没有必要让客户等待响应，应该是写入数据库就直接返回。
（3） 消息队列RabbitMQ
引入消息队列后，用户的响应时间就等于写入数据库的时间+写入消息队列的时间（可以忽略不计），引入消息队列后，响应时间大幅度缩减。
2、应用解耦
（1）场景
双11是购物狂欢节，用户下单后，订单系统需要通知库存系统，传统的做法就是订单系统调用库存系统接口。
（2）缺点
由于订单系统和库存系统的高耦合，当库存系统出现故障时，订单就会失败。
（3）引入消息队列RabbitMQ
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录大纲截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且后续会持续更新
如果你觉得这些内容对你有帮助，可以添加V获取：vip1024b （备注Java）
感受：
其实我投简历的时候，都不太敢投递阿里。因为在阿里一面前已经过了字节的三次面试，投阿里的简历一直没被捞，所以以为简历就挂了。
特别感谢一面的面试官捞了我，给了我机会，同时也认可我的努力和态度。对比我的面经和其他大佬的面经，自己真的是运气好。别人8成实力，我可能8成运气。所以对我而言，我要继续加倍努力，弥补自己技术上的不足，以及与科班大佬们基础上的差距。希望自己能继续保持学习的热情，继续努力走下去。
也祝愿各位同学，都能找到自己心动的offer。
分享我在这次面试前所做的准备（刷题复习资料以及一些大佬们的学习笔记和学习路线），都已经整理成了电子文档
一个人可以走的很快，但一群人才能走的更远。如果你从事以下工作或对以下感兴趣，欢迎戳这里加入程序员的圈子，让我们一起学习成长！
AI人工智能、Android移动开发、AIGC大模型、C C#、Go语言、Java、Linux运维、云计算、MySQL、PMP、网络安全、Python爬虫、UE5、UI设计、Unity3D、Web前端开发、产品经理、车载开发、大数据、鸿蒙、计算机网络、嵌入式物联网、软件测试、数据结构与算法、音视频开发、Flutter、IOS开发、PHP开发、.NET、安卓逆向、云计算
rhsmRM-1712316307311)]
一个人可以走的很快，但一群人才能走的更远。如果你从事以下工作或对以下感兴趣，欢迎戳这里加入程序员的圈子，让我们一起学习成长！
AI人工智能、Android移动开发、AIGC大模型、C C#、Go语言、Java、Linux运维、云计算、MySQL、PMP、网络安全、Python爬虫、UE5、UI设计、Unity3D、Web前端开发、产品经理、车载开发、大数据、鸿蒙、计算机网络、嵌入式物联网、软件测试、数据结构与算法、音视频开发、Flutter、IOS开发、PHP开发、.NET、安卓逆向、云计算
参考文章
发表评论