小白快速入门消息中间件

Posted 2021-10-04 哪吒

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了小白快速入门消息中间件相关的知识，希望对你有一定的参考价值。

🍅 Java学习路线：搬砖工逆袭Java架构师

🍅 简介：Java领域优质创作者🏆、CSDN哪吒公众号作者✌ 、Java架构师奋斗者

🍅 扫描主页左侧二维码，一起学习、一起进步

🍅 欢迎点赞 👍 收藏 ⭐留言 📝

一、学习中间件的方式和技巧

理解中间件在项目架构中的作用，以及各中间件的底层实现
可以使用一些类比的生活概念去理解中间件
使用一些主流图或者脑图的方式去梳理各个中间件在架构中的作用
尝试使用Java技术去实现中间件
静下来去思考中间件在项目中设计和使用的原因
如何找到对应的替代方案
尝试编写博客总结类同中间件技术的对比和使用场景
学会查看中间件的源码以及开源项目和博客

二、消息中间件的应用场景

跨系统数据传递
高并发的流量削峰
数据的分发和异步处理
大数据分析与传递
分布式事务

比如你有一个数据需要进行迁移或者请求并发过多的时候，比如你有10W的并发请求订单，我们可以在这些订单入库之前，把订单请求堆积到消息队列中，让它稳健可靠的入库和执行。

消息中间件负责数据的传递、存储和分发，所以性能上要高于普通服务和技术。

三、消息中间件的核心组成部分

消息的协议
消息的持久化机制
消息的分发策略
消息的高可用，高可靠
消息的容错机制

四、网络协议的三要素

语法。语法是用户数据与控制信息的结构与格式以及数据出现的顺序。
语义。语义是解释控制信息每个部分的意义。它规定了需要发出何种控制信息以及完成的动作与做出什么样的响应。
时序。时序是对时间发生顺序的详细说明。

五、为什么消息中间件不直接使用http协议呢？

因为http请求报文头和响应报文头是比较复杂的，包含了cookie，数据的加密解密，状态码，响应码等附加的功能，但是对于一个消息而言，我们并不需要这么复杂，也没有这个必要性，它其实就是负责数据传递，存储，分发就行，一定要追求高性能，尽量简洁，快速。
大部分情况下http都是短连接，在实际的交互过程中，一个请求到响应很有可能会中断，中断以后就不会进行持久化，就会造成请求的丢失。这样就不利于消息中间件的业务场景，因为消息中间件可能是一个长期的获取消息的过程，出现问题和故障要对数据或消息进行持久化，目的是为了保证消息和数据的高可靠性和稳健的运行。

六、AMQP协议

AMQP：全称Advanced Message Queuing Protocol，是高级消息队列协议。由摩根大通集团联合其他公司设计，是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息中间件设计，基于此协议的客户端和消息中间件可传递消息，并不受客户端或中间件或不同的开发条件的限制。

特性：

分布式事务支持
消息的持久化支持
高性能和高可靠的消息处理优势

七、消息的分发策略

1、MQ消息队列有如下几个角色

生产者
存储消息
消费者

在发送消息的过程中可能出现异常，或者网络抖动，故障等等原因，从而造成消息无法消费，比如用户下订单，消费MQ接受，订单系统出现故障，导致用户支付失败，那么这个时候就需要消息中间件支持消息重试机制策略。也就是支持：出现问题和故障的情况下，消息不丢失还可以进行重发。

2、消息分发策略的机制和对比

	ActiveMQ	RabbitMQ	Kafka	RocketMQ
发布订阅	支持	支持	支持	支持
轮询分发	支持	支持	支持	/
公平分发	/	支持	支持	/
重发	支持	支持	/	支持
消息拉取	/	支持	支持	支持