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

RabbitMQ通信模式(Simplest)Python示例

news 来源：原创 2025/7/20 7:26:08

RabbitMQ通信模式-Python示例

0.RabbitMQ官网通信模式
1.Simplest(简单)模式
- 1.1 发送端
- 1.2 接收端

0.RabbitMQ官网通信模式

在这里插入图片描述

1.Simplest(简单)模式

1.1 发送端

# -*- coding: utf-8 -*-
"""
Author: xxx
date:   2025/5/19 11:30
Description:    Simaple简单模式，生产者简单的RabbitMQ消息队列（不安全，不能持久化）
"""import pika# RabbitMQ 服务器地址
rabbitmq_host = '192.168.120.19'
# RabbitMQ 服务器端口
rabbitmq_port = 5672
# RabbitMQ 用户名
rabbitmq_username = 'rabbitmq'
# RabbitMQ 密码
rabbitmq_password = 'rabbitmq@123'# 根据用户名和密码，创建凭证对象
credentials = pika.PlainCredentials(rabbitmq_username, rabbitmq_password)
# 创建连接参数对象，指定主机、端口、凭证等信息
connection = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_host,port=rabbitmq_port,credentials=credentials)
)
# 创建通道对象
channel = connection.channel()# 定义消息队列名称
queue_name = 'hello'
# 声明消息队列，如果没有队列会自动创建
channel.queue_declare(queue=queue_name
)# 定义消息内容
message = 'Hello, World!'
# 发布消息到消息队列，routing_key为队列名称，body为消息内容，properties为属性，其中delivery_mode为2表示持久化
channel.basic_publish(exchange='',routing_key=queue_name,body=message
)
print(" [x] Sent '{}'".format(message))# 关闭通道和连接
connection.close()

1.2 接收端

# -*- coding: utf-8 -*-
"""
Author: tanggaomeng
date:   2025/5/19 11:44
Description:    Simaple简单模式，消费者简单的RabbitMQ消息队列（不安全，不能持久化）
"""import pika# RabbitMQ 服务器地址
rabbitmq_host = '192.168.120.19'
# RabbitMQ 服务器端口
rabbitmq_port = 5672
# RabbitMQ 用户名
rabbitmq_username = 'rabbitmq'
# RabbitMQ 密码
rabbitmq_password = 'rabbitmq@123'# 根据用户名和密码，创建凭证对象
credentials = pika.PlainCredentials(rabbitmq_username, rabbitmq_password)
# 创建连接参数对象，指定主机、端口、凭证等信息
connection = pika.BlockingConnection(pika.ConnectionParameters(host=rabbitmq_host,port=rabbitmq_port,credentials=credentials)
)
# 创建通道对象
channel = connection.channel()# 定义消息队列名称
queue_name = 'hello'
# 声明消息队列，如果没有队列会自动创建
channel.queue_declare(queue=queue_name
)# 将ReceivedMessage添加到队列中，同时替换通道实现。
# 返回的结果，会返回到这里面，如果有兴趣可以点开basic_consume方法去看看源代码
# 订阅消息队列，设置自动应答（auto_ack=False），并指定回调函数
def callback(ch, method, properties, body):print(" [x] Received %r" % (body,))# 从服务器队列中消费
# no_ack=True ,是需要是否确定消息的处理了，告诉服务端
# no_ack=False ，默认是False，可以不写
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=False)print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()'''
注意：接收到处于死循环，一直在等待接收，发送一个数据，就收到一个数据
'''

基于上面的代码不做任何修改
把上面的消费者开N个就是想要的结果。
如下：
运行3个消费者，生产者生成的消息队列依次被接收者接收，每次只有一个消费者接收到信息，3个消费者接收顺序依次进行

在这里插入图片描述

参考：
https://www.rabbitmq.com/tutorials

RabbitMQ通信模式(Simplest)Python示例

