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

RabbitMQ的基本使用

news 来源：原创 2025/7/18 23:44:13

RabbitMQ 是一个非常流行的消息中间件，用于实现生产者与消费者之间的异步通信。它基于 AMQP 协议（高级消息队列协议），支持多种编程语言和平台。

以下是 RabbitMQ 的基本使用说明，包括安装、核心概念、基本操作和 Python 的简单示例。

---

一、RabbitMQ 核心概念

在使用 RabbitMQ 之前，理解以下基本概念是非常重要的：

  1. Producer（生产者）：
    • 消息的发送方，负责将消息发送到 RabbitMQ。
  2. Queue（队列）：
    • 消息的存储位置，RabbitMQ 内部的消息队列，用于存储待处理的消息。
  3. Consumer（消费者）：
    • 消息的接收方，从队列中取出消息进行处理。
  4. Exchange（交换机）：
    • 生产者发送的消息并不是直接发送到队列，而是先发送到交换机，由交换机根据路由规则将消息分发到队列。
  5. Binding（绑定）：
    • 用于将交换机和队列关联起来，并指定路由规则。
  6. Routing Key（路由键）：
    • 消息的路由规则，用于决定消息应该被发送到哪个队列。
  7. Acknowledgment（确认）：
    • 消费者在处理完消息后，向 RabbitMQ 确认消息已被处理，RabbitMQ 会将其从队列中删除。

二、RabbitMQ 的基本使用

1. 安装 RabbitMQ

RabbitMQ 是基于 Erlang 的，因此需要先安装 Erlang，然后再安装 RabbitMQ。

在 Linux 上安装 RabbitMQ

Language:bash

bash
# 安装 Erlang
sudo apt update
sudo apt install -y erlang# 安装 RabbitMQ
sudo apt install -y rabbitmq-server# 启动 RabbitMQ 服务
sudo systemctl start rabbitmq-server# 检查 RabbitMQ 服务状态
sudo systemctl status rabbitmq-server
在 Windows 上安装 RabbitMQ
  1. 下载并安装 Erlang：Erlang 官方下载页面。
  2. 下载并安装 RabbitMQ：RabbitMQ 官方下载页面。
  3. 安装完成后，启动 RabbitMQ 服务。

2. 启用 RabbitMQ 管理插件

RabbitMQ 提供了一个 Web 管理界面，可以用来管理队列、交换机和消息。

Language:bash

bash
# 启用管理插件
sudo rabbitmq-plugins enable rabbitmq_management# 默认管理界面地址：http://localhost:15672
# 默认用户名和密码：guest / guest

---

三、RabbitMQ 的基本操作

1. 创建用户和虚拟主机

RabbitMQ 使用虚拟主机（Virtual Host）来隔离不同的消息队列。

创建用户

Language:bash

bash
# 添加用户
sudo rabbitmqctl add_user username password# 设置用户权限
sudo rabbitmqctl set_permissions -p / username ".*" ".*" ".*"

创建虚拟主机

Language:bash

bash
# 添加虚拟主机
sudo rabbitmqctl add_vhost my_vhost# 将用户与虚拟主机绑定
sudo rabbitmqctl set_permissions -p my_vhost username ".*" ".*" ".*"

---

四、使用 Python 操作 RabbitMQ

1. 安装依赖

在 Python 中，使用 pika 库与 RabbitMQ 通信。安装方法：

Language:bash
pip install pika

2. 基本生产者和消费者示例

以下是一个简单的生产者和消费者示例：

生产者（Producer）

Language:python

python
import pika# 连接到 RabbitMQ 服务
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()# 声明队列（如果队列不存在，会自动创建）
channel.queue_declare(queue='hello')# 发送消息
message = "Hello RabbitMQ!"
channel.basic_publish(exchange='', routing_key='hello', body=message)print(f" [x] Sent '{message}'")# 关闭连接
connection.close()
消费者（Consumer）

Language:python

