当前位置：首页 > news >正文

RabbitMQ 工作模式（上）

news 来源：原创 2025/7/30 3:39:43

前言

在 RabbitMQ 中，一共有七种工作模式，我们也可以打开官网了解：
在这里插入图片描述

本章我们先介绍前三种工作模式

（Simple）简单模式

在这里插入图片描述

P：producer 生产者，负责发送消息
C：consumer 消费者，接收消息
Queue: 消息队列

简单模式的特点：一个生产者P，一个消费者C，消息只能被消费一次，也被称为点对点【Point-to-Point】模式

案例：上一篇文章中的快速入门RabbitMQ 就是简单模式的演示，大家可以去看一下代码的实现

Work Queue（工作队列）

在这里插入图片描述
特点：多个消费者共同消费同一条队列的消息，消息不重复
假设队列有 10 条消息，C1 消费了 4 条，C2 消费了 6 条，这就是共同消费。

生产者：

public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//进行绑定ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//这里使用默认的交换机//声明队列channel.queueDeclare(Constants.WORK_QUEUE, true, false, false, null);//发送消息for (int i = 0; i < 10; i++) {String msg = "hello work queue...."+i;channel.basicPublish("",Constants.WORK_QUEUE, null, msg.getBytes());}System.out.println("发送消息成功");//资源释放channel.close();connection.close();}
}

消费者：

