说下RabbitMQ的整体架构

RabbitMQ 是一个基于 AMQP(Advanced Message Queuing Protocol) 协议的开源消息中间件,RabbitMQ的整体架构围绕消息的生产、路由、存储和消费设计,旨在实现高效、可靠的消息传递,它由多个核心组件协同工作。

核心组件

1. 生产者(Producer)

  • 负责创建并向RabbitMQ服务器发送消息。消息可以包含任意数据(如 JSON、文本、二进制等。生产者不直接将消息发送到队列,而是通过交换机进行消息的路由。

2. 交换机(Exchange)

  • 接收生产者发送的消息,并根据路由规则将消息转发到一个或多个队列。交换机不存储消息,如果没有匹配的队列,消息可能会被丢弃(取决于具体配置)。交换机的类型决定路由行为
  • 类型
    • Direct Exchange精确匹配,根据消息的路由键(routing key)进行匹配。如果路由键与绑定队列时指定的键完全匹配,消息就会被发送到该队列。比如在一个物流系统中,根据订单的配送地区作为路由键,将订单消息发送到对应地区的处理队列。
    • Topic Exchange:支持通配符匹配的路由规则。使用 * 匹配一个单词,# 匹配零个或多个单词。比如在日志监控系统中,以系统名称(如 order.*user.#)作为路由规则,将不同的日志消息发送到相应的队列。
    • Fanout Exchange:将接收到的消息广播到所有与它绑定的队列,不考虑路由键。适用于广播消息的场景,如系统通知,所有订阅通知的队列都会收到消息。
    • Headers Exchange:根据消息的headers属性进行匹配,而不是路由键。这种类型相对较少使用。

3. 队列(Queue)

  • 存储消息的地方,消费者从队列中获取消息进行处理。队列是RabbitMQ中消息存储的基本单元,多个消费者可以从同一个队列中竞争获取消息。队列需与交换机通过 Binding Key 绑定,才能接收消息。
  • 队列可以设置持久化(服务器重启后队列依然存在)、排他性(仅创建它的连接可见且使用,连接关闭队列自动删除)、自动删除(当所有消费者断开连接后,队列自动删除)等属性。

4. 消费者(Consumer)

  • 从RabbitMQ服务器的队列中获取消息并进行处理。消费者可以订阅一个或多个队列,当队列中有新消息时,消费者会收到并处理。
  • 可以进行手动确认(ACK)或拒绝(NACK)消息,确保可靠性。

5. 消息代理(Broker)

  • 即RabbitMQ服务器本身,它负责接收生产者发送的消息根据交换机和绑定规则进行消息路由,并为消费者提供消息。Broker管理着交换机、队列、绑定等各种资源,并保证消息的可靠传递。
    • 集群模式:为了提高可靠性和性能,RabbitMQ可以组成集群。集群中的节点可以共享队列、交换机等资源,当某个节点出现故障时,其他节点可以继续提供服务。
    • 镜像队列:是一种特殊的队列集群方式,队列会在多个节点上进行镜像备份,确保即使某个节点故障,消息仍然可用。

辅助组件

1. 绑定(Binding)

  • 建立交换机和队列之间的关联关系。通过绑定,交换机知道应该将哪些消息发送到哪个队列。绑定可以指定一个路由键(在Direct和Topic交换机中),用于更精确的消息路由。

2. 连接与信道(Connection & Channel)

  • Connection:生产者/消费者与 Broker 之间的 TCP 连接。
  • Channel:复用连接中的逻辑通道,避免频繁创建 TCP 连接的开销。

3. 虚拟主机(Virtual Host)

  • Virtual Host 是 RabbitMQ 中的一个逻辑概念,类似于数据库中的“数据库实例”。每个虚拟主机都有自己独立的交换机、队列、绑定等资源,它们之间相互隔离。虚拟主机为多租户环境提供了支持,不同的应用或用户可以在各自的虚拟主机中进行消息传递,互不干扰。
  • 比如云服务提供商,可以为每个租户分配一个独立的虚拟主机,每个租户在自己的虚拟主机内管理自己的消息队列系统,不用担心与其他租户的资源冲突。
    在这里插入图片描述

架构特点

  1. 解耦生产与消费
    • 生产者无需知道消费者的存在,通过交换机和队列实现松耦合。
  2. 灵活的路由机制
    • 通过交换机类型和绑定规则支持多种消息分发模式(点对点、发布订阅等)。
  3. 可靠性保证
    • 支持消息持久化、手动确认(ACK)、死信队列(Dead Letter Queue)等机制。
  4. 扩展性
    • 支持集群部署、镜像队列(高可用)、负载均衡。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/80164.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

STM32--GPIO

教程 视频 博主教程 STM32系统结构图 GPIO GPIO(General Purpose Input/Output)是STM32内部的一种外设。 一个STM32芯片内存在多个GPIO外设,每个GPIO外设有16个引脚; 比如GPIOA:PA0~PA15; GPIOB:PB0~…

QUIC协议优化:HTTP_3环境下的超高速异步抓取方案

摘要 随着 QUIC 和 HTTP/3 的普及,基于 UDP 的连接复用与内置加密带来了远超 HTTP/2 的性能提升,可显著降低连接握手与拥塞恢复的开销。本文以爬取知乎热榜数据为目标,提出一种基于 HTTPX aioquic 的异步抓取方案,并结合代理 IP设…

[论文阅读]MCP Guardian: A Security-First Layer for Safeguarding MCP-Based AI System

MCP Guardian: A Security-First Layer for Safeguarding MCP-Based AI System http://arxiv.org/abs/2504.12757 推出了 MCP Guardian,这是一个框架,通过身份验证、速率限制、日志记录、跟踪和 Web 应用程序防火墙 (WAF) 扫描来…

Redis客户端缓存的4种实现方式

Redis作为当今最流行的内存数据库和缓存系统,被广泛应用于各类应用场景。然而,即使Redis本身性能卓越,在高并发场景下,应用与Redis服务器之间的网络通信仍可能成为性能瓶颈。 这时,客户端缓存技术便显得尤为重要。 客…

eNSP中路由器OSPF协议配置完整实验和命令解释

本实验使用三台华为路由器(R1、R2和R3)相连,配置OSPF协议实现网络互通。拓扑结构如下: 实验IP规划 R1: GE0/0/0: 192.168.12.1/24 (Area 0)Loopback0: 1.1.1.1/32 (Area 0) R2: GE0/0/0: 192.168.12.2/24 (Area 0)GE0/0/1: 192.…

内网渗透——红日靶场三

目录 一、前期准备 二、外网探测 1.使用nmap进行扫描 2.网站信息收集 3.漏洞复现(CVE-2021-23132) 4.disable_function绕过 5.反弹shell(也,并不是) 6.SSH登录 7.权限提升(脏牛漏洞) 8.信息收集 9.上线msf 三…

解决Win11下MySQL服务无法开机自启动问题

问题描述 在win11系统中,明明将MySQL服务设置成了自动启动,但在重启电脑后MySQL服务还是无法自动启动,每次都要重新到计算机管理的服务中找到服务再手动启动。 解决方式 首先确保mysql服务的启动类型为自动。 设置方法:找到此电…

后端项目进度汇报

项目概述 本项目致力于构建一个先进的智能任务自动化平台。其核心技术是一套由大型语言模型(LLM)驱动的后端系统。该系统能够模拟一个多角色协作的团队,通过一系列精心设计或动态生成的处理阶段,来高效完成各种复杂任务&#xff…

深度学习中学习率调整:提升食物图像分类模型性能的关键实践

深度学习中学习率调整:提升食物图像分类模型性能的关键实践 接上篇保存最优模型,在深度学习模型训练过程中,学习率作为核心超参数,其设置直接影响模型的收敛速度与最终性能。本文将结合食物图像分类项目,深入探讨学习…

Vue 3零基础入门:从环境搭建到第一个组件

Vue 3零基础入门:从环境搭建到第一个组件 一、Vue 3简介 Vue.js是一款渐进式JavaScript框架,用于构建用户界面。Vue 3是Vue的最新主要版本,于2020年9月发布,带来了许多改进和新特性: 更快的渲染速度更小的包体积Com…

为了结合后端而学习前端的学习日志(1)——纯CSS静态卡片案例

前端设计专栏 使用纯CSS创建简洁名片卡片的学习实践 在这篇技术博客中,我将分享我的前端学习过程,如何使用纯HTML和CSS创建一个简洁美观的名片式卡片,就像我博客首页展示的那样。这种卡片设计非常适合作为个人简介、产品展示或团队成员介绍…

k8s监控方案实践(一):部署Prometheus与Node Exporter

k8s监控方案实践(一):部署Prometheus与Node Exporter 文章目录 k8s监控方案实践(一):部署Prometheus与Node Exporter一、Prometheus简介二、PrometheusNode Exporter实战部署1. 创建Namespace(p…

谷歌最新推出的Gemini 2.5 Flash人工智能模型因其安全性能相较前代产品出现下滑

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗?订阅我们的简报,深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同,从行业内部的深度分析和实用指南中受益。不要错过这个机会,成为AI领…

【Python】PDF文件处理(PyPDF2、borb、fitz)

Python提供了多种方法和库用于处理PDF文件,这些工具可以帮助开发者实现诸如读取、写入、合并、拆分以及压缩等功能。以下是几个常用的Python PDF操作库及其基本用法(PyPDF2、borb、fitz)。 1. PyPDF2 PyPDF2 是一个功能强大的库&#xff0…

websocketd 10秒教程

websocketd 参考地址:joewalnes/websocketd 官网地址:websocketd websocketd简述 websocketd是一个简单的websocket服务Server,运行在命令行方式下,可以通过websocketd和已经有程序进行交互。 现在,可以非常容易地构…

Spring Boot 基于 Cookie 实现单点登录:原理、实践与优化详解

前言 在多系统交互的应用场景中,单点登录(SSO)能够显著提升用户体验,减少重复登录的繁琐操作。基于 Cookie 的单点登录方案,凭借其简单直观、浏览器原生支持的特性,成为快速实现单点登录的有效方式。本文将…

ModBus协议详解:从基础概念到C#实现RTU与TCP通讯

ModBus协议是莫迪康公司为了让PLC之间进行数据通信而设计出来的协议。它是一种总线协议,是一种一对多,上下级的关系。 它的应用广泛,具有免费开源,操作简单的有点,并且可以兼容串口和网络通讯,兼容也不错。…

PHP数组排序深度解析:sort()、rsort()、asort()、arsort()、ksort()、krsort() 的适用场景与性能对比

在PHP开发中,数组排序是日常操作的核心技能之一。无论是处理用户数据、产品列表,还是分析日志信息,合理的排序方法能显著提升代码的效率和可维护性。PHP提供了多种数组排序函数(如 sort()、rsort()、asort() 等)&#…

RabittMQ-高级特性2-应用问题

文章目录 前言延迟队列介绍ttl死信队列存在问题延迟队列插件安装延迟插件使用事务消息分发概念介绍限流非公平分发(负载均衡) 限流负载均衡RabbitMQ应用问题-幂等性保障顺序性保障介绍1顺序性保障介绍2消息积压总结 前言 延迟队列介绍 延迟队列(Delaye…

HOW - 在 Mac 上的 Chrome 浏览器中调试 Windows 场景下的前端页面

文章目录 为什么需要模拟 Windows 环境?一、修改 User-Agent 模拟 Windows 浏览器方法 1:通过 Chrome 开发者工具修改 UA方法 2:使用浏览器插件 二、模拟 Windows 的字体和滚动条样式1. 模拟 Windows 字体2. 强制显示滚动条(模拟 …