- RabbitMQ的交换器类型？Exchange Types常用的类型有fanout、direct、topic、headers四种fanout广播消息路由规则：它会把所有发送到该路由（Exchange）的消息到所有与它绑定的队列（Queue）,无需做任何判断，fanout类型是速度最快的。direct完全匹配路由规则：他会根据发送到路由时设置的路由键（RoutingKey）以及路由与队列绑定的... RabbitMQ的交换器类型？Exchange Types常用的类型有fanout、direct、topic、headers四种fanout广播消息路由规则：它会把所有发送到该路由（Exchange）的消息到所有与它绑定的队列（Queue）,无需做任何判断，fanout类型是速度最快的。direct完全匹配路由规则：他会根据发送到路由时设置的路由键（RoutingKey）以及路由与队列绑定的...
- 本文介绍了如何基于SpringAMQP实现消息队列。Spring AMQP是Spring框架对AMQP（高级消息队列协议）的支持，提供了在分布式系统中进行消息传递的强大机制。它构建在RabbitMQ之上，并提供了一种灵活且易于使用的方式，用于在微服务架构中进行异步通信和消息传递。 本文介绍了如何基于SpringAMQP实现消息队列。Spring AMQP是Spring框架对AMQP（高级消息队列协议）的支持，提供了在分布式系统中进行消息传递的强大机制。它构建在RabbitMQ之上，并提供了一种灵活且易于使用的方式，用于在微服务架构中进行异步通信和消息传递。
- 本文详细介绍了在Spring Cloud框架中集成RabbitMQ消息队列的步骤。首先，通过添加必要的依赖，配置RabbitMQ连接信息。接着，创建消息生产者和消费者，利用Spring Cloud Stream简化消息绑定过程。生产者负责发送消息到RabbitMQ队列，而消费者通过监听队列接收并处理消息。通过这种异步通信机制，实现了分布式系统中微服务之间的松耦合，提高了系统的可伸缩性和可维护性。 本文详细介绍了在Spring Cloud框架中集成RabbitMQ消息队列的步骤。首先，通过添加必要的依赖，配置RabbitMQ连接信息。接着，创建消息生产者和消费者，利用Spring Cloud Stream简化消息绑定过程。生产者负责发送消息到RabbitMQ队列，而消费者通过监听队列接收并处理消息。通过这种异步通信机制，实现了分布式系统中微服务之间的松耦合，提高了系统的可伸缩性和可维护性。
- 本文深入介绍了RabbitMQ消息模型，涵盖了基本消息队列、工作消息队列、广播、路由和主题等五种常见消息模型。每种模型都具有独特的特点和适用场景，为开发者提供了灵活而强大的消息传递工具。通过这些模型，RabbitMQ实现了解耦、异步通信以及高效的消息路由，为分布式系统的开发和部署提供了可靠的基础。 本文深入介绍了RabbitMQ消息模型，涵盖了基本消息队列、工作消息队列、广播、路由和主题等五种常见消息模型。每种模型都具有独特的特点和适用场景，为开发者提供了灵活而强大的消息传递工具。通过这些模型，RabbitMQ实现了解耦、异步通信以及高效的消息路由，为分布式系统的开发和部署提供了可靠的基础。
- 本文介绍了在 Windows 环境下安装 RabbitMQ 及其依赖的 Erlang 语言的过程。通过提供下载链接和详细的安装步骤，使读者能够快速搭建 RabbitMQ 开发环境。同时，展示了常用的命令和验证方法，确保安装正确完成。这为搭建 RabbitMQ 服务奠定了基础。 本文介绍了在 Windows 环境下安装 RabbitMQ 及其依赖的 Erlang 语言的过程。通过提供下载链接和详细的安装步骤，使读者能够快速搭建 RabbitMQ 开发环境。同时，展示了常用的命令和验证方法，确保安装正确完成。这为搭建 RabbitMQ 服务奠定了基础。
- 新建服务器流程使用xshell登录服务器下载宝塔安装稳定版的宝塔5.9Centos安装脚本yum install -y wget && wget -O install.sh http://download.bt.cn/install/install.sh && sh install.shUbuntu/Deepin安装脚本wget -O install.sh http://download.b... 新建服务器流程使用xshell登录服务器下载宝塔安装稳定版的宝塔5.9Centos安装脚本yum install -y wget && wget -O install.sh http://download.bt.cn/install/install.sh && sh install.shUbuntu/Deepin安装脚本wget -O install.sh http://download.b...
- 前面一文通过Java整合RabbitMQ实现生产消费（7种通讯方式），本文基于SpringBoot实现RabbitMQ中的死信队列和延迟队列。 概念介绍 什么是死信死信可以理解成没有被正常消费的消息，在RabbitMQ中以下几种情况会被认定为死信：消费者使用basic.reject或basic.nack（重新排队参数设置为false）对消息进行否定确认。消息到达生存时间还未被消费。队列超过长... 前面一文通过Java整合RabbitMQ实现生产消费（7种通讯方式），本文基于SpringBoot实现RabbitMQ中的死信队列和延迟队列。 概念介绍 什么是死信死信可以理解成没有被正常消费的消息，在RabbitMQ中以下几种情况会被认定为死信：消费者使用basic.reject或basic.nack（重新排队参数设置为false）对消息进行否定确认。消息到达生存时间还未被消费。队列超过长...
- 可靠性分析RabbitMQ如何保证消息的可靠？如RabbitMQ基础概念中的架构模型可以看到一条消息的传递过程：发布者和RabbitMQ建立连接发送消息至交换机。交换机和队列绑定，将消息路由到队列中。消费者和RabbitMQ建立连接指定某个队列的消息进行消费。在这过程中以下几个环节可能会丢失消息：发布者到交换机环节。交换机到队列环节。队列到消费者环节。如下图 可靠性方案所以要保证消息的可靠... 可靠性分析RabbitMQ如何保证消息的可靠？如RabbitMQ基础概念中的架构模型可以看到一条消息的传递过程：发布者和RabbitMQ建立连接发送消息至交换机。交换机和队列绑定，将消息路由到队列中。消费者和RabbitMQ建立连接指定某个队列的消息进行消费。在这过程中以下几个环节可能会丢失消息：发布者到交换机环节。交换机到队列环节。队列到消费者环节。如下图 可靠性方案所以要保证消息的可靠...
- @[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）：可以为消费者设置一个死信队列，当消息超时时，将消息转发到死信队列中。然后可以根据需要对死...
上滑加载中
推荐直播
-
走进数据库：数据库基础知识精讲2024/12/27 周五 16:00-17:30
Steven 华为云学堂技术讲师
数据管理是数据库的核心任务，本期直播将带领大家一起走进数据库，了解期发展趋势、基础模型、架构演进及相关的技术特点。同时还会介绍数据库对象和相关概念，帮助开发者对数据库使用和实践夯实基础。
回顾中 -
手把手教你在 CodeArts 上部署敏捷流水线2024/12/31 周二 16:30-18:00
Jerry 华为云生态技术讲师
CodeArts的适用场景以及如何从CodeArts Pipeline出发，一步步添加关联工具，最后让整个流水线流动起来，一起来动手试试吧。
即将直播
热门标签