public class Consumer1 {public static void main(String[] args) throws IOException, TimeoutException {//进行参数绑定ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//使用默认的交换机//声明队列channel.queueDeclare(Constants.WORK_QUEUE, true, false, false, null);//消息消费DefaultConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("接收到的消息：" + new String(body));}};channel.basicConsume(Constants.WORK_QUEUE, true, consumer);}
}

public class Consumer2 {public static void main(String[] args) throws IOException, TimeoutException {//进行参数绑定ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//使用默认的交换机//声明队列channel.queueDeclare(Constants.WORK_QUEUE, true, false, false, null);//消息消费DefaultConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println("接收到的消息：" + new String(body));}};channel.basicConsume(Constants.WORK_QUEUE, true, consumer);}
}

交换机概念

这里解释一下为什么上面两种工作模式流程图没有交换机的存在，因为交换机在上面两种工作模式中不起重要作用，为了简化，所以省略了交换机，实际在 RabbitMQ 中生产者发送的消息是需要通过交换机将消息发送到对应的队列中。

在RabbitMQ 中，一共有四种类型的交换机，分别是 Fanout、Direct、Topic、Headers，不同类型的交换机有着不同的路由策略。
在 AMQP 协议中还有额外的两种类型：System 和自定义，在RabbitMQ 中我们就不介绍这额外的两种

Fanout：广播模式，将小心发送给所有与该交换机绑定的队列中，对应下面即将讲解的 Publish / Subscribe (发布 / 订阅) 工作模式

Direct：定向，将消息发送给指定的 routing key 的队列中，对应 Routing 模式

Topic：通配符，将消息交给符合指定的 routing pattern （路由模式）的队列

Headers : 该交换机不依赖路由键的批匹配规则来路由消息，而是根据发送的消息内容中的headers 属性进行匹配，headers 类型的交换机性能很差，很少很在工作中遇到。

这里解释一下 routing key 和 binding key 的概念：

在这里插入图片描述

生产者和交换机的联系使用的是 Routing Key，交换机和队列的联系使用的是 Binding Key

在后续的代码中我们也会将 Binding Key 当作 Routing Key

Publish / Subscribe (发布 / 订阅)

在这里插入图片描述

交换机将消息发送到不同的队列中，类似广播的作用，所有和该交换机绑定的队列都会收到一样的消息

public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//设置 MQ 参数ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();// 开启信道Channel channel = connection.createChannel();//声明交换机channel.exchangeDeclare("publish", BuiltinExchangeType.FANOUT, true, false, null);//声明队列channel.queueDeclare("fanout1", true, false, false, null);channel.queueDeclare("fanout2", true, false, false, null);//绑定队列和交换机channel.queueBind("fanout1","publish","");channel.queueBind("fanout2","publish","");//发送消息for (int i = 0; i < 10; i++) {channel.basicPublish("publish", "", null, ("hello" + i).getBytes());}//关闭资源channel.close();connection.close();}
}

方法参数介绍：

交换机声明：

Exchange.DeclareOk exchangeDeclare(String exchange,
BuiltinExchangeType type,
boolean durable, 
boolean autoDelete,
Map<String, Object> arguments) throws IOException;

exchange：交换机的名称

BuiltinExchangeType type：交换机的类型，点击 BuiltinExchangeType 可以查看到这是一个枚举类，一共有四种类型的交换机：DIRECT(“direct”), FANOUT(“fanout”), TOPIC(“topic”), HEADERS(“headers”);

public enum BuiltinExchangeType {DIRECT("direct"), FANOUT("fanout"), TOPIC("topic"), HEADERS("headers");private final String type;BuiltinExchangeType(String type) {this.type = type;}public String getType() {return type;}
}

durable：是否进行持久化

autoDelete：是否自动删除

arguments：高级特性的设置

交换机与队列的绑定：

Queue.BindOk queueBind(String queue, 
String exchange, 
String routingKey) throws IOException;

queue：队列的名称

exchange: 交换机的名称

routingKey ：交换机和队列绑定的联系词BindingKey，这里写的RoutingKey，本质上是一样的。

消费者代码：

public class Consumer1 {public static void main(String[] args) throws IOException, TimeoutException {//设置 MQ 参数ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//声明队列channel.queueDeclare("fanout1", true, false, false, null);//消费消息Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(new String(body));}};channel.basicConsume("fanout1", true, consumer);}
}

public class Consumer2 {public static void main(String[] args) throws IOException, TimeoutException {//设置 MQ 参数ConnectionFactory factory = new ConnectionFactory();factory.setHost(Constants.HOST);factory.setPort(Constants.PORT);factory.setUsername(Constants.NAME);factory.setPassword(Constants.PASSWORD);factory.setVirtualHost(Constants.VIRTUAL_HOST);//建立连接Connection connection = factory.newConnection();//开启信道Channel channel = connection.createChannel();//声明队列channel.queueDeclare("fanout2", true, false, false, null);//进行消费Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(new String(body));}};channel.basicConsume("fanout2", true, consumer);}
}

RabbitMQ 工作模式（上）

前言在 RabbitMQ 中，一共有七种工作模式，我们也可以打开官网了解： 本章我们先介绍前三种工作模式 （Simple）简单模式 P：producer 生产者，负责发送消息 C：consumer 消费者&#x…...

编程日记 2025/7/30 3:39:43

为什么需要加密机服务？

前言大家好，我是老马。以前我自己在写工具的时候，都是直接自己实现就完事了。但是在大公司，或者说随着合规监管的要求，自己随手写的加解密之类的，严格说是不合规的。作为一家技术性公司，特别是金融…...

编程日记 2025/7/30 3:30:30

【Linux】利用多路转接epoll机制、ET模式，基于Reactor设计模式实现

编程日记 2025/7/30 3:37:37

c/c++的findcontours崩溃解决方案

解决 Windows 平台 OpenCV findContours 崩溃：一种更稳定的方法许多在 Windows 平台上使用 OpenCV 的开发者可能会在使用 findContours 函数时，遇到令人头疼的程序崩溃问题。尽管网络上流传着多种解决方案，但它们并非总能根治此问题。当时…...

编程日记 2025/7/27 22:38:23

机器学习 Day18 Support Vector Machine ——最优美的机器学习算法

1.问题导入： 2.SVM定义和一些最优化理论 2.1SVM中的定义 2.1.1 定义 SVM 定义：SVM（Support Vector Machine，支持向量机）核心是寻找超平面将样本分成两类且间隔最大。它功能多样，可用于线性或非线性分类…...

编程日记 2025/7/27 9:47:16

npm与pnpm--为什么推荐pnpm

包管理器中 npm是最经典的，但大家都任意忽略一个更优质的管理器：pnpm 1. 核心区别特性npmpnpm依赖存储方式扁平化结构（可能重复依赖）硬链接符号链接（共享依赖，节省空间）安装速度较慢&#…...

编程日记 2025/7/30 3:26:38

ollama调用千问2.5-vl视频图片UI界面小程序分享

1、问题描述： ollama调用千问2.5-vl视频图片内容，通常用命令行工具不方便，于是做了一个python UI界面与大家分享。需要提前安装ollama，并下载千问qwen2.5vl:7b 模型，在ollama官网即可下载。 （8G-6G 显卡可…...

编程日记 2025/7/30 3:27:03

济南国网数字化培训班学习笔记-第三组-1-电力通信传输网认知

电力通信传输网认知电力通信基本情况传输介质传输介质类型（导引与非导引） 导引传输介质，如电缆、光纤； 非导引传输介质，如无线电波； 传输介质的选择影响信号传输质量信号传输模式（单工…...

编程日记 2025/7/30 3:31:40

Kubernetes控制平面组件：Kubelet详解（六）：pod sandbox(pause)容器

云原生学习路线导航页（持续更新中） kubernetes学习系列快捷链接 Kubernetes架构原则和对象设计（一）Kubernetes架构原则和对象设计（二）Kubernetes架构原则和对象设计（三）Kubernetes控…...

编程日记 2025/7/24 20:01:30

51单片机，两路倒计时，LCD1602 ，Proteus仿真

初始上电默认2路都是0分钟的倒计时 8个按键 4个一组一组控制一路倒计时 4个按键：加减开始或者暂停复位到0分钟相当于停止针对第一路倒计时 4个按键2：加减开始或者暂停复位到0分钟相当于停止针对第2路倒计时哪一路到了0后蜂鸣器响对应LED点亮 main.c 文件实现了…...

编程日记 2025/7/27 14:03:19

MySQL之储存引擎和视图

一、储存引擎基本介绍： 1、MySQL的表类型由储存引擎(Storage Engines)决定，主要包括MyISAM、innoDB、Memory等。 2、MySQL数据表主要支持六种类型，分别是：CSV、Memory、ARCHIVE、MRG_MYISAN、MYISAM、InnoBDB。 3、这六种又分…...

编程日记 2025/7/28 21:56:57

写spark程序数据计算（数据库的计算，求和，汇总之类的）连接mysql数据库，写入计算结果

1. 添加依赖在项目的 pom.xml（Maven）中添加以下依赖： xml  <dependency> <groupId>org.apache.spark</groupId> <artifactId>spark-sql_2.12</artifactId> <version>3.3.0…...

编程日记 2025/7/28 1:08:48

一：操作系统之系统调用

系统调用：用户程序与操作系统交互的桥梁在计算机的世界里，应用程序是我们日常接触最多的部分，比如浏览器、文本编辑器、游戏等等。然而，这些应用程序并不能直接控制硬件资源，比如读写硬盘、创建新进程、发送网络数据…...

编程日记 2025/7/25 16:19:08

【ROS2】核心概念6——通信接口语法（Interfaces）

古月21讲/2.6_通信接口官方文档：Interfaces — ROS 2 Documentation: Humble documentation 官方接口代码实战：https://docs.ros.org/en/humble/Tutorials/Beginner-Client-Libraries/Single-Package-Define-And-Use-Interface.html ROS 2使用简化的描…...

编程日记 2025/7/16 7:51:17

SmartETL函数式组件的设计与应用

SmartETL框架主要采用了面向对象的设计思想，将ETL过程中的处理逻辑抽象为Loader和Processor（对应loader模块和iterator模块），所有流程组件需要继承或实现DataProvider（iter方法）或JsonIterator（…...

编程日记 2025/7/27 23:08:03

Spring Security与SaToken的对比与优缺点分析

Spring Security与SaToken对比分析一、框架定位 Spring Security 企业级安全解决方案，深度集成Spring生态提供完整的安全控制链（认证、授权、会话管理、攻击防护）适合中大型分布式系统 SaToken 轻量级权限认证框架，专注Token会…...

编程日记 2025/7/29 16:18:00

|从零开始的Pyside2界面编程| 环境搭建以及第一个ui界面

🐑 |从零开始的Pyside2界面编程| 环境搭建以及第一个ui界面🐑 文章目录 🐑 |从零开始的Pyside2界面编程| 环境搭建以及第一个ui界面🐑♈前言♈♈Pyside2环境搭建♈♈做个简单的UI界面♈♒代码实现♒♒QTdesigner设计UI界面♒ ♒总…...

编程日记 2025/7/27 13:35:17

【爬虫】DrissionPage-7

官方文档： https://www.drissionpage.cn/browser_control/get_page_info/ 1. 页面信息 📌 html 描述：返回当前页面的 HTML 文本。注意：不包含 <iframe> 元素的内容。返回类型：str 示例： html_co…...

编程日记 2025/7/25 19:37:12

系统架构设计（十二）：统一过程模型（RUP）

简介 RUP 是由 IBM Rational 公司提出的一种面向对象的软件工程过程模型，以 UML 为建模语言，是一种以用例为驱动、以架构为中心、迭代式、增量开发的过程模型。三大特征特征说明以用例为驱动（Use Case Driven）需求分析和测…...

编程日记 2025/7/24 10:43:48

深入解析Java事件监听机制与应用

Java事件监听机制详解一、事件监听模型组成事件源（Event Source） 产生事件的对象（如按钮、文本框等组件） 事件对象（Event Object） 封装事件信息的对象（如ActionEvent包含事件源信息&#xf…...

编程日记 2025/7/28 4:22:31

QT聊天项目DAY11

1. 验证码服务 1.1 用npm安装redis npm install redis 1.2 修改config.json配置文件 1.3 新建redis.js const config_module require(./config) const Redis require("ioredis");// 创建Redis客户端实例 const RedisCli new Redis({host: config_module.redis_…...

编程日记 2025/7/27 23:18:01

Python训练营---Day29

知识点回顾类的装饰器装饰器思想的进一步理解：外部修改、动态类方法的定义：内部定义和外部定义作业：复习类和函数的知识点，写下自己过去29天的学习心得，如对函数和类的理解，对python这门工具的理解等&…...

编程日记 2025/7/22 22:54:20

Flask-SQLAlchemy_数据库配置

1、基本概念（SQLAlchemy与Flask-SQLAlchemy） SQLAlchemy 是 Python 生态中最具影响力的 ORM（对象关系映射）库，其设计理念强调 “框架无关性”，支持在各类 Python 项目中独立使用，包括 Flask、D…...

编程日记 2025/7/24 7:00:07

世界银行数字经济指标（1990-2022年）-社科数据

世界银行数字经济指标（1990-2022年）-社科数据https://download.csdn.net/download/paofuluolijiang/90623839 https://download.csdn.net/download/paofuluolijiang/90623839 此数据集涵盖了1990年至2022年间全球各国的数字经济核心指标，数据…...

编程日记 2025/7/25 16:02:04

Redis进阶知识

Redis 1.事务2. 主从复制2.1 如何启动多个Redis服务器2.2 监控主从节点的状态2.3 断开主从复制关系2.4 额外注意2.5拓扑结构2.6 复制过程2.6.1 数据同步 3.哨兵选举原理注意事项 4.集群4.1 数据分片算法4.2 故障检测 5. 缓存5.1 缓存问题 6. 分布式锁 1.事务 Redis的事务只能保…...

编程日记 2025/7/29 11:23:22

NY337NY340美光固态颗粒NC010NC012

NY337NY340美光固态颗粒NC010NC012 在存储技术的浩瀚星空中，美光的NY337、NY340、NC010、NC012等固态颗粒宛如璀璨星辰，闪耀着独特的光芒。它们承载着先进技术与无限潜力，正深刻影响着存储行业的格局与发展。一、技术架构与核心优势美光…...

编程日记 2025/7/16 13:19:59

DAY26 函数定义与参数

浙大疏锦行-CSDN博客知识点回顾： 1.函数的定义 2.变量作用域：局部变量和全局变量 3.函数的参数类型：位置参数、默认参数、不定参数 4.传递参数的手段：关键词参数 5.传递参数的顺序：同时出现三种参数类型时函数的定义…...

编程日记 2025/7/16 15:31:42

系统安全及应用

目录一、账号安全控制 1.基本安全措施 （1）系统账号清理 (2)密码安全控制 （3）历史命令，自动注销 2.用户提权和切换命令 2.1 su命令用法 2.2 sudo命令提权 2.3通过是sudo执行特权命令二、系统引导和登录控制…...

编程日记 2025/7/17 7:09:01

微信小程序地图使用射线法判断目标点是否在多边形内部（可用于判断当前位置是否在某个区域内部）

目录射线法原理简要逻辑代码小程序代码调试基础库小程序配置地图数据地图多边形点与多边形关系射线法原理使用射线法来判断，目标点是否在多边形内部这里简单说下，具体细节可以看这篇文章平面几何：判断点是否在多边形内（…...

编程日记 2025/7/25 20:24:33

第三十七节：视频处理-视频读取与处理

引言：解码视觉世界的动态密码在数字化浪潮席卷全球的今天，视频已成为信息传递的主要载体。从短视频平台的爆火到自动驾驶的视觉感知，视频处理技术正在重塑人类与数字世界的交互方式。本指南将深入探讨视频处理的核心技术，通过Python与OpenCV的实战演示，为您揭开动态影像…...

编程日记 2025/7/11 15:18:09

什么是 Flink Pattern

在 Apache Flink 中，Pattern 是 Flink CEP（Complex Event Processing）模块的核心概念之一。它用于定义你希望从数据流中检测出的事件序列模式（Event Sequence Pattern）。 🎯 一、什么是 Flink Pattern&am…...

编程日记 2025/7/30 1:20:47

ADB基本操作和命令

1.ADB的含义 adb 命令是 Android 官方提供，调试 Android 系统的工具。 adb 全称为 Android Debug Bridge（Android 调试桥），是 Android SDK 中提供的用于管理 Android 模拟器或真机的工具。 adb 是一种功能强大的命令行工具&#x…...

编程日记 2025/7/17 21:01:09

NSString的三种实现方式

oc里的NSString有三种实现方式，为_ _NSCFConstantString、__NSCFString、NSTaggedPointerString 1._ _NSCFConstantString(字面量字符串) 从字面意思上可以看出，_ _NSCFContantString可以理解为常量字符串，这种类型的字符串在编译期就确定了…...

编程日记 2025/7/23 1:23:02

2025年PMP 学习二十第13章项目相关方管理

第13章项目相关方管理序号过程过程组过程组1识别相关方启动2规划相关方管理规划3管理相关方参与与执行4监控相关方参与与监控相关方管理，针对于团队之外的相关方的，核心目标是让对方为了支持项目，以达到项目目标。文章目录第13章项目相…...

编程日记 2025/7/23 21:28:22

学习黑客Kerberos深入浅出：安全王国的门票系统

Kerberos深入浅出：安全王国的门票系统 🎫 作者: 海尔辛 | 发布时间: 2025-05-18 🔑 理解Kerberos：为什么它如此重要？ Kerberos是现代网络环境中最广泛使用的身份验证协议之一，尤其在Windows Active Dire…...

编程日记 2025/7/28 14:03:18

蓝桥杯19681 01背包

问题描述有 N 件物品和一个体积为 M 的背包。第 i 个物品的体积为 vi，价值为 wi。每件物品只能使用一次。请问可以通过什么样的方式选择物品，使得物品总体积不超过 M 的情况下总价值最大，输出这个最大价值即可。输入格式第一行输…...

编程日记 2025/7/28 21:06:55

使用 Auto-Keras 进行自动化机器学习

使用 Auto-Keras 进行自动化机器学习了解自动化机器学习以及如何使用 auto-keras 完成它。如今，机器学习并不是一个非常罕见的术语，因为像 DataCamp、Coursera、Udacity 等组织一直在努力提高他们的效率和灵活性，以便将机器学习的教育带给普…...

编程日记 2025/7/18 14:51:49

算法刷题Day9 5.18:leetcode定长滑动窗口3道题，结束定长滑动窗口,用时1h

12. 1852.每个子数组的数字种类数 1852. 每个子数组的数字种类数 - 力扣（LeetCode） 思想找到nums 所有长度为 k 的子数组中不同元素的数量。返回一个数组 ans，其中 ans[i] 是对于每个索引 0 < i < n - k，nums[i..(i …...

编程日记 2025/7/24 15:36:49

Protect Your Digital Privacy: Obfuscate, Don’t Hide

Protect Your Digital Privacy: Obfuscate, Don’t Hide In today’s digital world, hiding completely online is nearly impossible. But you can protect yourself by deliberately obfuscating your personal information — making it harder for others to track, pro…...

编程日记 2025/7/28 13:41:39

前言

（Simple）简单模式

Work Queue（工作队列）

交换机概念

Publish / Subscribe (发布 / 订阅)

相关文章：