RabbitMQ通信模式-Python示例 0.RabbitMQ官网通信模式1.Simplest(简单)模式1.1 发送端1.2 接收端 0.RabbitMQ官网通信模式 1.Simplest(简单)模式 1.1 发送端 # -*- coding: utf-8 -*- """ Author: xxx date: 2025/5/19 11:30 Description: Simaple简单模…...

编程日记 2025/7/20 7:26:08

游戏开发实战（一）：Python复刻「崩坏星穹铁道」嗷呜嗷呜事务所---源码级解析该小游戏背后的算法与设计模式【纯原创】

文章目录奇美拉项目游戏规则奇美拉(Chimeras)档案领队成员结果展示： 奇美拉项目由于项目工程较大，并且我打算把我的思考过程和实现过程中踩过的坑都分享一下，因此会分3-4篇博文详细讲解本项目。本文首先介绍下游戏规则并给出奇美拉档案。…...

编程日记 2025/7/20 7:07:32

力扣热题100之删除链表的倒数第N个节点

题目给你一个链表，删除链表的倒数第 n 个结点，并且返回链表的头结点。代码方法一将链表中的值放入列表中，然后删除倒数第n个值，再将剩下的数依次转化为链表 # Definition for singly-linked list. # class ListNode: # …...

编程日记 2025/7/20 7:12:31

OCframework编译Swift

建一个OC的framework： 需要对外暴露的OC文件，需要放到OC的.h文件中 framework中，OC类，调用framework中的Swift类： #import "WowAudioFocus/WowAudioFocus-Swift.h" //02 #import "{工程名}/{工程…...

编程日记 2025/7/20 6:50:25

【AI News | 20250519】每日AI进展

AI Repos 1、deepdrone DeepDrone是一款基于smolagents框架的无人机聊天代理，集成DroneKit实现无人机分析与操作。用户可通过自然语言聊天与无人机助手交互，实现飞行路径和传感器数据可视化、基于飞行时长的维护建议、任务规划以及真实的无人机控制&…...

编程日记 2025/7/20 7:14:48

分布式ID生成系统

代码地址: github mid 简介分布式 ID 生成系统是一个高性能、可靠的 ID 生成服务，支持两种模式：Snowflake（基于时间戳的内存生成）和 Segment（基于 MySQL 的号段分配）。系统采用双 Buffer 策略优化性能，集成 Prometheus 监控和 Zap 结构化日志，确保高可用性和可观测性…...

编程日记 2025/7/20 7:16:14

MAC常用操作整理

音量方法： 电脑键盘的右上角就有静音和不静音的按钮，还有调节音量的按钮，调节屏幕亮度的按钮切换输入法方法： 1.大写按键，2.function按键(fn), 3.control 空格键, 选择上一个输入法，4.controloption空格…...

编程日记 2025/7/20 6:55:06

【Canvas与图标】圆角方块蓝星CSS图标

【成图】 120*120的png图标大小图： 【代码】 <!DOCTYPE html> <html lang"utf-8"> <meta http-equiv"Content-Type" content"text/html; charsetutf-8"/> <head><title>圆角方块蓝星CSS Draft1</…...

编程日记 2025/7/14 5:45:09

易境通散货拼柜系统：提高货代企业货物配载效率

在国际物流代理运输领域，货物配载是整个供应链的核心环节，其优化对于提升整个供应链的效率至关重要。传统的配载管理方式往往依赖人工操作，不仅效率低下，还容易出现错误。面对多订单、多货主、多目的地的复杂场景，传统…...

编程日记 2025/7/4 13:44:25

[Spring Boot]整合Java Mail实现Outlook发送邮件

日常开发过程中，我们经常需要使用到邮件发送任务，比方说验证码的发送、日常信息的通知等。日常比较常用的邮件发送方包括：163、QQ等，本文主要讲解Outlook SMTP的开启方式、OutLook STARTTTL的配置、如何通过JavaMail来实现电子邮件的发送等。 Outlook作为微软提供的企业电子…...

编程日记 2025/7/20 7:13:43

【盈达科技】GEO优化实战策略

