Rabbit MQ消息队列原理(4)

简介: Rabbit MQ消息队列原理(4)

七,RabbitMQ收到 消费端的的ACK,如何让生产者知道,如何确保一致性呢?

1,调用生产者API,修改数据库中表的状态,只要API没被调用,数据状态没有被修改,则认为下游系统没有收到这条消息


2,发送相应消息给生产者


如果生产者的API没有被调用,也没有收到消费者的响应消息,如何处理?

建立补偿机制


后台代码中创建定时任务,


如30s跑一次,找到业务表里面的这条业务状态是中间状态的记录,查询出来,构建为MQ消息,重新发送。


发送时间可以衰减,1分钟,10分钟,60分钟,


重发消息要控制次数:比如设置成3次


重复发送一模一样的消息


八,如何避免出现重复消息?


image.png


九,rabbitMQ节点类型与集群


image.png


我们一般把应用连接诶到内存节点(读写快),磁盘节点用来备份。


集群的配置步骤:

1,配置Hosts以便互相通信

2,同步erlang.cookie

3,加入集群(join cluster命令)

Rabbit有两种集群模式:普通集群模式和镜像队列模式。


1,普通集群模式下,不同的节点之间只会互相同步元数据(交换机,队列,绑定关系,Vhost的定义),而不会同步消息


image.png


image.png


同理,如果消费者连接的是节点2,要从队列1上拉取消息,消息会从节点1抓饭到节点2,。其它节点起到了一个路由的作用,类似于指针。


2,镜像集群模式


image.png


image.png



相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
9天前
|
消息中间件 存储 网络协议
手写消息队列(基于RabbitMQ)
手写消息队列(基于RabbitMQ)
|
15天前
|
消息中间件 数据采集 Serverless
云消息队列 RocketMQ 版-消息集成-概述
消息集成是助力企业数字化转型的全栈式消息与数据集成平台,简化流程,支持云上云下、跨区域集成。它提供低代码的事件流服务,具备数据源集成、数据清洗、Serverless自定义处理等功能,支持丰富的数据源和跨端连接。然而,使用时存在如单个任务数据限制、任务名称长度等约束。消息流入(Source)负责从各种数据源获取数据,消息流出(Sink)将数据分发到目标,数据处理(Transform)允许数据转换和分析,而任务(Task)则结合这些组件执行实际的集成操作。
31 3
|
22天前
|
消息中间件 存储 运维
为什么选择云消息队列 RocketMQ 版
为什么选择云消息队列 RocketMQ 版
23 1
|
22天前
|
消息中间件 存储 运维
深入理解MQ消息队列的高可用与可靠性策略
深入理解MQ消息队列的高可用与可靠性策略
1011 3
|
22天前
|
消息中间件 存储 传感器
Kafka消息队列原理及应用详解
【5月更文挑战第6天】Apache Kafka是高性能的分布式消息队列,常用于实时数据管道和流应用。它提供高性能、持久化、分布式和可伸缩的消息处理,支持解耦、异步通信和流量控制。Kafka的核心概念包括Broker、Topic、Partition、Producer、Consumer和Consumer Group。其特点是高吞吐、低延迟、数据持久化、分布式架构和容错性。常见应用包括实时数据流处理、日志收集、消息传递和系统间数据交换。
|
22天前
|
消息中间件 大数据 Java
消息队列 MQ
消息队列 MQ
41 3
|
22天前
|
消息中间件 存储 监控
RabbitMQ:分布式系统中的高效消息队列
RabbitMQ:分布式系统中的高效消息队列
|
22天前
|
消息中间件 分布式计算 监控
Python面试:消息队列(RabbitMQ、Kafka)基础知识与应用
【4月更文挑战第18天】本文探讨了Python面试中RabbitMQ与Kafka的常见问题和易错点,包括两者的基础概念、特性对比、Python客户端使用、消息队列应用场景及消息可靠性保证。重点讲解了消息丢失与重复的避免策略,并提供了实战代码示例,帮助读者提升在分布式系统中使用消息队列的能力。
48 2
|
22天前
|
消息中间件 Java
springboot整合消息队列——RabbitMQ
springboot整合消息队列——RabbitMQ
88 0
|
22天前
|
消息中间件 JSON Java
RabbitMQ消息队列
RabbitMQ消息队列
48 0

热门文章

最新文章

相关产品

  • 云消息队列 MQ