python
import pika# 连接到 RabbitMQ 服务
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()# 声明队列（需与生产者的队列名称一致）
channel.queue_declare(queue='hello')# 回调函数，处理接收到的消息
def callback(ch, method, properties, body):print(f" [x] Received {body}")# 订阅队列，注册回调函数
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

运行步骤：

  1. 先启动消费者代码，等待消息。
  2. 再启动生产者代码，发送消息。
  3. 消费者会接收到生产者发送的消息，并在控制台打印。

3. 使用交换机（Exchange）和路由键（Routing Key）

RabbitMQ 的交换机类型有以下几种：

  1. Direct：通过路由键将消息发送到指定队列。
  2. Fanout：将消息广播到所有绑定的队列。
  3. Topic：通过模式匹配的路由键将消息发送到队列。
  4. Headers：根据消息头属性路由消息。

以下是使用 Direct 类型交换机的示例：

生产者（使用 Direct 交换机）

Language:python

python
import pika# 连接到 RabbitMQ 服务
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()# 声明交换机
channel.exchange_declare(exchange='direct_logs', exchange_type='direct')# 发送消息
routing_key = 'info'  # 路由键
message = "This is an info message"
channel.basic_publish(exchange='direct_logs', routing_key=routing_key, body=message)print(f" [x] Sent '{message}' with routing key '{routing_key}'")# 关闭连接
connection.close()
消费者（使用 Direct 交换机）

Language:python

python
import pika# 连接到 RabbitMQ 服务
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()# 声明交换机
channel.exchange_declare(exchange='direct_logs', exchange_type='direct')# 创建一个临时队列
result = channel.queue_declare(queue='', exclusive=True)
queue_name = result.method.queue# 绑定队列到交换机，指定路由键
routing_key = 'info'
channel.queue_bind(exchange='direct_logs', queue=queue_name, routing_key=routing_key)print(' [*] Waiting for messages. To exit press CTRL+C')# 回调函数
def callback(ch, method, properties, body):print(f" [x] Received {body}")# 开始消费
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)
channel.start_consuming()

---

五、总结

  1. 基本流程：

    • 生产者发送消息到交换机。
    • 交换机根据路由规则将消息分发到队列。
    • 消费者从队列中取出消息进行处理。

  2. 常用工具：

    • pika 是 Python 操作 RabbitMQ 的标准库。
    • RabbitMQ 管理界面（http://localhost:15672）可以用于监控队列和交换机。

  3. RabbitMQ 的高级功能：

    • 消息持久化（Durable Queues）。
    • 消息确认（Acknowledge）。
    • 死信队列（Dead Letter Queue）。
    • 优先级队列（Priority Queues）。

希望这份指南能帮你快速上手 RabbitMQ！如果还有其他问题，可以随时提问。

相关文章：

RabbitMQ的基本使用

RabbitMQ 是一个非常流行的消息中间件，用于实现生产者与消费者之间的异步通信。它基于 AMQP 协议（高级消息队列协议），支持多种编程语言和平台。 以下是 RabbitMQ 的基本使用说明，包括安装、核心概念、基本操作和 Pyth…...

编程日记 2025/7/18 23:44:13

CSS专题之常见布局

前言 石匠敲击石头的第 13 次 作为一名前端开发，在日常开发中，写页面是必不可少的工作，但有时候发现很多的页面结构都是类似的，所以打算写一篇文章来梳理一下日常开发中常见的布局，如果哪里写的有问题欢迎指出。 单列…...

编程日记 2025/7/18 23:43:15

CentOS 7连接公司网络配置指南

在物理主机上安装了一个CentOS 7，需要连接公司的网络，但是公司的网络需要输入用户名密码才能连接 解决方案 需要 同时设置 wifi-sec.key-mgmt 和 802-1x 参数。以下是分步操作： 1. 创建基础 Wi-Fi 连接 sudo nmcli con add con-name &quo…...

编程日记 2025/7/18 23:42:09

RustDesk CentOS自建中继节点

