RabbitMq中交换机(Exchange)、队列(Queue)和路由键(Routing Key)

news/2024/9/19 17:40:43/ 标签: rabbitmq, 中间件, 分布式

RabbitMQ 是一个消息代理系统,使用交换机(Exchange)、队列(Queue)和路由键(Routing Key)来管理消息的传递。它们分别起到不同的作用,构成了消息从生产者到消费者的传递路径。

以下是详细的解释:

1. 交换机(Exchange)

作用

交换机负责接收来自生产者的消息,并根据一定的路由规则将消息分发给一个或多个队列。它是生产者和队列之间的中间层,生产者永远不会直接将消息发送到队列,而是通过交换机。

种类

RabbitMQ 中有几种类型的交换机,每种交换机的消息路由行为都不同:

  • Direct(直连交换机):根据精确匹配路由键(Routing Key)来将消息转发到绑定了相同路由键的队列。
  • Fanout(扇出交换机):不处理路由键,直接将消息广播给绑定到该交换机的所有队列。类似广播机制。
  • Topic(主题交换机):根据路由键的模式匹配(可以使用通配符)将消息路由到符合条件的队列。
  • Headers(头交换机):根据消息的 headers(头部信息)属性来路由,而不是使用路由键。
作用场景

交换机的主要作用是 决定消息应该被发送到哪些队列,每种交换机的类型决定了消息的路由逻辑。


2. 队列(Queue)

作用

队列是消息的实际存储位置。消息被发送到队列后,消费者从队列中取出并处理。队列中的消息按照 先进先出(FIFO) 的顺序被消费者处理。

  • 队列是点对点通信的终点,消费者从队列中拉取消息并处理,每个消息只会被一个消费者处理(除非有特别的广播机制)。
  • 消息可以在队列中持久化(持久化队列),即使 RabbitMQ 服务器重启,消息仍然会保存在队列中。
作用场景

队列的作用是 存储和传递消息。消息在队列中被保存,直到消费者来获取和处理消息。队列可以支持多种消费者,并且保证消息被处理一次且仅一次。


3. 路由键(Routing Key)

作用

路由键是生产者在将消息发送给交换机时提供的一个字符串,用来指定消息的路由路径。交换机会根据路由键的内容,决定该消息应该发送到哪些队列。

  • Direct 交换机 中,路由键用于精确匹配。例如,路由键 task_queue 只会将消息发送到绑定了 task_queue 路由键的队列。
  • Topic 交换机 中,路由键可以使用通配符进行模糊匹配。例如,device.* 可以匹配 device.datadevice.status,但 device.# 可以匹配多个词。
作用场景

路由键的作用是 指定消息传递路径。交换机会根据路由键将消息发送到符合条件的队列。


三者的区别和作用总结

名称作用和功能角色区别
交换机(Exchange)接收生产者的消息并根据路由键将消息发送到一个或多个队列。交换机本身不保存消息,只负责转发消息。中间人决定消息如何分发到不同的队列
队列(Queue)用于存储消息,等待消费者来处理。消费者从队列中拉取消息进行处理。队列是消息的最终接收点,消息只能在队列中被消费一次。消费者终点存储和传递消息
路由键(Routing Key)生产者指定的一个字符串,用来决定交换机如何将消息路由到队列。路由键可以是精确匹配或模糊匹配(使用通配符)。消息路由控制决定消息走向哪些队列

三者之间的关系:

  1. 生产者(Producer):向 交换机 发送消息,并指定一个 路由键
  2. 交换机(Exchange):根据绑定的规则和 路由键,将消息转发到合适的 队列
  3. 队列(Queue):消息最终到达 队列,并等待消费者取出并处理。
  4. 消费者(Consumer):从队列中取出消息进行处理。

流程示例:

假设我们有以下 RabbitMQ 配置:

  • 交换机:task_exchange(类型为 Direct)。
  • 队列:task_queue
  • 路由键:task.new.
