- @[TOC] 环境说明操作系统：CentOS7Erlang版本：21.3RabbitMQ版本：3.8.0 Erlang安装 下载安装包参考链接：https://packagecloud.io/rabbitmq/erlang。精简的包，只提供运行RabbitMQ所需的组件。选择对应版本进入下载页面复制下图中的wget地址执行下载命令wget --content-disposition http... @[TOC] 环境说明操作系统：CentOS7Erlang版本：21.3RabbitMQ版本：3.8.0 Erlang安装 下载安装包参考链接：https://packagecloud.io/rabbitmq/erlang。精简的包，只提供运行RabbitMQ所需的组件。选择对应版本进入下载页面复制下图中的wget地址执行下载命令wget --content-disposition http...
- 前言1.消息属性RabbitMQ是基于AMQP消息传输协议来实现的消息中间件；类似HTTP有header和body两部分数据，Message是RabbitMQ中的消息体概念。Message由Properties和Body组成，前者是一些元信息，如消息的优先级、持久化、传输格式（如JSON）、延迟等高级特性，Body则是传递的消息数据实体2.消息投递Exchange、Queue与Routin... 前言1.消息属性RabbitMQ是基于AMQP消息传输协议来实现的消息中间件；类似HTTP有header和body两部分数据，Message是RabbitMQ中的消息体概念。Message由Properties和Body组成，前者是一些元信息，如消息的优先级、持久化、传输格式（如JSON）、延迟等高级特性，Body则是传递的消息数据实体2.消息投递Exchange、Queue与Routin...
- 目录基本介绍概述 为什么需要引进RabbitMQ延迟队列应用场景 springboot代码实战实战架构工程概述RabbitConfigDeal 配置类：创建队列及交换机并进行绑定 MessageService业务类：发送消息及接收消息主启动类RabbitMq01Application：实现ApplicationRunner接口基本介绍概述延时队列，首先，它是一种队列，队列意味着内部的元素... 目录基本介绍概述 为什么需要引进RabbitMQ延迟队列应用场景 springboot代码实战实战架构工程概述RabbitConfigDeal 配置类：创建队列及交换机并进行绑定 MessageService业务类：发送消息及接收消息主启动类RabbitMq01Application：实现ApplicationRunner接口基本介绍概述延时队列，首先，它是一种队列，队列意味着内部的元素...
- 目录 基本介绍springboot代码演示 演示架构工程概述RabbitConfig配置类：创建队列及交换机并进行绑定MessageService业务类：发送消息及接收消息主启动类RabbitMq01Application：实现ApplicationRunner接口基本介绍在rabbitmq中，生产者发信息不会直接将信息投递到队列中，而是先将信息投递到交换机中，在交换机转发在具体的队列，... 目录 基本介绍springboot代码演示 演示架构工程概述RabbitConfig配置类：创建队列及交换机并进行绑定MessageService业务类：发送消息及接收消息主启动类RabbitMq01Application：实现ApplicationRunner接口基本介绍在rabbitmq中，生产者发信息不会直接将信息投递到队列中，而是先将信息投递到交换机中，在交换机转发在具体的队列，...
- 前言我们在上次讨论RabbitMQ的消息可靠性时，已经提到了死信队列（详见系列文章《RabbitMQ 能保证消息可靠性吗》），死信概念是RabbitMQ的重要特性，官网也有该特性的介绍，那么这种设计有什么用，我们又该怎么使用死信呢？一起开始本次的学习吧一、死信与AMQP死信是指由于某些原因无法被正常投递到目标地址的邮件或消息，而在MQ的语义下，就是无法被消费的mq消息。从AMQP的规范原文中... 前言我们在上次讨论RabbitMQ的消息可靠性时，已经提到了死信队列（详见系列文章《RabbitMQ 能保证消息可靠性吗》），死信概念是RabbitMQ的重要特性，官网也有该特性的介绍，那么这种设计有什么用，我们又该怎么使用死信呢？一起开始本次的学习吧一、死信与AMQP死信是指由于某些原因无法被正常投递到目标地址的邮件或消息，而在MQ的语义下，就是无法被消费的mq消息。从AMQP的规范原文中...
- RabbitMQ图文快速入门 RabbitMQ图文快速入门
- 在RabbitMQ中，如果消息在指定的时间内没有被消费者消费，就会发生消息超时。 处理消息超时的方法有以下几种：设置消息的过期时间：在发送消息时，可以为消息设置一个过期时间。如果消息在指定时间内没有被消费者消费，就会被标记为过期，然后可以进行相应的处理。使用死信队列（Dead Letter Queue）：可以为消费者设置一个死信队列，当消息超时时，将消息转发到死信队列中。然后可以根据需要对死... 在RabbitMQ中，如果消息在指定的时间内没有被消费者消费，就会发生消息超时。 处理消息超时的方法有以下几种：设置消息的过期时间：在发送消息时，可以为消息设置一个过期时间。如果消息在指定时间内没有被消费者消费，就会被标记为过期，然后可以进行相应的处理。使用死信队列（Dead Letter Queue）：可以为消费者设置一个死信队列，当消息超时时，将消息转发到死信队列中。然后可以根据需要对死...
- 在RabbitMQ中，可以通过以下几种方式来保证消息不丢失：持久化消息：在发送消息时，将消息的delivery_mode设置为2，表示将消息持久化到磁盘上。这样即使RabbitMQ服务器重启，消息也不会丢失。消息确认机制：在消费者端，可以开启消息确认机制，确保消息被正确处理。消费者可以通过channel.basicAck(deliveryTag, multiple)方法发送确... 在RabbitMQ中，可以通过以下几种方式来保证消息不丢失：持久化消息：在发送消息时，将消息的delivery_mode设置为2，表示将消息持久化到磁盘上。这样即使RabbitMQ服务器重启，消息也不会丢失。消息确认机制：在消费者端，可以开启消息确认机制，确保消息被正确处理。消费者可以通过channel.basicAck(deliveryTag, multiple)方法发送确...
- 补偿机制是指在消息队列中，当某个消息处理失败时，可以通过一些手段进行补偿，尝试重新处理该消息，直到处理成功为止。 在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插件，然后解压放置到...
上滑加载中
推荐直播
-
HDC深度解读系列 - Serverless与MCP融合创新，构建AI应用全新智能中枢2025/08/20 周三 16:30-18:00
张昆鹏 HCDG北京核心组代表
HDC2025期间，华为云展示了Serverless与MCP融合创新的解决方案，本期访谈直播，由华为云开发者专家(HCDE)兼华为云开发者社区组织HCDG北京核心组代表张鹏先生主持，华为云PaaS服务产品部 Serverless总监Ewen为大家深度解读华为云Serverless与MCP如何融合构建AI应用全新智能中枢
回顾中 -
苏州工业园区“华为云杯”2025人工智能应用创新大赛赛中直播2025/08/21 周四 16:00-17:00
Vz 华为云AIoT技术布道师
本期直播将与您一起探讨如何基于华为云IoT平台全场景云服务，结合AI、鸿蒙、大数据等技术，打造有创新性，有竞争力的方案和产品。
即将直播
热门标签