提升内容在生成式引擎中的可见性：实战策略随着生成式引擎（Generative Engines, GEs）的兴起，内容创作者面临着新的挑战和机遇。这些引擎通过整合和总结多源信息来提供精准且个性化的回答，正在迅速取代传统搜索引擎。为…...

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

HTTP 协议基础

本篇文章会从如下角度介绍 HTTP 协议： 原理与工作机制请求方法与状态码Header 与 Body 1、原理与工作机制 1.1 HTTP 是什么 HyperText Transfer Protocol，超文本传输协议，"超"表示扩展而非超级，即可以链接到其他文本…...

编程日记 2025/7/20 7:04:03

ros运行包，Ubuntu20.04成功运行LIO-SAM

zz:~/lio_sam_ws$ source devel/setup.bash zz:~/lio_sam_ws$ roslaunch lio_sam run.launch 创建包链接： 链接1：Ubuntu20.04成功运行LIO-SAM_ubuntu20.04运行liosam-CSDN博客链接2：ubuntu 20.04 ROS 编译和运行 lio-sam,并且导出PCD文件…...

编程日记 2025/7/20 7:14:48

Linux《自主Shell命令行解释器》

在上一篇的进程控制当中我们已经了解了进程退出、进程等待以及进程替换的相关概念，那么在了解了这些的概念之后接下来在本篇当中我们就可以结合之前我们学习的知识来实现一个自主的Shell命令行解释器，通过Shell的实现能让我们进一步的理解操作系统当中的…...

编程日记 2025/7/20 0:42:03

设置IDEA打开新项目使用JDK17

由于最近在学习Spring-AI，所以JDK8已经不适用了，但是每次创建新项目都还是JDK8，每次调来调去很麻烦把Projects和SDKs都调整为JDK17即可同时，Maven也要做些更改，主要是添加build标签 <build><plugins>&…...

编程日记 2025/7/20 7:17:50

Vue百日学习计划Day36-42天详细计划-Gemini版

总目标: 在 Day 36-42 理解组件化开发的思想，熟练掌握 Vue 组件的注册、Props、Events、v-model、Slots、Provide/Inject 等核心概念和实践，能够构建可复用和易于维护的组件结构。所需资源: Vue 3 官方文档 (组件基础): https://cn.vuejs.org/guide/es…...

编程日记 2025/7/20 7:13:43

Python对JSON数据操作

在Python中，对JSON数据进行增删改查及加载保存操作，主要通过内置的json模块实现。一、基础操作 1. 加载JSON数据 • 从文件加载使用json.load()读取JSON文件并转换为Python对象（字典/列表）： import json with open…...

编程日记 2025/7/20 7:20:21

upload靶场1-5关

网上的解析有一些题目对应不上，比如第五关说是空格点空格绕过 ，我这里就无法成功解析，但大小写绕过就成功了，慢慢会把后面的关卡也写出来这里建议开一台win7的虚拟机，在上面搭建靶场，可以省很多麻烦 …...

编程日记 2025/7/20 7:02:51

网络传输（ping命令，wget命令，curl命令），端口

网络传输： ping命令：检查指定的网络服务器是否是可联通状态语法：ping 【-c num】IP或主机名 -c：是检查的次数，不使用-c，将无限次持续检查 wget命令：wget是非交互式的文件下载器&#xff0…...

编程日记 2025/7/20 7:26:08

upload-labs靶场通关详解：第10关