消息传递过程:
  1. 生产者发送一条消息到 task_exchange,并指定路由键为 task.new
  2. task_exchange 交换机会检查是否有队列绑定了 task.new 路由键。
  3. 如果 task_queue 队列绑定了 task.new 路由键,交换机会将消息发送到 task_queue
  4. 消费者从 task_queue 中拉取消息并进行处理。

这个流程说明了交换机、队列和路由键之间如何协同工作来完成消息的路由和处理。


常见应用场景:

  1. Direct 交换机

    • 用于精确匹配路由键的场景,比如不同的任务类型对应不同的队列,确保消息到达正确的队列。
  2. Fanout 交换机

    • 广播消息给多个消费者,常用于发布/订阅模式,比如推送系统消息给所有消费者。
  3. Topic 交换机

    • 适用于需要根据复杂模式路由消息的场景,比如日志系统,路由键可以根据日志级别(如 errorinfo)路由到不同的队列。


http://www.ppmy.cn/news/1527173.html

相关文章

Matlab如何配置小波工具(Wavelet Toolbox)

1、发现问题 因为实验要使用小波工具函数,运行时报错如下: 查看对应文件夹发现没有小波工具(也可在控制台输入ver),检查是否有该工具,输入后回车返回如下: 2、下载工具包 没有这个工具就要去下…

深入剖析:C++类对象的内存布局与优化

深入剖析:C类对象的内存布局与优化 引言 在C编程中,理解类对象的内存布局对于优化内存使用和提高程序性能至关重要。本文将详细介绍C类对象的内存布局,包括数据成员、虚函数表指针以及静态变量和静态方法在内存中的位置。通过这些知识&…

【加密社】Solidity 中的事件机制及其应用

加密社 引言 在Solidity合约开发过程中,事件(Events)是一种非常重要的机制。它们不仅能够让开发者记录智能合约的重要状态变更,还能够让外部系统(如前端应用)监听这些状态的变化。 本文将详细介绍Solidity中…

OpenFeign接口调用日志

一、介绍 在开发或测试环境中,需要更多的调试信息;在通过 Spring Cloud OpenFeign 调用远程服务的接口时,可能需要记录接口调用的日志详情,比如:请求头、请求参数、响应等。 Spring Cloud OpenFeign 打印 FeignClien…

达芬奇竖屏导出有黑屏解决方案

文章目录 项目设置导出设置 初学达芬奇,导出的时候,总是有黑边。 经过研究,才发现导出的时候的分辨率和项目分辨率 2个地方都要设置,否则导出就会导致有黑边。 项目设置 点击 文件 选择项目设置 选择竖屏分辨率 导出设置

C++ MFC SnowWorld

目录 效果 项目 代码 下载 效果 SnowWorld 项目 代码 // ChildView.cpp : implementation of the CChildView class // #include "stdafx.h" #include "SnowWorld.h" #include "ChildView.h" #ifdef _DEBUG #define new DEBUG_NEW #und…

无人机之防风性能篇

无人机的防风性能是评价其在不同风力条件下稳定性和安全性的重要指标。以下是关于无人机防风性能的几个关键点: 一、防风性能的影响因素 机身设计与结构:无人机的机身设计、材料选择以及结构强度直接影响其防风性能。例如,采用坚固耐用的材…

【笔记】1.3 二极管应用电路举例

文章目录 一、二极管的近似模型1、理想模型2、恒压降模型3、折线模型二、二极管的基本应用电路(主要涉及二极管的导通与否对电路的影响)1、开关电路(1)单管(2)多管优先导通原则:正向电压大的先导通。2、限幅电路单向限幅双向限幅一、二极管的近似模型 1、理想模型 就是…

图解Redis 01 | 初识Redis

什么是 Redis? Redis 是一种基于内存的数据库,所有的数据读写操作都在内存中完成,因此读写速度非常快。它被广泛应用于缓存、消息队列、分布式锁等场景。 Redis 提供了多种数据类型来支持不同的业务需求,如 String、Hash、List、…

