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

RabbitMQ快速入门

news 来源：原创 2025/9/12 7:04:48

MQ简介

1、同步通信

图片

2、异步通信

图片

RabbitMQ快速上手

基本介绍：

Producer和Consumer

Connection和Channel

Virtual host

Queue

Exchange

工作流程

AMQP

Java编写RabbitMQ生产者消费者

生产者

1.建立连接

2.开启信道

3.声明交换机

4.声明队列

5.发送消息

6.资源释放

生产者全部代码：

消费者

执行结果

MQ简介

MQ(Message Queue)消息队列，本质上是队列，满足队列FIFO(先入先出)的性质,队列中存放的内容是消息，消息可以是只包含文本字符串，JSON，也可以是对象等。

MQ经常用于分布式系统之间的通信，系统之间的通信通常有两种方式：

1、同步通信

直接调用对方的服务，数据从一端出发到达另一端。

图片

2、异步通信

数据从⼀端发出后，先进⼊⼀个容器进⾏临时存储，当达到某种条件后，再由这个容器发送给另⼀端，这个容器通常就是MQ(message queue)。

图片

RabbitMQ快速上手

基本介绍：

RabbitMQ是MQ的一种实现，工作流程如下：

RabbitMQ是一个消息中间件，也是一个生产者消费者模型，负责接收，存储并转发消息，消息传递的过程类似于发快递，你把快递放到驿站，快递小哥帮你把快递送到接收人的手上。这个过程中，你就相当于Producer，接收人相当于Consumer，快递站就是RabbitMQ。

Producer和Consumer

Producer(生产者)，是RabbitMQ的客户端，用于发送消息到RabbitMQ。

Consumer(消费者)，也是RabbitMQ的客户端，用于向RabbitMQ接收消息。

Broker(代理)，RabbitMQ服务器节点，用于接收和发送消息。

生产者发送消息到RabbitMQ服务器，让RabbitMQ进行路由转发到对应的消费者。

生产者发送的消息带有标签，代理（RabbitMQ服务器）会根据标签路由，找到需要的消费者，进行消息转发。消费者接收消息进行消费过程中标签就会被丢掉，也就是说消费者并不会知道消息的发送者是谁。

Connection和Channel

Connection(连接)：客户端和RabbitMQ服务器之间的⼀个TCP连接，建立连接后才可以进行消息的发送和接收。

Channel(信道)：类似于发送消息的一个通道，每个TCP连接可以有多个信道，每个信道都是独立的虚拟连接，消息的发送和接收都是基于Channel(信道)的。

Virtual host

Virtual host：虚拟主机，给消息队列提供逻辑上的隔离，一个BrokerServer可以有多个虚拟主机，当不同用户使用RabbitMQ Server提供的服务时，可以使用划分多个虚拟主机的方式将一系列业务隔离开来，类似于MySQL中不同的数据库。

Queue

Queue：队列，用于存放消息，一个队列可以被多个消费者订阅。

Exchange

Exchenge：交换机，交换机负责接收生产者发送的消息，并按照规则将消息路由到队列上。类似于快递小哥将快递送给

工作流程

Proucer生产消息 -> Producer连接到RabbitMQBroker，建立连接(Connection)，开启信道(Channel) -> Producer声明交换机(Exchange),路由消息 ->Producer声明队列(Queue) -> Produce发送消息到RabbitMQBroker-> RabbitMQBroker接收消息，并放入相应的队列(Queue)中，未找到相应队列根据生产者的配置，选择丢弃或者退回给生产者。

AMQP

AMQP是一种高级消息队列协议，定义了一套确定的消息交换功能，包括交换机，队列等，这些组件共同工作，使生产者能够将消息发送到交换机，由队列接收并等待消费者接收。AMQP还定义了一个网络协议，允许客户端应用通过这个协议与消息代理和AMQP模型进行交互通信。RabbitMQ使AMQP协议的Erlang实现。

Java编写RabbitMQ生产者消费者