一、需开放端口 TCP: 21115, 21116, 21117, 21118, 21119 UDP: 21116 二、安装docker 1.使用 root 权限登录 CentOS。确保 yum 包更新到最新 yum update 2. 卸载旧版本 yum remove docker 3. 安装 Docker 所需依赖 yum -y install yum-utils device-mapper-persistent-d…...

编程日记 2025/7/18 23:41:22

CentOS 7上部署BIND9 DNS服务器指南

场景假设： 我们要为内部网络 192.168.1.0/24 搭建一个权威 DNS 服务器。 域名：mylab.localDNS 服务器 IP：192.168.1.10我们将配置正向解析 (hostname -> IP) 和反向解析 (IP -> hostname)。 一、安装 BIND9 更新系统并安装 BIND 及工…...

编程日记 2025/7/18 23:20:16

面试突击：消息中间件之RabbitMQ

一：你们项目中哪里用到了RabbitMQ ? 难易程度：☆☆☆ 出现频率：☆☆☆☆ 我们项目中很多地方都使用了RabbitMQ , RabbitMQ 是我们项目中服务通信的主要方式之一 , 我们项目中服务通信主要有两种方式实现 : 通过Feign实现服务调用通过MQ实现服…...

编程日记 2025/7/18 23:21:31

基于 ESP32 与 AWS 全托管服务的 IoT 架构：MQTT + WebSocket 实现设备-云-APP 高效互联

目录 一、总体架构图 二、设备端（ESP32）低功耗设计（适配 AWS IoT） 1.MQTT 设置（ESP32 连接 AWS IoT Core） 2.低功耗策略总结（ESP32） 三、云端架构（基于 AWS Serverless + IoT Core） 1.AWS IoT Core 接入 2.云端 → APP：WebSocket 推送方案 流程： 3.数据存…...

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

将 /dev/vdb1 的空间全部合并到 /dev/mapper/centos-root（即扩展 CentOS 的根分区）

要将 /dev/vdb1 的 1TB 空间合并到 /dev/mapper/centos-root（即扩展 CentOS 的根分区），可以采用 LVM（逻辑卷管理） 的方式。以下是详细步骤： 步骤 1：检查当前磁盘和 LVM 情况 1.1 确认 /dev/vdb…...

编程日记 2025/7/18 23:22:32

CentOS Stream安装MinIO教程

1. 下载 MinIO 二进制文件 # 进入 MinIO 安装目录 sudo cd /usr/local/bin/# 下载 MinIO 二进制文件（替换为最新版本链接） wget https://dl.min.io/server/minio/release/linux-amd64/minio chmod x minio2. 创建专用用户和存储目录 # 创建 minio 用户…...

编程日记 2025/7/18 23:16:09

游戏引擎学习第299天:改进排序键 第二部分

回顾并为当天内容做准备 我们会现场编写完整的游戏代码。回顾上周发现自己对游戏中正确的排序规则并没有清晰的理解。主要原因是我们更擅长三维游戏开发，缺乏二维游戏和二维游戏技术的经验，对于二维精灵排序、模拟三维效果的最佳方案等没有太多技巧和经…...

编程日记 2025/7/18 9:25:12

设计模式----软考中级软件设计师（自用学习笔记）

目录 1、设计模式的要素 2、设计模式的分类 3、简单工厂模式 4、工厂方法 5、抽象工厂 6、生成器 7、原型 8、单例模式 9、适配器 10、桥接 11、组合模式 12、装饰 13、外观 14、享元 15、代理 16、责任链 17、命令 18、解释器 19、迭代器 20、中介者 21、…...

编程日记 2025/7/12 21:12:58

uniapp如何设置uni.request可变请求ip地址

文章目录 简介方法一：直接在请求URL中嵌入变量方法二：使用全局变量方法三：使用环境变量方法四：服务端配置方法五：使用配置文件（如config.js）:总结 简介 在uni-app中，uni.request 用…...

编程日记 2025/7/18 23:08:10

Centos上搭建 OpenResty

