Welcome to My Blog!
这里记录着我的java后端学习之路-
MQ保证消息不丢失
业务流程
“发送确认”模式：即生产者通过MQ发送消息后，MQ需要将“已发送成功/失败”反馈给生产者，告知生产者消息已投递成功，此方式可确保消息正确地发送至RabbitMQ
“消费确认”模式：即消费者监听到MQ中队列的消息并执行完对应的业务逻辑后，需要发送“消息已被成功监听、消费”反馈给MQ，此方式可保证接收方正确接收并消费了消息，消费成功后消息将从队列中移除
“避免消息重复投递”：生产者在生产消息时，MQ内部会针对每条消息生成一个MsgId，该标识可以作为去重的依据（消息投递失败并重传），避免重复的消息进入队列
“消息消费时保证幂等性”：这一点可以利用业务本身的特性来实现，即每个业务实体一般都会有一个唯一的ID，就像数据库表中唯一的主键一样，在监听消费处理时根据ID作为去重的依据
“持久化”：将队列、交换机、消息都设置为持久化模式，确保消息在投递、发送期间出现MQ服务宕机后重启恢复过来时消息依旧存在
“消息消费重试机制”：指的是消费者在监听、消费、处理消息的过程中出现了异常，导致业务逻辑没有处理成功，此时可以开启“消息重入队列”机制，设置消息重入队列N次 进行 重试消费
“消息投递补偿机制”：指的是消息在生产、投递期间出现“投递失败”，也就是“发送不成功”的情况，此时可以将其加入到DB中，并开启定时任务，拉取那些投递不成功的消息，重新投递入队列，如此一来便可以保证消息不丢失且准备被投递
流程图
-
rabbitMQ
简介
为什么选择？
- 开源，性能优秀，稳定性保障
- 提供可靠性消息投递模式（confirm），返回模式（return）
- 与SpringAMQP完美整合，API丰富
- 集群模式丰富，表达式配置，HA模式，镜像队列模型
- 保证数据不丢失的前提做到高可靠性，可用性
- Erlang语言最初应用于交换机领域的架构模式，这样使得RabbitMQ在Broker之间进行数据交互的性能是非常优秀的
- Erlang的特点：Erlang有着和原生Socket一样的延迟
AMQP
- 高级消息队列协议（Advanced Message Queuing Protocol）
- AMQP定义：是具有现代特征的二进制协议。是一个提供统一消息服务的应用层准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。
- 核心概念：
- Server：又称Broker，接收客户端的连接，实现AMQP实体服务
- Connection：连接，应用程序与Broker的网络连接
- Channel：网络信道，几乎所有的操作都在Channel中进行，Channel是进行消息读写的通道。客户端可建立多个Channel，每个Channel代表一个会话任务
- Message：消息，服务器和应用程序之间传送的数据，由Properties和Body组成。Properties可以对消息进行修饰，比如消息的优先级，延迟等高级特性；Body就是消息体内容
- Virtual host：虚拟地址，用于进行逻辑隔离，最上层的消息路由。一个Virtual Host里面可以有若干个Exchange和Queue，同一个Virtual Host 里面不能有相同名称的Exchange或Queue。
- Exchange：交换机，接收消息，根据路由键转发消息到绑定的队列
- Binding：Exchange和Queue之间的虚拟连接，binding中可以包含routing key
- Routing key：一个路由规则，虚拟机可用它来确定如何路由一个特定消息
- Queue：也称为Message Queue，消息队列，保存消息并将它们转发给消费者
-
activeMQ
概述
MQ比较
特性 activeMQ RabbitMQ Kafka RocketMQ PRODUCER-CUMSUMER 支持 支持 支持 支持 PUBLISH-SUBSCRIBE 支持 支持 支持 支持 REQUEST-REPLY 支持 支持 支持 API完备性 高 高 高 低（静态配置） 多语言支持 支持java优先 语言无关 支持java优先 支持 单机吞吐量 万级 万级 十万级 单机万级 消息延迟 微秒级 毫秒级 可用性 高（主从） 高（主从） 非常高（分布式） 高 消息丢失 低 理论上不会丢失 消息重复 可控性 理论上会有重复 文档完备性 高 高 高 中 快速入门 有 有 有 无 部署难度 低 中 高 java，中小型项目 erlang语言，不好修改底层，不建议选用 编程语言Scala，大数据领域主流MQ java，适用于大型集群项目
Recent Posts
Categories
- 易经 4
- 中医 1
- java基础 11
- HTML与CSS 2
- JDBC+servlet+jsp+MVC 4
- Tomcat 1
- HTTP协议 1
- 过滤器和监听器 1
- maven 2
- 测试 1
- 日志 1
- mysql 11
- Linux 9
- 八股文 2
- 工具类 7
- RBAC 1
- LeetCode 1
- javaPOI 1
- 设计模式 2
- springBoot 6
- spring 14
- springMVC 4
- hibernate 5
- mybatis 7
- mybatisPlus 3
- struts2 7
- git 2
- 电商项目 1
- 算法 1
- springsecurity 1
- java8 3
- 并发 4
- 注解 1
- 数据库 1
- 鉴权 5
- Quartz 2
- elasticSearch 2
- 定时任务 1
- redis 6
- 网络编程 2
- Nginx 1
- MQ 3
- zookeeper 2
- 微服务 3
- 代码优化 6
- 事务 1
- MongoDB 2
- 雪花算法 1
- golang基础 4
- springcloud 4
- docker 1
- Python 2
- ai 1
Tags