打开管理页面，添加用户：

这里添加的测试用户名称为：test 密码 123456。

创建虚拟机：

这里添加的虚拟机名称为：test

返回admin页面，点击刚刚创建的test用户，添加虚拟机操作权限。

进入IDEA创建一个Maven项目，导入依赖：

<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.20.0</version>
</dependency>

生产者

1.建立连接

使用依赖中的ConnectionFactory类创建连接，设置关键信息：

ConnectionFactory connectionFactory = new ConnectionFactory();
connectionFactory.setHost("139.9.116.124");
connectionFactory.setPort(5672);
connectionFactory.setUsername("fwx");
connectionFactory.setPassword("123456");
connectionFactory.setVirtualHost("测试");
Connection connection = connectionFactory.newConnection();

2.开启信道

Channel channel = connection.createChannel();

3.声明交换机

这里使用的是RabbitMQ默认提供的交换机，不需要代码进行声明

4.声明队列

使用channel的queueDeclare方法，依此填入相关参数：

channel.queueDeclare("hello",true,false,false,null);

打开源码，查看参数的含义：

第一个参数queue代表队列的名称，第二个参数durable代表是否持久化（true-设置队列为持久化, 待久化的队列会存盘,服务器重启之后, 消息不丢失），第三个参数exclusive代表是否独占（是否独占, 只能有⼀个消费者监听队列），第四个参数autoDelete代表是否自动删除（没有消费者自动删除队列），第五个参数arguments代表一些配置的参数。

5.发送消息

使用Channel的basicPublish()方法进行消息的发送，这里发送的消息为"hello RabbitMQ~"，消息发送10次：

for (int i = 0; i < 10; i++) {String msg = "hello RabbitMQ~";channel.basicPublish("","test1",null,msg.getBytes());
}

打开方法，分析方法参数：

第一个参数exchange代表交换机的名称(这里使用默认交换机"")，第二个参数routingKey代表路由的名称（使用默认交换机，路由名称要和队列名称相同才可以找到对应队列），第三个参数body代表发送的消息体（将String类型转换为字节数组）。

6.资源释放

channel.close();
connection.close();

最后将资源关闭即可。