一、OpenResty简介 OpenResty 是基于 Nginx 的扩展平台，完全兼容 Nginx 的核心功能（如 HTTP 服务和反向代理），同时通过内嵌 LuaJIT 支持，允许开发者用 Lua 脚本灵活扩展业务逻辑。它简化了动态逻辑的实现。 二、安装…...

编程日记 2025/7/18 23:38:24

Kotlin与物联网（IoT）：Android Things开发探索

在物联网（IoT）领域，Kotlin 凭借其简洁性、安全性和与 Java 生态的无缝兼容性，逐渐成为 Android Things 开发的有力工具。尽管 Google 已于 2022 年宣布停止对 Android Things 的官方支持，但其技术思想仍值得探索&#…...

编程日记 2025/7/18 23:21:31

WIFI信号状态信息 CSI 深度学习篇之CNN（Python）

本博客是一篇非新手导向的CNN处理CSI图像帧的教程，基于tensorflow框架构建CNN模型进行训练，训练对象依然是前述博客中所提到的CSI图像帧（500 x 90 x 1）。代码里用到了深度可分离卷积，这种结构在减少计算量和参数数量方…...

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

深度学习实战 04：卷积神经网络之 VGG16 复现三（训练）

在后续的系列文章中，我们将逐步深入探讨 VGG16 相关的核心内容，具体涵盖以下几个方面： 卷积原理篇：详细剖析 VGG 的 “堆叠小卷积核” 设计理念，深入解读为何 332 卷积操作等效于 55 卷积，以及 333 卷积操作…...

编程日记 2025/7/18 23:29:36

欧拉系统离线部署docker

https://www.cnblogs.com/hsh96/p/18150538 Docker 离线安装指南 本文介绍了如何在 Linux 系统上进行 Docker 的离线安装。首先，确保欧拉系统安装的是server版本，否则没有tar工具。 您需要下载 Docker 的离线安装包。您可以从以下链接获取所需的安装包&a…...

编程日记 2025/7/18 23:03:59

Java 中 final 与 static 的区别

Java 中 final 与 static 的区别 在 Java 中，final 和 static 是两个不同的关键字，它们的核心作用和不可变性特性有本质区别： 一、final 的核心作用 1. 变量（不可变引用） 不可重新赋值：final 修饰的变量…...

编程日记 2025/7/18 23:03:58

多模态实时交互边界的高效语音语言模型 VITA-Audio 介绍

介绍 VITA-Audio是由Zuwei Long等研究者提出的端到端大型语音语言模型，其核心目标是通过跨模态令牌生成技术，解决传统语音交互系统中首音频令牌生成延迟高的问题。该模型的创新点主要体现在： 低延迟：VITA-Audio 是首个能够在初次…...

编程日记 2025/7/18 23:13:09

LLM | 论文精读 | NAACL 2025 | Clarify When Necessary：教语言模型何时该“问一句”再答！

🔍 解读 NAACL 2025 重磅论文《Clarify When Necessary》：教语言模型何时该“问一句”再答！ 🧩 一、现实问题：大模型“看不懂装懂”有多危险？ 我们每天用的 ChatGPT、Claude 等大型语言模型（LL…...

编程日记 2025/7/18 23:04:49

MySQL 8.0 OCP 英文题库解析（七）

Oracle 为庆祝 MySQL 30 周年，截止到 2025.07.31 之前。所有人均可以免费考取原价245美元的MySQL OCP 认证。 从今天开始，将英文题库免费公布出来，并进行解析，帮助大家在一个月之内轻松通过OCP认证。 本期公布试题51~60 试题51:…...

编程日记 2025/7/18 23:03:58

深度解析Vue项目Webpack打包分包策略 从基础配置到高级优化，全面掌握性能优化核心技巧

深度解析Vue项目Webpack打包分包策略 从基础配置到高级优化，全面掌握性能优化核心技巧 一、分包核心价值与基本原理 1.1 为什么需要分包 首屏加载优化：减少主包体积，提升TTI（Time to Interactive）缓存利用率提升&am…...

编程日记 2025/7/18 23:17:09

MySQL——基本查询内置函数

