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

RabbitMQ实现生产者消费者

news 来源：原创 2025/7/19 21:27:02

一.启动MQ

注意管理员身份进入cmd才行,我这里是在本地安装的MQ,推荐使用虚拟机安装

二.思路

官方解释RabbitMQ结构:

自我理解RabbitMQ结构:

其实RabbitMQ的服务器就像邮局一样,我们的生产者和消费者对于这个服务器来说都是消费者,因为服务器都可以向两者发送消息

环境准备

导入依赖

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

建立生产者消费者

三.生产者代码

public class Consumer {public static void main(String[] args) throws IOException, TimeoutException {//1.建立连接ConnectionFactory connectionFactory=new ConnectionFactory();connectionFactory.setHost("127.0.0.1");//MQ服务器地址connectionFactory.setPort(5672);//端口connectionFactory.setUsername("guest");//账号connectionFactory.setPassword("guest");//密码connectionFactory.setVirtualHost("/");//虚拟主机名称Connection connection= connectionFactory.newConnection();//2开启信道Channel channel =connection.createChannel();//3生明队列channel.queueDeclare("hello",true,false,false,null);//4发送消息String message="hello,my name is RabbitMQ";channel.basicPublish("","hello",null,message.getBytes());System.out.println("成功发送消息");//5资源释放channel.close();connection.close();}
}

代码中方法解读解读:

四.消费者代码

public class Consumer {public static void main(String[] args) throws IOException, TimeoutException, InterruptedException {//1.建立连接ConnectionFactory connectionFactory=new ConnectionFactory();connectionFactory.setHost("127.0.0.1");//MQ服务器地址connectionFactory.setPort(5672);//端口connectionFactory.setUsername("guest");//账号connectionFactory.setPassword("guest");//密码connectionFactory.setVirtualHost("/");//虚拟主机名称Connection connection= connectionFactory.newConnection();//2开启信道Channel channel =connection.createChannel();//3生明队列channel.queueDeclare("hello",true,false,false,null);//4消费消息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("hello",true,consumer);//等待程序接受完毕大部分消息Thread.sleep(3000);//没有这条代码,将只接受MQ中一条消息//5资源释放channel.close();connection.close();}
}

读取了MQ中全部消息

RabbitMQ实现生产者消费者

一.启动MQ 注意管理员身份进入cmd才行,我这里是在本地安装的MQ,推荐使用虚拟机安装二.思路官方解释RabbitMQ结构: 自我理解RabbitMQ结构: 其实RabbitMQ的服务器就像邮局一样,我们的生产者和消费者对于这个服务器来说都是消费者,因为服务器都可以向两者发送消息环境准备 …...

编程日记 2025/7/19 21:27:02

main.c // main.c #include "sys.h" #include "ds18b20.h"int main(void){ uart_init(9600);delay_init();while(DS18B20_Init()) //DS18B20初始化 {printf("error");delay_ms(200);}while(1){printf("%4.2f\r\n",Get_Temp());}}ds18…...

编程日记 2025/7/15 5:43:22

期权懂|期权入门知识：开通50ETF期权需要什么条件？

锦鲤三三每日分享期权知识，帮助期权新手及时有效地掌握即市趋势与新资讯！ 开通50ETF期权需要什么条件？ 一、基本资格要求 （1）年龄限制：投资者必须年满18周岁，具备完全民事行为能力。 &#…...

编程日记 2025/7/19 20:20:30

Linux day 1129

家人们今天继续学习Linux，ok话不多说一起去看看吧三.Linux常用命令 3.1 Linux命令体验 3.1.1 常用命令演示在这一部分中，我们主要介绍几个常用的命令，让大家快速感受以下 Linux 指令的操作方式。主要包含以下几个指令： ls命…...

编程日记 2025/7/14 20:51:40

智能家居体验大变革博联 AI 方案让智能不再繁琐

1. 全球AI技术发展背景及智能家居市场趋势人工智能（AI）技术的飞速发展正在推动全球各行业的数字化转型。国际电信联盟与德勤联合发布《人工智能向善影响》报告指出，全球94%的商界领袖认为，人工智能技术对于其企业在未来5年内的发…...

编程日记 2025/7/15 22:48:30

git使用

git初始化 git init 指定要添加的文件 git add [文件名1] [文件名2] [文件名3] // 添加指定文件 git add . // 添加当前目录所有文件将文件提交到本地仓库 git commit -m "备注信息" 添加远程仓库 git remote add origin [远程仓库地址] git remote -v // …...

编程日记 2025/7/14 14:02:29

嵌入科技的温情

嵌入式世界，是一个微小却无比精妙的宇宙。晶体管之间的脉动，仿佛是心跳的回响；代码中跳跃的逻辑，犹如人生中不可预知的转折。每一个嵌入式系统，都像是一个看不见的灵魂，将冰冷的机器唤醒，为生活…...

编程日记 2025/7/18 19:30:13

python利用selenium实现大麦网抢票

大麦网（damai.cn）是中国领先的现场娱乐票务平台，涵盖演唱会、音乐会、话剧、歌剧、体育赛事等多种门票销售。由于其平台上经常会有热门演出，抢票成为许多用户关注的焦点。然而，由于票务资源的有限性，以及大…...

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

PS等软件学习笔记

目录一、ps基础操作快捷键 1、快速打开图片 2、屏幕画布变大变小 3、移动画布 4、CTRL回车，快速完成更改 5、还原 6、创建画布，CTRLN 7、复制图层，CTRLJ 8、一段文字行间距调整 9、反向选择，CTRLSHIFTI 10、抠图二、…...

编程日记 2025/7/19 8:28:14

vue3学习笔记（9）-pinia、storeToRefs、getters

1.新的集中式状态（数据）管理库，redux vuex pinia 搭建 2.ref拆包如果在reactive里面定义ref，则打印c时，无需.value 他自动拆包，如果直接在外面定义的ref则需要.value,他没有拆包 3.pinia存储读取数据存…...

编程日记 2025/7/19 21:18:52

数据库基础知识---以MySQL为例

一、什么是MySQL 数据保存在不同的表中，而不是将所有数据放在一个大仓库内二、特点开源--免费下载跨平台--可以在多个操作系统进行运行性能好--可以出来大量数据简单--安装配置简单支持多种编程语言--可以与多种编程语言进行无缝集成三、分类 DDL--数据定义…...

编程日记 2025/7/19 21:17:37

013-spring的注解整合第三方框架

给spring的ioc容器中添加对象常用这3个方法...

编程日记 2025/7/14 13:56:36

使用ForceBindIP绑定应用到指定IP

前言使用ForceBindIP工具，用户可以轻松地将特定应用程序绑定到指定的IP地址，从而确保应用程序的网络连接通过指定的网络适配器进行。通过在命令提示符下运行ForceBindIP并指定IP地址和应用程序的完整路径，用户能够控制应用程序的网络流量&a…...

编程日记 2025/7/19 21:22:14

python-LeetCode-两数之和

1. 两数之和 - 力扣（LeetCode） class Solution:def twoSum(self, nums: List[int], target: int) -> List[int]:# 创建一个哈希表用于存储值和索引num_to_index {}for i, num in enumerate(nums):# 计算目标值需要的补数complement target - num# 如…...

编程日记 2025/7/16 13:40:37

项目开发实践——基于SpringBoot+Vue3实现的在线考试系统(四)

文章目录一、管理员角色功能实现1、添加教师功能实现1.1 页面设计1.2 前端功能实现1.3 后端功能实现1.4 效果展示2、教师管理功能实现2.1 页面设计2.2 前端功能实现2.3 后端功能实现2.3.1 后端查询接口实现2.3.2 后端编辑接口实现2.3.3 后端删除接口实现2.4 效果展示二、代码下…...

编程日记 2025/7/15 1:10:28

大语言模型的token和向量

现在大语言模型火了，像 ChatGPT 什么的，能回答问题、写文章，。但它们为啥这么聪明呢？这就和向量、Token 有关系。那怎么通过向量、Token来理解我们的问题呢。看完这篇文章就知道了 token Token 就像是语言里的小积木&#xff0c…...

编程日记 2025/7/18 22:40:02

Hyperledger Fabric有那些核心技术，和其他区块链对比Hyperledger Fabric有那些优势

Hyperledger Fabric是一个模块化、权限化的企业级区块链平台，与比特币、以太坊等公有链相比，Fabric主要为私有链或联盟链设计，适用于企业应用。它包含多项核心技术，使其在企业级区块链应用中具有独特优势。以下是Fabric的核心技术…...

编程日记 2025/7/16 10:35:31

ThinkPHP 8高效构建Web应用-第一个简单的MVC应用示例

【图书介绍】《ThinkPHP 8高效构建Web应用》-CSDN博客《2025新书 ThinkPHP 8高效构建Web应用编程与应用开发丛书夏磊清华大学出版社教材书籍 9787302678236 ThinkPHP 8高效构建Web应用》【摘要书评试读】- 京东图书使用VS Code开发ThinkPHP项目-CSDN博客我们先实现一…...

编程日记 2025/7/19 17:04:49

【Goland】怎么执行 go mod download

1、终端的执行 go mod tidy 2、终端执行不行的话，就可以通过右击go.mod文件来执行； 3、也可以按住Ctrl点击这个包安装；...

编程日记 2025/7/15 22:10:34

SpringBoot入门案例

目录一、SpringBoot入门 1. Spring Boot 简介（脚手架） 2. 微服务微服务优点： 微服务缺点： 3. 环境准备 3.1 spring boot项目的创建 3.2 导入spring boot相关的依赖 3.5 编写主程序 3.4 编写相关的controller、service…...

编程日记 2025/7/16 5:17:05

自定义 Celery的logging模块

为什么需要自定义 Celery 日志默认的 Celery 日志配置虽然满足基本需求，但在以下情况下可能需要进行自定义： 支持日志滚动：原生celery不支持日志滚动。更详细的日志信息：需要包含更多上下文信息，以便更好地理解任务…...

编程日记 2025/7/18 1:12:00

docker-开源nocodb，使用已有数据库

使用已有数据库创建本地数据库数据库：nocodb 用户：nocodb 密码：xxxxxx修改docker-compose.yml 默认网关的 IP 地址是 172.17.0.1（适用于 bridge 网络模式）version: "2.1" services:nocodb:environment:…...

编程日记 2025/7/16 5:37:15

【UE5】UnrealEngine源码构建1：tag为5.3.2源码clone

fatal: fetch-pack: invalid index-pack output clone unreal 速度很快，但是很容易失败Cloning into UnrealEngine... remote: Enumerating objects: 6511087, done. remote: Counting objects: 100% (196/196), done. remote: Compressing objects: 100% (50/50), done. erro…...

编程日记 2025/6/28 14:37:33

RoboMIND：多体现基准机器人操纵的智能规范数据

编程日记 2025/7/14 12:05:08

FPGA自学之路：到底有多崎岖？

FPGA，即现场可编程门阵列，被誉为硬件世界的“瑞士军刀”，其灵活性和可编程性让无数开发者为之倾倒。但谈及FPGA的学习难度，不少人望而却步。那么，FPGA自学之路到底有多崎岖呢？ 几座大山那么高？…...

编程日记 2025/7/16 1:45:41

讲一个自己写的 excel 转 html 的 java 工具

由来这是一个从开发需求中诞生的工具，在工作中因为有一个 excel 转 html 的任务，又没找到一个专门做这方面的工具（其他工具几乎都是简单的转换，无法还原 excel 样式，而且转换的宽高有点儿差距）&#xff0…...

编程日记 2025/7/15 14:49:44

打破视障壁垒，百度文心快码无障碍版本助力视障IT从业者就业无“碍”

有AI无碍钟科：被黑暗卡住的开发梦提起视障群体的就业，绝大部分人可能只能想到盲人按摩。但你知道吗？视障人士也能写代码。钟科，一个曾经“被黑暗困住”的人，他的世界，因为一场突如其来的疾病&#xff0c…...

编程日记 2025/7/14 13:53:02

爆改RagFlow

爆改RagFlow 一、Rag理论概述二、Ragflow解析参数说明三、♥ RagFlow源码解析核心代码流程梳理1、OCR识别2、版面分析3、parser功能3.1 PdfParser3.1.1 首先，初始化3.1.2 **pdf转图片** [来自工业界的知识库 RAG 服务(二)，RagFlow 源码全流程深度解析](h…...

编程日记 2025/7/19 13:29:13

Unity 使用UGUI制作卷轴开启关闭效果

视频效果代码 using UnityEngine.UI; using System.Collections; using System.Collections.Generic; using UnityEngine; using DG.Tweening; using DG.Tweening.Core; using DG.Tweening.Plugins.Options;public class JuanZhou : MonoBehaviour {[SerializeField]private …...

编程日记 2025/7/18 19:30:09