25. MyBatis中的RowBounds是什么?如何实现内存分页?

是 MyBatis 提供的一种用于结果集分页的功能,主要通过内存分页的方式实现。它通过在查询时传递分页参数,限制返回的结果集的大小。RowBounds 并不依赖于数据库层的分页功能,而是通过 MyBatis 在内存中对结果集进行截取,从而实现分…

中国计算机学会(CCF)推荐中文科技期刊目录(2019年)

推荐期刊害死人 ### A 类 | 序号 | 期刊名称 | 主办单位 | 网址 | |------|--------------------------|------------------------------------|-----------------------------------| | 1 | 软…

【Python机器学习】序列到序列建模——实际应用

序列到序列网络非常适合所有具有可变长度输入序列或可变长度输出序列的机器学习应用。由于自然语言的词序列几乎总是有不可预测的长度,因此序列到序列模型可以提高大多数机器学习模型的精确率。 目前序列到序列结构的主要应用有: 聊天机器人对话&#…

TensorRT-LLM——优化大型语言模型推理以实现最大性能的综合指南

引言 随着对大型语言模型 (LLM) 的需求不断增长,确保快速、高效和可扩展的推理变得比以往任何时候都更加重要。NVIDIA 的 TensorRT-LLM 通过提供一套专为 LLM 推理设计的强大工具和优化,TensorRT-LLM 可以应对这一挑战。TensorRT-LLM 提供了一系列令人印…

day22JS-npm中的部分插件使用方法

1. 静态资源目录 静态资源目录就是访问服务器的某些路劲时候,服务器可以吐出一个写好的指定页面。 实现思路: 1、先判断要找的路径是否是文件,如果是文件,就加载发给对方。 2、如果是文件夹,找到这个文件夹所在路径中…

用户体验在网站建设中的重要性

用户体验在网站建设中的重要性不言而喻。以下是对其重要性的具体介绍: 提升用户满意度:用户体验的优劣直接关系到用户对网站的满意程度。一个设计良好、易于导航、响应迅速的网站能够让用户在使用过程中感到舒适和愉悦,从而增加用户对网站的…

人工智能物联网的去中心化和分布式学习:全面综述、新兴挑战和机遇

这篇论文的标题是《Decentralized and Distributed Learning for AIoT: A Comprehensive Review, Emerging Challenges, and Opportunities》,作者是Hanyue Xu, Kah Phooi Seng, Li Minn Ang, 和 Jeremy Smith。论文发表在IEEE Access期刊上,接收日期为2…

Matlab simulink建模与仿真 第十七章(补充离散库和补充数学库)

参考视频:simulink1.1simulink简介_哔哩哔哩_bilibili 一、补充离散库和补充数学库中的模块概览 1、补充离散库 注:每个版本的补充离散库不一定相同,也不是每个版本的库都有如上所有模块。 2、补充数学库 二、离散直接传递函数Ⅱ模块 1、…

解决Tez报错问题

在启动hive的时候,发现该报错 1、检测HADOOP_PATH环境变量 echo $HADOOP_CLASSPATH 如果没有输出,说明我们的配置文件没有生效,这时候需要重写source一下 2、刷新配置文件生效 source /etc/profile 有输出,环境生效 3、再次运…

flink实战--如何基于java-agent技术增强Flink功能

Agent实现Flink流动数据的监听 一个Flink程序的运行,会依赖到一个或多个Connector(连接器),而这些连接器分为Source(主要用于读)和Sink(主要用于写),那么如果要监听到Flink作业流动的数据,我们这里可以简单尝试去查看支持Sink的Connector(例如:flink…

[docker]入门

本文章主要讲述的是,docker基本实现原理,docker概念的解释,docker的使用场景以及docker打包与部署的应用。 文章中docker所运行的系统:CentOS Linux release 7.9.2009 (Core) 目录 docker是什么,什么时候需要去使用 …