目录 CRUD Create Retrieve where order by limit Update Delete 去重操作 聚合函数 聚合统计 内置函数 日期函数 字符函数 数学函数 其它函数 实战OJ 批量插入数据 找出所有员工当前薪水salary情况 查找最晚入职员工的所有信息 查找入职员工时间升序排…...

编程日记 2025/7/18 23:24:56

实现图片自动压缩算法，canvas压缩图片方法

背景： 在使用某些支持webgl的图形库（eg：PIXI.js，fabric.js）场景中，如果加载的纹理超过webgl可处理的最大纹理限制，会导致渲染的纹理缺失，甚至无法显示。 方案 实现图片自动压缩算…...

编程日记 2025/7/14 3:57:05

零基础设计模式——创建型模式 - 单例模式

第二部分：创建型模式 - 单例模式 (Singleton Pattern) 欢迎来到创建型模式的第一站——单例模式！这是最简单也最常用的设计模式之一。 核心思想：关注对象的创建过程，将对象的创建与使用分离，降低系统的耦合度。 单例…...

编程日记 2025/7/15 5:54:12

数据挖掘：从数据堆里“淘金”，你的数据价值被挖掘了吗？

数据挖掘：从数据堆里“淘金”，你的数据价值被挖掘了吗？ 在这个数据爆炸的时代，我们每天都在产生海量信息：社交媒体上的点赞、网购时的浏览记录，甚至是健身手环记录下的步数。这些数据本身可能看似杂乱无章…...

编程日记 2025/7/13 8:46:29

k8s1.27版本集群部署minio分布式

需求： 1.创建4个pv，一个pv一个minio-pod。使用sts动态分配pvc(根据存储类找到pv)。----持久化 2.暴露minio的9001端口。（nodeport）----管理界面 镜像：minio/minio:RELEASE.2023-03-20T20-16-18Z--->换国内源 说明…...

编程日记 2025/6/29 0:48:41

雷军：芯片，手机，平板，SUV一起发

大家好，我是小悟。 5月19日，雷军在微博上宣布，5月22日晚7点将举办小米战略新品发布会。 这场被官方称为“人车家全生态”战略升级的重要活动，一口气带来了小米手机SoC芯片“玄戒O1”、旗舰手机小米15S Pro、小米平板7 Ultra&…...

编程日记 2025/7/16 8:04:03

使用Dockerfile构建含私有Maven仓库依赖包的Java容器

背景 需要用JDBC方式访问ArgoDB星环提供了ArgoDB jar包应用将以Container的方式运行我希望打包成镜像之后&#xff0c;镜像启动就能测试连接是否成功连接URL串需要能够传递进去 失败的方案一&#xff1a;本地文件导入POM pom.xml 配置本地路径 <dependency><groupI…...

编程日记 2025/7/14 19:23:33

AI指令模板综述（Prompt Review）

文章目录 DeepSeek DeepSeek 参考&#xff1a;DeepSeek学术指令大全 找到有价值的研究方向 "作为我的学术研究助手&#xff0c;你需要基于以下要求为我生成5个具有学术价值的创新选题&#xff1a; 请聚焦于[具体研究领域&#xff0c;如’社交媒体用户行为’或’深度学习…...

编程日记 2025/7/16 16:58:47

软件架构之-论分布式架构设计及其实现

论分布式架构设计及其实现 摘要正文 摘要 2023年2月&#xff0c;本人所在集团公司承接了长三角地区某省渔船图纸电子化审查项目开发&#xff0c;该项目旨在为长三角地区渔船建造设计院、渔船审图机构提供一个便捷化的服务平台。在次项目中&#xff0c;我作为项目成员参与了整个…...

编程日记 2025/7/15 17:08:16

零售EDI：Belk Stores EDI需求分析

Belk Stores 成立于 1888 年&#xff0c;是美国历史最悠久的家族百货连锁品牌之一&#xff0c;总部位于北卡罗来纳州夏洛特市。作为美国东南部领先的零售企业&#xff0c;Belk 在16个州拥有近300家门店&#xff0c;主要经营服装、鞋履、美妆、家居用品等多个品类&#xff0c;服…...