生产者全部代码：

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class Producer {public static void main(String[] args) throws IOException, TimeoutException {//1.建立链接ConnectionFactory connectionFactory = new ConnectionFactory();//主机地址connectionFactory.setHost("139.9.116.124");//端口号connectionFactory.setPort(5672);//用户名connectionFactory.setUsername("test");//密码connectionFactory.setPassword("123456");//虚拟机connectionFactory.setVirtualHost("test");//连接建立Connection connection = connectionFactory.newConnection();//2.开启信道Channel channel = connection.createChannel();//3.声明交换机,使用内置交换机//4.声明队列channel.queueDeclare("test1",true,false,false,null);//5.发送消息for (int i = 0; i < 10; i++) {String msg = "hello RabbitMQ~";channel.basicPublish("","test1",null,msg.getBytes());}//6.资源释放channel.close();connection.close();}
}

消费者

消费者与生产者逻辑相似，这里不再讲解，全部代码：

import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class Consumer {public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {//1.建立链接ConnectionFactory connectionFactory = new ConnectionFactory();//主机地址connectionFactory.setHost("139.9.116.124");//端口号connectionFactory.setPort(5672);//用户名connectionFactory.setUsername("test");//密码connectionFactory.setPassword("123456");//虚拟机connectionFactory.setVirtualHost("test");//连接建立Connection connection = connectionFactory.newConnection();//2.开启信道Channel channel = connection.createChannel();//3.声明队列(生产者已经声明)//4.消费消息/**参数声明* basicConsume(String queue, boolean autoAck, Consumer callback)* queue:队列名* autoAck:自动确认* callback：接收到消息执行逻辑*/DefaultConsumer consumer = new DefaultConsumer(channel){//从队列中收到消息，就会执行的方法@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {//TODOSystem.out.println("接收的消息："+new String(body));}};channel.basicConsume("test1",true,consumer);//等待程序执行完成Thread.sleep(2000);//5.释放资源channel.close();connection.close();}
}

生产者已经声明过队列，消费者无需声明，消费者通过重写handleDelivery()方法（这个方法在接收消息时自动执行）去消费消息。

执行结果

执行生产者代码，打开RabbitMQ管理页面，看到队列test1产生了10条消息等待消费：

执行消费者，此时控制台打印了接收的消息：

再查看管理页面，消息已经全部消费：

到此结束，感谢观看！

RabbitMQ快速入门

目录 MQ简介 1、同步通信图片 2、异步通信图片 RabbitMQ快速上手基本介绍： Producer和Consumer Connection和Channel Virtual host Queue Exchange 工作流程 AMQP Java编写RabbitMQ生产者消费者生产者 1.建立连接 2.开启信道 3.声明交换机 4.声…...

编程日记 2025/9/12 7:04:48

内存中的缓存区

在 Java 的 I/O 流设计中，BufferedInputStream 和 BufferedOutputStream 的“缓冲区”是内存中的缓存区（具体是 JVM 堆内存的一部分），但它们的作用是优化数据的传输效率，并不是直接操作硬盘和内存之间的缓存。以下是详…...

编程日记 2025/9/10 11:03:39

快速列出MS Word中所有可用字体

Word中有很多字体，虽然在字体下拉列表中提供了字体的样例，但是并不全面，例如使用Batang字体的话，数字会显示成什么效果，就无法直观的看到。打开Word应用程序，新建一个空白文档，按AltF11打开VBE…...

编程日记 2025/9/12 18:41:01

《机器学习数学基础》补充资料：矩阵的LU分解

本文是对《机器学习数学基础》第2章2.3.3节矩阵LU分解的拓展。判断是否可LU分解并非所有矩阵都可以实现LU分解。定理1： 若 n n n 阶可逆矩阵 A \pmb{A} A 可以进行LU分解，则 A \pmb{A} A 的 k k k 阶顺序主子阵（leading principal s…...

编程日记 2025/9/12 18:41:39

seasms v9 注入漏洞 + order by注入+information_schema解决方法

目录一、当注入时，information_schema被禁用的解决方法 1.通过sys库可以获取到表名和库名 2.通过无列名注入join获取列名二、seasms v9 注入漏洞三、order by注入一、当注入时，information_schema被禁用的解决方法 information_schema数据库是My…...

编程日记 2025/9/12 18:34:50

跨端方案选型：对比Uni-app与Taro在复杂电商项目中的技术选型依据参考

跨端方案选型：对比Uni-app与Taro在复杂电商项目中的技术选型依据参考请赏析： Uni-app与Taro复杂电商项目选型对比指南一、核心选型维度速记技术栈匹配 → 跨端能力 → 性能优化 → 开发效率 → 生态支持 → 长期维护二、关键维度对比分析 1. 技术栈匹配性框架技术栈适…...

编程日记 2025/9/12 18:41:37

C语言32个关键字

32个关键字 1.基本数据类型 signed unsigned char int float double short long void 2.构造数据类型 struct union enum 3.数据存储类别 auto static extern register 4.数据优化 const volatile 5. 9条基本语句 if else switch case break default while do for…...

编程日记 2025/9/9 1:12:05

音乐游戏Drummania(GITADORA)模拟器

文章目录 （一）Drummania和GITADORA（1.1）基本情况（1.2）机体 （二）模拟器（2.1）主程序（2.2）模拟器主题 （三）曲谱文…...

编程日记 2025/9/10 19:23:12

WPF中对滚动条进行平滑滚动

有时候我们在动态添加内容时，需要将滚动条滚动到指定内容处。一般我们会调用ScrollViewer的ScrollToVerticalOffset（垂直方向）函数和ScrollToHorizontalOffset（水平方向）函数来控制滚动条滚动到指定位置。正常滚动效…...

编程日记 2025/9/12 18:41:38

【通俗讲解电子电路】——从零开始理解生活中的电路(一)

导言：电子电路为什么重要？ ——看不见的“魔法”，如何驱动你的生活？ 清晨，当你的手机闹钟响起时，你可能不会想到，是电子电路在精准控制着时间的跳动；当你用微波炉加热早餐时&#…...

编程日记 2025/9/12 18:32:55

达梦：内存相关参数

目录 28个相关参数1. 内存池相关MEMORY_POOLMEMORY_N_POOLSMEMORY_BAK_POOL 2. 大缓冲区相关HUGE_BUFFERHUGE_BUFFER_POOLS 3. 共享缓冲区相关BUFFERBUFFER_POOLSBUFFER_MODEMAX_BUFFER 4. 快速池相关FAST_POOL_PAGES 5. 回收池相关RECYCLE_POOLS 6. 回滚段池相关ROLLSEG_POOLS…...

编程日记 2025/9/8 20:23:06

MySql面试总结（一）

mysql中排序是怎么实现的？ MySQL 中的排序主要通过ORDER BY子句来实现，其底层实现方式有文件排序和索引排序两种，以下是具体介绍：通过ORDER BY子句实现排序这是 MySQL 中进行排序的基本方式，语法为SELECT column1, column2,... FROM table_name ORDER BY column_name…...

编程日记 2025/9/9 22:34:57

YOLOv5 + SE注意力机制：提升目标检测性能的实践

一、引言目标检测是计算机视觉领域的一个重要任务，广泛应用于自动驾驶、安防监控、工业检测等领域。YOLOv5作为YOLO系列的最新版本，以其高效性和准确性在实际应用中表现出色。然而，随着应用场景的复杂化，传统的卷积神经网络在处…...

编程日记 2025/8/31 2:21:52

第十四届蓝桥杯大赛软件赛国赛C/C++大学C组

A 【跑步计划——日期问题】-CSDN博客 B 【残缺的数字】-CSDN博客 C 题目代码 #include <bits/stdc.h> using namespace std;void change(int &x) {int sum 0, t x;while(t){sum t % 10;t / 10;}x - sum; } int main() {int n;cin >> n;int ans 0;…...

编程日记 2025/9/9 4:24:03

【备份】php项目处理跨域请求踩坑

这都是老生常谈的东西了。我还在踩坑，记录一下。我在项目入口明明写了如下代码： // 处理预检请求 (OPTIONS) if ($_SERVER[REQUEST_METHOD] OPTIONS) {header("Access-Control-Allow-Origin: https://xxx.vip");header("Access-Cont…...

编程日记 2025/9/12 18:40:02

编程题 - 汽水瓶【JavaScript/Node.js解法】

‌“学如逆水行舟，不进则退。”‌ ——《增广贤文》目录汽水瓶题目：解答分析：js代码解答 -ACM模式：代码通过：题解分析：简洁思路代码： 汽水瓶题目： 某商店规定：三个空…...

编程日记 2025/9/12 9:22:19

【考研】复试相关上机题目

文章目录 22机试回忆版1、判断燃气费描述输入格式输出格式输入样例输出样例 C o d e Code Code 2、统计闰年数量描述输入格式输出格式输入样例输出样例 C o d e Code Code 3、打印图形描述输入格式输出格式 C o d e Code Code 4、密文数据描述输入格式输出格式输入样例输出样例…...

编程日记 2025/9/4 23:00:56

HONOR荣耀MagicBook 15 2021款独显(BOD-WXX9,BDR-WFH9HN)原厂Win10系统

适用型号：【BOD-WXX9】 MagicBook 15 2021款 i7 独显 MX450 16GB512GB (BDR-WFE9HN) MagicBook 15 2021款 i5 独显 MX450 16GB512GB (BDR-WFH9HN) MagicBook 15 2021款 i5 集显 16GB512GB (BDR-WFH9HN) 链接：https://pan.baidu.com/s/1S6L57ADS18fnJZ1…...

编程日记 2025/9/8 14:37:33

微信小程序：完善购物车功能，购物车主页面展示，详细页面展示效果

一、效果图 1、主页面根据物品信息进行菜单分类，点击单项购物车图标添加至购物车，记录总购物车数量 2、购物车详情页根据主页面选择的项，根据后台查询展示到页面，可进行多选，数量加减等二、代码 1、主页面页…...

编程日记 2025/9/8 16:37:47

Spring Boot集成MyBatis访问MySQL：从项目搭建到基础数据库查询（基础入门）

Spring Boot集成MyBatis访问MySQL 一、引言在当今企业级应用开发中，Spring Boot、MyBatis与MySQL的组合凭借其高效性和灵活性，成为构建数据驱动型应用的首选方案。本文将带你从零开始搭建项目，掌握Spring Boot集成MyBatis的基础入门内容。…...

编程日记 2025/9/3 22:24:55

基于STM32的智能家居能源管理系统

1. 引言传统家庭能源管理存在能耗监控粗放、设备联动不足等问题，难以适应绿色低碳发展需求。本文设计了一款基于STM32的智能家居能源管理系统，通过多源能耗监测、负荷预测与优化调度技术，实现家庭能源的精细化管理与智能优化，提…...

编程日记 2025/9/8 12:57:28

OpenAI发布GPT-4.5：功能非常特殊，推理很贵

今天凌晨4点，OpenAI进行了在线技术直播，发布了最新模型GPT-4.5。 GPT-4.5与之前的模型相比，本次最大的亮点是加上了“情商”，这也是目前所有大模型最缺、最难的功能。此外，GPT-4.5 在SimpleQA上的测试数据显示&…...

编程日记 2025/9/10 0:11:50

DeepSeek开源周 Day04：从DualPipe聊聊大模型分布式训练的并行策略

DualPipe简介今天是DeepSeek开源周的第四天，官方开源了一种新型并行计算优化策略——DualPipe。其实大家阅读过Deepseek-V3技术报告的同学，对这个技术并不陌生。开源地址：https://github.com/deepseek-ai/DualPipe 核心亮点 DualPipe&…...

编程日记 2025/9/11 8:58:17

RabbitMQ系列（七）基本概念之Channel

RabbitMQ 中的 Channel（信道） 是客户端与 RabbitMQ 服务器通信的虚拟会话通道，其核心作用在于优化资源利用并提升消息处理效率。以下是其核心机制与功能的详细解析： 一、Channel 的核心定义虚拟通信链路 Channel 是建立在 TCP 连…...

编程日记 2025/9/10 9:43:50

LeetCode 热题 100_有效的括号（69_20_简单_C++）（栈；栈+哈希表（建立左右括号的对应关系））

LeetCode 热题 100_有效的括号（69_20） 题目描述：输入输出样例：题解：解题思路：思路一（栈）：思路二（栈哈希表（建立左右括号的对应关系）&a…...

编程日记 2025/9/9 14:19:10

c#-LINQ与lambda表达式学习笔记

https://blog.csdn.net/m0_56259289/article/details/144134122 static void Main(string[] args) //程序入口{int[] arr1 new int[] { 1, 2, 3, 4, 5, 6, 7 };int[] arr2 new int[] { 1, 2, 3, 4, 5, 6, 7 };var query1 from n in arr1 select n;var query2 from a in arr…...

编程日记 2025/9/10 10:56:29

MQ简介

1、同步通信

图片

2、异步通信

图片

RabbitMQ快速上手

基本介绍：

Producer和Consumer

Connection和Channel

Virtual host

Queue

Exchange

工作流程

AMQP

Java编写RabbitMQ生产者消费者

生产者

1.建立连接

2.开启信道

3.声明交换机

4.声明队列

5.发送消息

6.资源释放

生产者全部代码：

消费者

执行结果

相关文章：