- 补偿机制是指在消息队列中，当某个消息处理失败时，可以通过一些手段进行补偿，尝试重新处理该消息，直到处理成功为止。 在RabbitMQ中，可以通过以下方式实现补偿机制：重试机制：当消息处理失败时，可以将该消息重新发送到队列中，供消费者再次处理。可以通过设置消息的属性，如消息的过期时间、消息的优先级等，来控制重新发送的时间和顺序。延时队列：当消息处理失败时，可以将该消息发送到延时队列中，延时队... 补偿机制是指在消息队列中，当某个消息处理失败时，可以通过一些手段进行补偿，尝试重新处理该消息，直到处理成功为止。 在RabbitMQ中，可以通过以下方式实现补偿机制：重试机制：当消息处理失败时，可以将该消息重新发送到队列中，供消费者再次处理。可以通过设置消息的属性，如消息的过期时间、消息的优先级等，来控制重新发送的时间和顺序。延时队列：当消息处理失败时，可以将该消息发送到延时队列中，延时队...
- RabbitMQ是一个开源的消息中间件，它提供了可靠的消息传递机制。当消息发送到RabbitMQ时，可能会出现一些问题，例如网络故障、消费者不可用等，导致消息无法成功发送或消费。为了解决这些问题，RabbitMQ提供了重试机制。 重试机制是指在消息发送或消费过程中，当出现错误或失败时，RabbitMQ会自动尝试重新发送或消费消息，直到达到一定的重试次数或达到一定的时间限制。下面是Rabbit... RabbitMQ是一个开源的消息中间件，它提供了可靠的消息传递机制。当消息发送到RabbitMQ时，可能会出现一些问题，例如网络故障、消费者不可用等，导致消息无法成功发送或消费。为了解决这些问题，RabbitMQ提供了重试机制。 重试机制是指在消息发送或消费过程中，当出现错误或失败时，RabbitMQ会自动尝试重新发送或消费消息，直到达到一定的重试次数或达到一定的时间限制。下面是Rabbit...
- RabbitMQ手动ACK与死信队列 RabbitMQ手动ACK与死信队列
- RabbitMQ发送方确认机制 RabbitMQ发送方确认机制
- 2023-07-08：RabbitMQ如何做到消息不丢失？答案2023-07-08：1.持久化发送消息时设置delivery_mode属性为2，使消息被持久化保存到磁盘，即使RabbitMQ服务器宕机也能保证消息不丢失。同时，创建队列时设置durable属性为True，以确保队列也被持久化保存。2.确认机制消费者通过basic.ack命令向RabbitMQ服务器确认已经消费了消息。如果消费者... 2023-07-08：RabbitMQ如何做到消息不丢失？答案2023-07-08：1.持久化发送消息时设置delivery_mode属性为2，使消息被持久化保存到磁盘，即使RabbitMQ服务器宕机也能保证消息不丢失。同时，创建队列时设置durable属性为True，以确保队列也被持久化保存。2.确认机制消费者通过basic.ack命令向RabbitMQ服务器确认已经消费了消息。如果消费者...
- 2023-07-06：RabbitMQ中的AMQP是什么？答案2023-07-06： AMQPAMQP（Advanced Message Queuing Protocol）是一个应用层协议的开放标准，旨在设计面向消息的中间件。基于AMQP协议的客户端和消息中间件可以自由地传递消息，不受客户端、中间件产品或开发语言的限制。其目标是实现一种被广泛应用于各行业的标准消息中间件技术，以降低企业和系统... 2023-07-06：RabbitMQ中的AMQP是什么？答案2023-07-06： AMQPAMQP（Advanced Message Queuing Protocol）是一个应用层协议的开放标准，旨在设计面向消息的中间件。基于AMQP协议的客户端和消息中间件可以自由地传递消息，不受客户端、中间件产品或开发语言的限制。其目标是实现一种被广泛应用于各行业的标准消息中间件技术，以降低企业和系统...
- 原因：RabbitMQ只会检查第一个消息是否过期，如果过期则丢到死信队列，如果第一个消息的延时时长很长，而第二个消息的延时时长很短，第二个消息并不会优先得到执行。操作前需要安装延时队列插件 在官网上下载https://www.rabbitmq.com/community-plugins.html，下载rabbitmq_delayed_message_exchange插件，然后解压放置到... 原因：RabbitMQ只会检查第一个消息是否过期，如果过期则丢到死信队列，如果第一个消息的延时时长很长，而第二个消息的延时时长很短，第二个消息并不会优先得到执行。操作前需要安装延时队列插件 在官网上下载https://www.rabbitmq.com/community-plugins.html，下载rabbitmq_delayed_message_exchange插件，然后解压放置到...
- @toc 1、RabbitMQ的概念 RabbitMQ 是一个消息中间件：它接受并转发消息。你可以把它当做一个快递站点，当你要发送一个包裹时，你把你的包裹放到快递站，快递员最终会把你的快递送到收件人那里，按照这种逻辑 RabbitMQ 是一个快递站，一个快递员帮你传递快件。RabbitMQ 与快递站的主要区别在于，它不处理快件而是接收， 存储和转发消息数据。 2、四大核心概念 2.1 生产... @toc 1、RabbitMQ的概念 RabbitMQ 是一个消息中间件：它接受并转发消息。你可以把它当做一个快递站点，当你要发送一个包裹时，你把你的包裹放到快递站，快递员最终会把你的快递送到收件人那里，按照这种逻辑 RabbitMQ 是一个快递站，一个快递员帮你传递快件。RabbitMQ 与快递站的主要区别在于，它不处理快件而是接收， 存储和转发消息数据。 2、四大核心概念 2.1 生产...
- @toc 1、前言 这里将编写两个java程序。发送单个消息的生产者和接收消并打印出来的消费者。 在下图中，p是我们的生产者，c是我们的消费者。中间框是一个队列-RabbitMQ代表使用者保留的消息缓冲区。 2、简单消息发送与接收实战 2.1 引入依赖<build> <plugins> <plugin> <groupId>org.apache.m... @toc 1、前言 这里将编写两个java程序。发送单个消息的生产者和接收消并打印出来的消费者。 在下图中，p是我们的生产者，c是我们的消费者。中间框是一个队列-RabbitMQ代表使用者保留的消息缓冲区。 2、简单消息发送与接收实战 2.1 引入依赖<build> <plugins> <plugin> <groupId>org.apache.m...
- @[toc](Work Queues) 工作队列简介 工作队列(又称任务队列)的主要思想是避免立即执行资源密集型任务，而不得不等待它完成。相反我们安排任务在之后执行。我们把任务封装为消息并将其发送到队列。在后台运行的工作进=程将弹出任务并最终执行作业。当有多个工作线程时，这些工作线程将一起处理这些任务。 1、轮询发送消息这里我们会启动两个工作线程，一个消息发送线程，我们看看这两个工作线程是... @[toc](Work Queues) 工作队列简介 工作队列(又称任务队列)的主要思想是避免立即执行资源密集型任务，而不得不等待它完成。相反我们安排任务在之后执行。我们把任务封装为消息并将其发送到队列。在后台运行的工作进=程将弹出任务并最终执行作业。当有多个工作线程时，这些工作线程将一起处理这些任务。 1、轮询发送消息这里我们会启动两个工作线程，一个消息发送线程，我们看看这两个工作线程是...
- @toc 1、发布确认原理 生产者将信道设置成 confirm 模式，一旦信道进入 confirm 模式，所有在该信道上面发布的消息都将会被指派一个唯一的 ID(从 1 开始)，一旦消息被投递到所有匹配的队列之后，broker就会发送一个确认给生产者(包含消息的唯一 ID)，这就使得生产者知道消息已经正确到达目的队列了，如果消息和队列是可持久化的，那么确认消息会在将消息写入磁盘之后发出，b... @toc 1、发布确认原理 生产者将信道设置成 confirm 模式，一旦信道进入 confirm 模式，所有在该信道上面发布的消息都将会被指派一个唯一的 ID(从 1 开始)，一旦消息被投递到所有匹配的队列之后，broker就会发送一个确认给生产者(包含消息的唯一 ID)，这就使得生产者知道消息已经正确到达目的队列了，如果消息和队列是可持久化的，那么确认消息会在将消息写入磁盘之后发出，b...
- @toc 引言 在生产环境中由于一些不明原因，导致 rabbitmq 重启，在 RabbitMQ 重启期间生产者消息投递失败， 导致消息丢失，需要手动处理和恢复。于是，我们开始思考，如何才能进行 RabbitMQ 的消息可靠投递呢？ 特别是在这样比较极端的情况，RabbitMQ 集群不可用的时候，无法投递的消息该如何处理呢: 1、发布确认(SpringBoot版本) 1.1 代码架构图 1... @toc 引言 在生产环境中由于一些不明原因，导致 rabbitmq 重启，在 RabbitMQ 重启期间生产者消息投递失败， 导致消息丢失，需要手动处理和恢复。于是，我们开始思考，如何才能进行 RabbitMQ 的消息可靠投递呢？ 特别是在这样比较极端的情况，RabbitMQ 集群不可用的时候，无法投递的消息该如何处理呢: 1、发布确认(SpringBoot版本) 1.1 代码架构图 1...
- @toc 1、备份交换机 有了 mandatory 参数和回退消息，我们获得了对无法投递消息的感知能力，有机会在生产者的消息 无法被投递时发现并处理。但有时候，我们并不知道该如何处理这些无法路由的消息，最多打个日志，然 后触发报警，再来手动处理。而通过日志来处理这些无法路由的消息是很不优雅的做法，特别是当生产者 所在的服务有多台机器的时候，手动复制日志会更加麻烦而且容易出错。而且设置 ma... @toc 1、备份交换机 有了 mandatory 参数和回退消息，我们获得了对无法投递消息的感知能力，有机会在生产者的消息 无法被投递时发现并处理。但有时候，我们并不知道该如何处理这些无法路由的消息，最多打个日志，然 后触发报警，再来手动处理。而通过日志来处理这些无法路由的消息是很不优雅的做法，特别是当生产者 所在的服务有多台机器的时候，手动复制日志会更加麻烦而且容易出错。而且设置 ma...
- @toc RabbitMQ集群 1、Clustering 1.1 使用集群的原因 最开始我们介绍了如何安装及运行 RabbitMQ 服务，不过这些是单机版的，无法满足目前真实应用的 要求。如果 RabbitMQ 服务器遇到内存崩溃、机器掉电或者主板故障等情况，该怎么办？单台 RabbitMQ 服务器可以满足每秒 1000 条消息的吞吐量，那么如果应用需要 RabbitMQ 服务满足每秒 ... @toc RabbitMQ集群 1、Clustering 1.1 使用集群的原因 最开始我们介绍了如何安装及运行 RabbitMQ 服务，不过这些是单机版的，无法满足目前真实应用的 要求。如果 RabbitMQ 服务器遇到内存崩溃、机器掉电或者主板故障等情况，该怎么办？单台 RabbitMQ 服务器可以满足每秒 1000 条消息的吞吐量，那么如果应用需要 RabbitMQ 服务满足每秒 ...
- RabbitMQ Windows 安装、配置、使用 - 小白教程 RabbitMQ Windows 安装、配置、使用 - 小白教程
上滑加载中
推荐直播
-
华为AI技术发展与挑战：集成需求分析的实战指南2024/11/26 周二 18:20-20:20
Alex 华为云学堂技术讲师
本期直播将综合讨论华为AI技术的发展现状，技术挑战，并深入探讨华为AI应用开发过程中的需求分析过程，从理论到实践帮助开发者快速掌握华为AI应用集成需求的框架和方法。
去报名 -
华为云DataArts+DWS助力企业数据治理一站式解决方案及应用实践2024/11/27 周三 16:30-18:00
Walter.chi 华为云数据治理DTSE技术布道师
想知道数据治理项目中，数据主题域如何合理划分？数据标准及主数据标准如何制定？数仓分层模型如何合理规划？华为云DataArts+DWS助力企业数据治理项目一站式解决方案和应用实践告诉您答案！本期将从数据趋势、数据治理方案、数据治理规划及落地，案例分享四个方面来助力企业数据治理项目合理咨询规划及顺利实施。
去报名 -
大模型+知识库（RAG）：如何使能行业数智化？—华为行业数字化转型实践分享2024/11/27 周三 19:00-20:00
华为人工智能专家史老师
本次直播，我们特别邀请了华为人工智能专家史老师，将以大模型知识库为切入点，详细揭示大模型与知识库结合的过程，并分享利用大模型+知识库（RAG）使能行业数智化转型的实践经验。
即将直播
热门标签