编程日记 2025/7/14 21:51:59

LangChain4j入门（六）整合提示词（Prompt）

前言 提示词&#xff08;Prompt&#xff09;是用户输入给AI模型的一段文字或指令&#xff0c;用于引导模型生成特定类型的内容。通过提示词&#xff0c;用户可以告诉AI“做什么”、 “如何做”以及“输出格式”&#xff0c;从而在满足需求的同时最大程度减少无关信息的生成。有…...

编程日记 2025/7/13 21:50:45

【HarmonyOS 5】金融应用开发鸿蒙组件实践

【HarmonyOS 5】金融应用开发鸿蒙组件实践 一、鸿蒙生态观察 2024 年 1 月 18 日&#xff1a; 发布 原生鸿蒙操作系统星河版&#xff0c;面向开发者开放申请&#xff0c;余承东宣布鸿蒙生态设备数达 8 亿台&#xff1b;建设银行、邮储银行等完成鸿蒙原生应用 Beta 版本开发。 …...

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

cv2.VideoWriter_fourcc(*‘mp4v‘)生成的视频无法在浏览器展

看这个博主的博客&#xff0c;跟我碰到的问题的一致&#xff0c;都是使用AVC1写视频时报编码器不存在的异常&#xff0c;手动编译opencv-python或者使用conda install -c conda-forge opencv安装依赖即可。 博主博客&#xff1a;Python OpenCV生成视频无法浏览器播放问题说明及…...

编程日记 2025/7/16 5:00:49

MD编辑器推荐【Obsidian】含下载安装和实用教程

为什么推荐 Obsidian &#xff1f; 免费 &#xff08;Typora 开始收费了&#xff09;Typora 实现的功能&#xff0c;它都有&#xff01;代码块可一键复制 文件目录支持文件夹 大纲支持折叠、搜索 特色功能 – 白板 特色功能 – 关系图谱 下载 https://pan.baidu.com/s/1I1fSly…...

编程日记 2025/7/16 1:36:58

新书速览|GraphPad Prism图表可视化与统计数据分析:视频教学版

《GraphPad Prism图表可视化与统计数据分析:视频教学版 》 本书内容 《GraphPad Prism图表可视化与统计数据分析:视频教学版 》以GraphPad Prism 10为平台&#xff0c;讲述统计分析软件GraphPad Prism的具体应用方法。在介绍《GraphPad Prism图表可视化与统计数据分析:视频教学…...

编程日记 2025/7/15 11:54:40

波峰波谷策略

这是一个基于数据分布的峰度（kurtosis）和偏度（skewness）的交易策略。 当数据呈现趋势性，并且潜在趋势为正时，我们做多。 当数据呈现趋势性，并且潜在趋势为负时，我们做空。 当趋势发生反转后，我们平仓。 那么，我们如何确定趋势和趋势的强度呢？让我们先来复习一下峰…...

编程日记 2025/7/16 8:40:49

【综述】视频目标分割VOS

目录 1、Associating Objects with Transformers for Video Object Segmentation1&#xff09;背景知识2&#xff09;研究方法3&#xff09;实验结果4&#xff09;结论 2、Rethinking Space-Time Networks with Improved Memory Coverage for Efficient Video Object Segmentat…...

编程日记 2025/7/15 9:43:27

基于线性回归的数据预测

1. 自主选择一个公开回归任务数据集&#xff08;如房价预测、医疗数据、空气质量预测等&#xff0c;可Kaggle&#xff09;。 2. 数据预处理&#xff1a;完成标准化&#xff08;Normalization&#xff09;、特征选择或缺失值处理等步骤。 3. 使用线性回归模型进行建模。采用80…...

编程日记 2025/6/29 0:24:59

第5天-python饼图绘制

一、基础饼图绘制（Matplotlib） 1. 环境准备 python 复制 下载 pip install matplotlib numpy 2. 基础饼图代码 python 复制 下载 import matplotlib.pyplot as plt# 数据准备 labels = [1, 2, 3, 4] sizes = [30, 25, 15, 30] # 各部分占比（总和建议100） colors…...