一、分析源代码 $is_upload false; $msg null; if (isset($_POST[submit])) {if (file_exists(UPLOAD_PATH)) {$deny_ext array(".php",".php5",".php4",".php3",".php2",".html",".htm",".ph…...

编程日记 2025/7/20 7:07:31

深入解析`lsof`命令：查看系统中打开文件与进程信息

1、lsof的基本概念 lsof （List Open Files） 提供了一种方式来查看系统上哪些进程正在访问哪些文件，能够显示文件类型、文件名、文件描述符、所属进程等详细信息。在类Unix系统中，几乎所有的操作都与文件相关联，文件不…...

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

C++ 与 Python 内存分配策略对比

内存管理是编程中的一个核心概念，它直接影响程序的性能、稳定性和资源利用率。C 和 Python 作为两种广泛使用的编程语言，在内存分配和管理方面采用了截然不同的策略。 C 内存分配策略 C 赋予程序员对内存的精细控制能力，同时也带来了更大的…...

编程日记 2025/7/20 7:18:57

TB开拓者策略交易信号闪烁根因及解决方法

TB开拓者策略信号闪烁分析 TB开拓者策略交易信号闪烁根因 TB开拓者策略交易信号闪烁根因分析信号闪烁是交易策略开发中常见的问题，特别是在TB(TradeBlazer)开拓者等平台上。以下是信号闪烁的主要根因分析： 主要根因未来函数问题使用了包含未来信息…...

编程日记 2025/7/20 7:12:31

日语学习-日语知识点小记-构建基础-JLPT-N4阶段（24）：受身形

日语学习-日语知识点小记-构建基础-JLPT-N4阶段（24）：受身形 1、前言（1）情况说明（2）工程师的信仰2、知识点（1）うけみけい　受身形（2）復習（ふくしゅう）：3、单词（1）日语（2）日语片假名单词4、相近词练习5、单词辨析记录6、总结1、前言（1）情况说明自己在今…...

编程日记 2025/7/1 22:19:26

牛客网NC209794:使徒袭来

牛客网NC209794:使徒袭来题目背景问题分析数学建模设三位驾驶员的战斗力分别为 a, b, c已知条件：a b c n (n为输入的正整数)目标：求 a b c 的最小值解题思路根据算术-几何平均值不等式(AM-GM不等式)，对于任意正实数a, b, c&a…...

编程日记 2025/7/4 13:45:23

命令行登录 MySQL 报 Segmentation fault 故障解决

问题描述：对 mysql8.0.35 源码进行 make，由于一开始因为yum源问题少安装依赖库库，在链接时遇到错误 undefined reference to，后来安装了相关依赖库，再次 make 成功。于是将 mysqld 启动，再用 mysql -u roo…...

编程日记 2025/7/5 7:19:36

2025ICPC邀请赛南昌游记

滚榜时候队伍照片放的人家的闹麻了，手机举了半天。最后银牌700小几十罚时，rank60多点。参赛体验还行，队长是福建人，说感觉这个热度是主场作战哈哈哈哈。空调制冷确实不太行吧。 9s过A是啥，没见过，虽然…...

编程日记 2025/7/1 22:19:20

kotlin flow的写法

以下是 Android 开发中 Kotlin Flow 的常见使用模式和操作符的完整中文总结： 1. 基本 Flow 创建方式 // 从多个值创建 val flow1 flowOf(1, 2, 3)// 使用 flow 构建器 val flow2 flow {emit(1)delay(100)emit(2) }// 从集合创建 val flow3 listOf(1, 2, 3).asFl…...

编程日记 2025/7/7 21:05:52

springboot+mybatis或mybatisplus在进行%name%的前后模糊查询时如何放防止sql注入

在使用 Spring Boot 配合 MyBatis 或 MyBatis-Plus 进行数据库操作时，确保防止 SQL 注入是非常重要的。对于 %name% 样式的前后模糊查询，以下是几种有效的方法来防止 SQL 注入： 1. 使用 MyBatis 的 <if> 标签和 #{} 占位符 MyBatis 默…...

编程日记 2025/7/14 11:01:10

基于51单片机教室红外计数灯光控制—可蓝牙控制

基于51单片机智能教室灯光 （仿真＋程序＋原理图＋PCB＋设计报告） 功能介绍具体功能： 本系统由STC89C52单片机时钟芯片DS1302液晶屏LCD1602光敏电阻红外对管LED灯模块按键模块蓝牙模块构成具体…...

编程日记 2025/7/18 16:07:01

HTTPS、SSL证书是啥？网站“安全小锁”的入门科普

你有没有发现，浏览网页时，有些网站地址栏前面会出现一个小锁的图标🔒，而有些网站却没有？这个小锁其实代表着网站用了“HTTPS”，是比普通“HTTP”更安全的协议。今天，我们就来聊聊HTTPS、SSL证书…...

编程日记 2025/7/1 22:19:12

大模型备案中的安全考量：筑牢数字时代的安全防线

在数字化浪潮席卷全球的当下，大模型技术凭借强大的数据分析、模式识别与语言理解生成能力，成为推动产业变革、提升社会运转效率的关键力量。从智能客服降本增效，到医疗影像精准诊断，再到金融风险智能预测，大模型正重塑…...

编程日记 2025/7/17 18:37:42

Linux句柄数过多问题排查

以下是Linux句柄数过多问题的排查与解决方法整理： 一、检测句柄使用情况 1‌.查看系统限制‌ 单个进程限制：ulimit -n 系统级总限制：cat /proc/sys/fs/file-max 2‌.统计进程占用量‌ 查看指定进程：lsof -p <PID> | wc -…...

编程日记 2025/7/17 10:12:32

Python训练第三十天

DAY 30 模块和库的导入知识点回顾： 导入官方库的三种手段导入自定义库/模块的方式导入库/模块的核心逻辑：找到根目录（python解释器的目录和终端的目录不一致） 总结：导入包的核心就是找到目录，只有理解了py…...

编程日记 2025/7/1 22:19:05

Java资源管理与防止泄漏：从SeaTunnel源码看资源释放

资源管理是 Java 开发中常被忽视却至关重要的一环。本文从 SeaTunnel 案例出发，探讨 Java 中如何正确管理资源，防止资源泄漏。 SeaTunnel 中的一次修复 Apache SeaTunnel 项目中的 HiveSink 组件曾存在一个典型的资源泄漏隐患。修复前后的代码对比如下…...

编程日记 2025/7/1 22:19:03

Notepad++ 学习（三）使用python插件编写脚本：实现跳转指定标签页（自主研发）

目录一、先看成果二、安装Python Script插件三、配置Python脚本四、使用脚本跳转标签页方法一：通过菜单运行方法二：设置快捷键（推荐） 五、注意事项六、进阶使用官网地址： https://notepad-plus-plus.org/Python Scri…...

编程日记 2025/7/12 6:57:15

PYTHON训练营DAY30

库的导入一、导入整个 import 库二、从库中导入特征项 from 库 import XXX 三、非标准导入：导入整个库 from 库 import * 四、导入自定义的库 （一）项目创建一个打招呼的库 # greet.py def say_hello(name):return f"你好&a…...

编程日记 2025/7/1 22:18:59

Linux 文件(2)

文章目录 1. 文件描述符1.1 文件描述符是什么1.2 文件描述符如何分配 2 重定向2.1 输出重定向2.2 输入重定向2.3 使用dup2进行重定向 3. 文件、父子进程和进程替换 1. 文件描述符 1.1 文件描述符是什么什么是文件描述符呢？ 我们先来看之前所介绍的系统级别的文件…...

编程日记 2025/7/20 7:08:20

netcore项目使用winforms与blazor结合来开发如何按F12,可以调出chrome devtool工具辅助开发

就是像在开发网页那样，可以使用devtool工具辅助开发。可查看页面css，js等。我在网上看解决办法。没一个有用的。自己找了一个。不需要单独在页面写多余的代码我的program.cs中有服务注册代码增加 3行代码。 #if DEBUGservices.AddBlazorWebViewDevelo…...

编程日记 2025/7/19 1:43:25

CSS attr() 函数详解

attr() 是 CSS 中的一个函数，用于获取 HTML 元素的属性值并在样式中使用。虽然功能强大，但它的应用有一些限制和注意事项。基本语法 element::pseudo-element {property: attr(attribute-name); } 可用场景 1. 在伪元素的 content 属性中使用&#…...

编程日记 2025/7/13 18:17:18

人生如戏、戏如人生

今早，6：30起床给一家人弄早餐，然后听到了老公的一声大喊：”半小时了，你干什么了“，原来孩子说她在理书包，被老公骂了。最近几天，老公脾气变得很差，孩子每天都会被老公骂…...

编程日记 2025/7/1 22:18:51

Java迭代器知识点详解

在 Java 编程中，迭代器（Iterator）是一种用于遍历集合（如 List、Set、Map 等）元素的接口。它提供了一种统一的方式来访问集合中的元素，而无需暴露集合的内部结构。以下是关于 Java 迭代器的详细知识点&#…...

编程日记 2025/7/1 22:18:49

免费开放试乘体验！苏州金龙自动驾驶巴士即将上线阳澄数谷

近日，苏州自动驾驶巴士线路——阳澄数谷示范线正式上线，即日起向全民免费开放试乘体验！ 在苏州工业园区地铁3号线倪浜•阳澄数谷站外，一辆辆黑、白配色的小巴正在道路上有条不紊地行驶。与普通公交不同的是，小巴造型奇…...

编程日记 2025/7/1 22:18:46

Kotlin 协程

第一个协程程序协程是可暂停计算的一个实例。它在概念上类似于线程，因为它需要运行一个代码块，该代码块与其他代码并发运行。然而，协程并不绑定到任何特定的线程。它可以在一个线程中暂停执行，并在另一个线程中恢复执行。协程…...

编程日记 2025/7/19 9:00:49

MySQL函数触发：函数处理与触发器自动化应用

引言各位数据库爱好者们好！今天我们要探索MySQL中两个强大的自动化工具——函数和触发器 🚀。函数就像数据库中的"瑞士军刀"，能帮你高效处理各种数据；而触发器则是数据库的"自动感应器"，能在数据…...

编程日记 2025/7/1 23:42:54

数据可视化热图工具：Python实现CSV/XLS导入与EXE打包

在数据分析工作中，热图(Heatmap)是一种非常直观的可视化工具，能够清晰展示数据矩阵中的数值分布和相关性。本文将介绍如何使用Python构建一个支持CSV/XLS文件导入、热图生成并可打包为EXE的桌面应用程序。核心功能设计我们的热图工具将包含以下核心功能：支持CSV和Excel…...

编程日记 2025/7/1 23:42:53

CUDA Stream的进阶用法：流水线并行的资源竞争解决方案

点击 “AladdinEdu，同学们用得起的【H卡】算力平台”，H卡级别算力，按量计费，灵活弹性，顶级配置，学生专属优惠。引言：多任务推理场景的挑战 GPU在AI推理服务器的典型负载特征（并行模…...

编程日记 2025/7/1 23:42:51

Eclipse Java 开发调优：如何让 Eclipse 运行更快？

Eclipse Java 开发调优：如何让 Eclipse 运行更快？ 在 Java 开发领域，Eclipse 是一款被广泛使用的集成开发环境（IDE）。然而，随着项目的日益庞大和复杂，Eclipse 的运行速度可能会逐渐变慢&#x…...

编程日记 2025/7/1 23:42:49

大模型（1）——基本概念

文章目录一、大模型的定义与概念二、大模型的原理与技术核心三、大模型的应用领域四、市面上常用的大模型1. 生成类模型（文本/代码/图像）2. 理解类模型（文本/语义）3. 多模态模型4. 国产大模型五、总结与趋势一、大模型的定义与…...

编程日记 2025/7/4 17:32:56

MYSQL故障排查和环境优化

一、MySQL故障排查 1. 单实例常见故障 （1）连接失败类问题 ERROR 2002 (HY000): Cant connect to MySQL server 原因：MySQL未启动或端口被防火墙拦截。解决：启动MySQL服务（systemctl start mysqld）或开放…...

编程日记 2025/7/19 3:06:09

RabbitMQ通信模式-Python示例

0.RabbitMQ官网通信模式

1.Simplest(简单)模式

1.1 发送端

1.2 接收端

相关文章：