编程日记 2025/7/15 4:53:26

c++学习方向选择说明

文章目录 前言一、什么样的人适合用c找编程相关工作二、c可以投递什么岗位三、应届生c怎么学才可以找到好工作那这样的话&#xff0c;校招生搞c应该怎么学才能凸显自己的优势呢&#xff1f;那有人就问了&#xff0c;那我应该学啥啊&#xff1f; 四、零基础学习c路线 前言 做了…...

编程日记 2025/7/14 22:36:12

采集需要登录网站的教程

有些网站需要用户登录才能显示相关信息&#xff0c;如果要采集这类网站&#xff0c;有以下几个方法&#xff1a; 1. 写发布模块来抓包获取post的数据&#xff1b; 2. 有些采集器内置浏览器获取这些信息&#xff0c;但是经常获取的不准确&#xff0c;可靠性太低&#xff1b; 3. …...

编程日记 2025/7/14 15:14:06

在hadoop中实现序列化与反序列化

在 Hadoop 分布式计算环境中&#xff0c;序列化与反序列化是数据处理的核心机制之一。由于 Hadoop 需要在集群节点间高效传输数据并进行分布式计算&#xff0c;其序列化框架不仅要支持对象的序列化与反序列化&#xff0c;还要满足高效、紧凑、可扩展等特殊需求。本文将深入探讨…...

编程日记 2025/7/18 4:46:13

数据结构*排序

排序的一些相关概念 稳定性 假设在待排序序列中&#xff0c;存在两个元素A和B&#xff0c;A和B的值相同。在排序后&#xff0c;A和B的相对位置没有变化&#xff0c;就说这排序是稳定的。反之不稳定。 内部排序与外部排序 内部排序&#xff1a;数据完全存储在内存中&#xf…...

编程日记 2025/7/14 18:50:05

新浪《经济新闻》丨珈和科技联合蒲江政府打造“数字茶园+智能工厂+文旅综合体“创新模式

5月14日&#xff0c;新浪网《经济新闻》频道专题报道珈和科技在第十四届四川国际茶业博览会上的精彩亮相&#xff0c;并深度聚焦我司以数字技术赋能川茶产业高质量发展创新技术路径&#xff0c;及在成都市“茶业建圈强链”主题推介会上&#xff0c;珈和科技与蒲江县人民政府就智…...

编程日记 2025/7/14 23:00:38

【Linux】第二十三章 控制启动过程

1. 请简要说明 RHEL9的启动过程。 &#xff08;1&#xff09;计算机通电。系统固件 (UEFI 或 BIOS) 开机自检 (POST)&#xff0c;并初始化部分硬件&#xff0c;然后&#xff0c;固件会寻找启动设备&#xff08;如硬盘、USB、网络等&#xff09;&#xff0c;并将控制权交给引导…...

编程日记 2025/7/17 1:26:00

深信服golang面经

for range 中赋值的变量&#xff0c;这个变量指向的是真实的地址吗&#xff0c;还是临时变量 不是真实地址&#xff0c;是临时变量 package mainimport "fmt"func main() {slice : []int{4, 2, 3}for _, v : range slice {fmt.Println(v, &v) // 这里的 v 是临…...

编程日记 2025/7/15 1:19:13

基于 Netty + SpringBoot + Vue 的高并发实时聊天系统设计与实现

一、系统架构设计 1.1 整体架构图 ------------------ WebSocket (wss) ------------------ Netty TCP ------------------ | Vue前端 | <-------------------------> | SpringBoot网关 | <------------------> | Netty服务集…...

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

根据当前日期计算并选取上一个月和上一个季度的日期范围，用于日期控件的快捷选取功能

代码如下&#xff1a; <el-date-picker v-model"value" type"monthrange" align"right" unlink-panels range-separator"至"start-placeholder"开始月份" end-placeholder"结束月份" :picker-options"pic…...

编程日记 2025/6/29 0:20:29