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

【高性能缓存Redis_中间件】二、redis进阶 高级特性及应用

一、前言

在第一篇文章中,我们已经对 Redis 消息队列有了基础的认识,掌握了其基本使用方法。然而,在实际的复杂业务场景中,仅仅运用基础功能是远远不够的。本篇文章将深入探讨 Redis 消息队列的高级特性,如消息确认机制、延迟队列、优先级队列等。

二、环境准备:在 CentOS 上安装和配置 Redis

2.1 安装 Redis

在 CentOS 系统上,我们可以使用以下命令来安装 Redis:

# 更新系统包
sudo yum update -y
# 安装 Redis
sudo yum install redis -y

上述命令首先使用 yum update 对系统的软件包进行更新,确保系统是最新状态。

然后使用 yum install redis 命令来安装 Redis。

2.2 启动和配置 Redis

安装完成后,我们需要启动 Redis 服务,并设置其开机自启:

# 启动 Redis 服务
sudo systemctl start redis
# 设置 Redis 开机自启
sudo systemctl enable redis

systemctl start redis 用于启动 Redis 服务。

systemctl enable redis 则将 Redis 服务设置为开机自启,这样在系统重启后,Redis 服务会自动启动。

为了确保 Redis 服务的安全性,我们可以对其进行一些基本的配置。打开 Redis 的配置文件:

sudo vi /etc/redis.conf

在配置文件中,我们可以设置以下内容:

# 绑定的 IP 地址,可根据需要修改,这里设置为仅允许本地访问
bind 127.0.0.1
# 设置访问密码,可替换为你自己的强密码
requirepass your_strong_password

修改完成后,保存并退出配置文件,然后重启 Redis 服务使配置生效:

sudo systemctl restart redis

2.3 验证 Redis 安装

使用以下命令连接到 Redis 服务器,验证是否安装成功

redis-cli -a your_strong_password

这里的 -a 选项用于指定访问密码。连接成功后,你可以输入 PING 命令,如果返回 PONG,则表示 Redis 服务器正常运行。

三、消息确认机制

3.1 消息确认机制的重要性

在消息队列的使用过程中,消息的可靠性是至关重要的。由于网络故障、消费者崩溃等原因,可能会导致消息丢失。消息确认机制可以确保消息在被消费者成功处理后才被标记为已消费,从而避免消息丢失的问题。

3.2 Redis 中实现消息确认的方法

在 Redis 中,我们可以使用列表和集合结合的方式来实现消息确认机制。具体步骤如下:

  1. 生产者:将消息添加到一个列表(待处理队列)中。
  2. 消费者:从待处理队列中获取消息,并将消息添加到一个集合(处理中集合)中,表示该消息正在被处理。
  3. 处理完成:消费者处理完消息后,从处理中集合中移除该消息,并向生产者发送确认信息。
  4. 异常处理:如果消费者在处理消息过程中出现异常,可以将消息重新放回待处理队列中,以便其他消费者继续处理。

3.3 代码演示(python)

import redis
import time# 连接 Redis
r = redis.Redis(host='localhost', port=6379, password='your_strong_password')# 待处理队列名称
pending_queue = 'pending_queue'
# 处理中集合名称
processing_set = 'processing_set'# 生产者:添加消息到待处理队列
def add_message_to_pending_queue(message):r.rpush(pending_queue, message)print(f"消息 '{message}' 已添加到待处理队列")# 消费者:从待处理队列中获取消息
def get_message_from_pending_queue():message = r.lpop(pending_queue)if message:message = message.decode('utf-8')# 将消息添加到处理中集合r.sadd(processing_set, message)print(f"从待处理队列中获取到消息: {message},已添加到处理中集合")return messagereturn None# 消费者:处理消息并确认
def process_message(message):try:# 模拟消息处理print(f"正在处理消息: {message}")time.sleep(2)# 处理完成,从处理中集合中移除消息r.srem(processing_set, message)print(f"消息 '{message}' 处理完成,已从处理中集合移除")except Exception as e:print(f"处理消息 '{message}' 时出现异常: {e}")# 出现异常,将消息重新放回待处理队列r.rpush(pending_queue, message)r.srem(processing_set, message)print(f"消息 '{message}' 已重新放回待处理队列")if __name__ == "__main__":# 生产者添加消息add_message_to_pending_queue('Hello, Redis Message Confirmation!')# 消费者获取并处理消息message = get_message_from_pending_queue()if message:process_message(message)

注释

  • redis.Redis:用于连接 Redis 服务器。
  • r.rpush:将消息添加到待处理队列的右端。
  • r.lpop:从待处理队列的左端获取并移除一个消息。
  • r.sadd:将消息添加到处理中集合。
  • r.srem:从处理中集合中移除消息。

四、延迟队列

4.1 延迟队列的概念和应用场景

延迟队列是一种特殊的消息队列,消息在队列中不会立即被处理,而是在指定的时间后才会被处理。延迟队列的应用场景非常广泛,例如:

  • 定时任务:在电商系统中,用户下单后,如果在一定时间内未支付,系统需要自动取消订单。可以使用延迟队列来实现这个定时任务。
  • 缓存预热:在系统启动时,需要提前将一些常用的数据加载到缓存中。可以使用延迟队列来安排缓存预热的任务。

4.2 Redis 实现延迟队列的方式

在 Redis 中,我们可以使用 Sorted Set 来实现延迟队列。具体步骤如下:

  1. 生产者:将消息作为成员,将消息的执行时间作为分数,添加到 Sorted Set 中。
  2. 消费者:定期检查 Sorted Set 中分数小于当前时间的成员,将这些成员取出并处理。

4.3 代码演示(Python)

import redis
import time# 连接 Redis
r = redis.Redis(host='localhost', port=6379, password='your_strong_password')# 延迟队列名称
delay_queue = 'delay_queue'# 生产者:添加延迟消息
def add_delay_message(message, delay_time):# 计算消息的执行时间execute_time = time.time() + delay_timer.zadd(delay_queue, {message: execute_time})print(f"消息 '{message}' 已添加到延迟队列,执行时间: {execute_time}")# 消费者:处理延迟消息
def process_delay_messages():while True:# 获取当前时间current_time = time.time()# 获取分数小于当前时间的成员messages = r.zrangebyscore(delay_queue, 0, current_time)if messages:for message in messages:message = message.decode('utf-8')# 处理消息print(f"处理延迟消息: {message}")# 从延迟队列中移除消息r.zrem(delay_queue, message)time.sleep(1)if __name__ == "__main__":# 生产者添加延迟消息add_delay_message('Delayed Message 1', 5)add_delay_message('Delayed Message 2', 10)# 启动消费者线程import threadingconsumer_thread = threading.Thread(target=process_delay_messages)consumer_thread.start()

注释

  • r.zadd:将消息作为成员,执行时间作为分数,添加到 Sorted Set 中。
  • r.zrangebyscore:获取 Sorted Set 中分数在指定范围内的成员。
  • r.zrem:从 Sorted Set 中移除指定的成员。

五、优先级队列

5.1 优先级队列的作用和适用场景

优先级队列是一种根据消息的优先级来决定消息处理顺序的队列。在一些场景中,某些消息需要优先处理,例如紧急任务、高优先级的订单等。使用优先级队列可以确保这些高优先级的消息能够及时得到处理。

5.2 使用 Redis 的 Sorted Set 实现优先级队列

在 Redis 中,我们可以使用 Sorted Set 来实现优先级队列。具体步骤如下:

  1. 生产者:将消息作为成员,将消息的优先级作为分数,添加到 Sorted Set 中。
  2. 消费者:从 Sorted Set 中获取分数最高的成员进行处理。

5.3 代码演示(Python)

import redis# 连接 Redis
r = redis.Redis(host='localhost', port=6379, password='your_strong_password')# 优先级队列名称
priority_queue = 'priority_queue'# 生产者:添加消息到优先级队列
def add_message_to_priority_queue(message, priority):r.zadd(priority_queue, {message: priority})print(f"消息 '{message}' 已添加到优先级队列,优先级: {priority}")# 消费者:从优先级队列中获取消息
def get_message_from_priority_queue():# 获取分数最高的成员message = r.zrevrange(priority_queue, 0, 0)if message:message = message[0].decode('utf-8')# 从优先级队列中移除消息r.zrem(priority_queue, message)print(f"从优先级队列中获取到消息: {message}")return messagereturn Noneif __name__ == "__main__":# 生产者添加消息add_message_to_priority_queue('Message 1', 1)add_message_to_priority_queue('Message 2', 3)add_message_to_priority_queue('Message 3', 2)# 消费者获取并处理消息while True:message = get_message_from_priority_queue()if not message:break

注释

  • r.zadd:将消息作为成员,优先级作为分数,添加到 Sorted Set 中。
  • r.zrevrange:获取 Sorted Set 中分数从高到低排序的成员。
  • r.zrem:从 Sorted Set 中移除指定的成员。

六、分布式锁与消息队列

6.1 分布式环境下消息队列的一致性问题

在分布式环境中,多个消费者可能同时从消息队列中获取消息,这可能会导致消息的重复处理或丢失。为了保证消息队列的一致性和可靠性,需要使用分布式锁来控制对消息队列的访问。

6.2 Redis 分布式锁的实现原理

Redis 分布式锁的实现原理基于 Redis 的原子操作。具体步骤如下:

  1. 获取锁:使用 SET key value NX PX timeout 命令尝试获取锁。如果返回 OK,表示获取锁成功;否则,表示获取锁失败。
  2. 释放锁:使用 DEL key 命令释放锁。

6.3 代码演示(Python)

import redis
import time# 连接 Redis
r = redis.Redis(host='localhost', port=6379, password='your_strong_password')# 锁的键名
lock_key = 'message_queue_lock'
# 锁的过期时间(毫秒)
lock_timeout = 5000# 获取锁
def acquire_lock():result = r.set(lock_key, 'locked', nx=True, px=lock_timeout)return result# 释放锁
def release_lock():r.delete(lock_key)# 消费者:使用分布式锁从消息队列中获取消息
def get_message_with_lock():if acquire_lock():try:# 模拟从消息队列中获取消息message = 'Sample Message'print(f"获取到消息: {message}")time.sleep(2)finally:release_lock()else:print("获取锁失败,稍后重试")if __name__ == "__main__":get_message_with_lock()

注释

  • r.set(lock_key, 'locked', nx=True, px=lock_timeout):尝试获取锁,nx=True 表示只有当键不存在时才设置,px=lock_timeout 表示设置锁的过期时间。
  • r.delete(lock_key):释放锁。

七、具体应用具体分析(简单举例来提供思路)

7.1 电商系统中的订单处理

在电商系统中,订单处理涉及多个环节,如库存扣减、支付处理、物流配送等。使用 Redis 消息队列的高级特性可以优化订单处理流程,提高系统的性能和可靠性。

  • 延迟队列:用户下单后,如果在一定时间内未支付,系统可以使用延迟队列自动取消订单。
  • 消息确认机制:在库存扣减和支付处理过程中,使用消息确认机制确保消息不会丢失,保证订单处理的一致性。
  • 优先级队列:对于一些紧急订单(如 VIP 用户的订单),可以使用优先级队列优先处理。

7.2 社交平台的消息推送

在社交平台中,消息推送是一个重要的功能。使用 Redis 消息队列的高级特性可以实现高效的消息推送。

  • 延迟队列:可以根据用户的设置,使用延迟队列在合适的时间推送消息,提高用户体验。
  • 分布式锁:在高并发场景下,使用分布式锁控制对消息队列的访问,避免消息的重复推送。

相关文章:

【高性能缓存Redis_中间件】二、redis进阶 高级特性及应用

一、前言 在第一篇文章中,我们已经对 Redis 消息队列有了基础的认识,掌握了其基本使用方法。然而,在实际的复杂业务场景中,仅仅运用基础功能是远远不够的。本篇文章将深入探讨 Redis 消息队列的高级特性,如消息确认机…...

vs2022 pcl1.15.0注意点

pcl1.15.0的版本变化很大,其中有一个地方需要设置成如下图所示 如果不设置生成的时候可能有以下错误: 严重性 代码 说明 项目 文件 行 禁止显示状态 详细信息 错误 C1189 #error: "Potential runtime error due to…...

React Router路由

例子 // 创建Router实例对象 const router createBrowserRouter([{path:/login,element:<div>我是登录</div>},{path:/article,element:<div>我是文章</div> }])在jsx中配置一个RouterProvider组件 绑定 router{router} 常规的组件配置...

深度学习(一)

(Ⅰ)神经网络和深度学习 一&#xff0c;ReLU激活函数 ReLU(Rectified Linear Unit)函数&#xff0c;输入大于0时&#xff0c;直接输出该值&#xff1b;输入小于0时&#xff0c;输出0 代码实现&#xff1a; 图中的每个节点都可以是ReLU激活函数的一部分 二&#xff0c;循环神经…...

【LeetCode 热题100】二叉树遍历入门:从中序遍历到层序与右视图(力扣94 / 102/199)(Go语言版)

&#x1f333; 二叉树遍历入门&#xff1a;从中序遍历到层序与右视图 本文涵盖 LeetCode 上的三道基础但极具代表性的二叉树遍历题&#xff1a; 二叉树的中序遍历 二叉树的层序遍历 二叉树的右视图 通过这些题目&#xff0c;我们将从 DFS 到 BFS&#xff0c;深入理解如何处理…...

Tauri 2.3.1+Leptos 0.7.8开发桌面应用--Sqlite数据库的写入、展示和选择删除

在前期工作的基础上&#xff08;Tauri2Leptos开发桌面应用--Sqlite数据库操作_tauri sqlite-CSDN博客&#xff09;&#xff0c;尝试制作产品化学成分录入界面&#xff0c;并展示数据库内容&#xff0c;删除选中的数据。具体效果如下&#xff1a; 一、前端Leptos程序 前端程序主…...

MySQL 5.7.43 二进制安装指南:从零开始的高效快速实现安装部署

目录 引言&#xff1a;为什么选择二进制安装&#xff1f; 1 环境准备 1.1 基础环境检查 1.2 系统安全设置 2 系统优化配置 2.1 磁盘调度策略 2.2 系统资源限制 3 mariadb删除 4 依赖包安装 5 MySQL二进制安装包下载 6 MySQL安装部署 6.1 解压安装包 6.2 创建用户以…...

使用U盘安装 ubuntu 系统

1. 准备U 盘制作镜像 1.1 下载 ubuntu iso https://ubuntu.com/download/ 这里有多个版本以供下载&#xff0c;本文选择桌面版。 1.2 下载rufus https://rufus.ie/downloads/ 1.3 以管理员身份运行 rufus 设备选择你用来制作启动项的U盘&#xff0c;不能选错了&#xff1b;点…...

【家政平台开发(42)】筑牢家政平台安全防线:安全测试与漏洞修复指南

本【家政平台开发】专栏聚焦家政平台从 0 到 1 的全流程打造。从前期需求分析,剖析家政行业现状、挖掘用户需求与梳理功能要点,到系统设计阶段的架构选型、数据库构建,再到开发阶段各模块逐一实现。涵盖移动与 PC 端设计、接口开发及性能优化,测试阶段多维度保障平台质量,…...

JavaWeb-04-Web后端基础(SpringBootWeb、HTTP协议、分层解耦、IOC和DI)

目录 一、SpringBootWeb入门 1.1 概述 1.2 入门程序 1.2.1 需求 1.2.2 开发步骤 1.3 入门解析 二、HTTP协议 2.1 HTTP概述 2.1.1 介绍 2.1.2 特点 2.2 HTTP请求协议 2.2.1 介绍 2.2.2 获取请求数据 2.3 HTTP响应协议 2.3.1 格式介绍 2.3.2 响应状态码 2.3…...

随笔 20250413 Elasticsearch 的 term 查询

你这个问题非常经典&#xff0c;来自于 Elasticsearch 的 term 查询是 ✅精确匹配&#xff08;case-sensitive&#xff0c;大小写敏感&#xff09;&#xff01; &#x1f9e8; 为什么查不到 "World"&#xff1f; 你的查询语句是&#xff1a; GET /movie/_search {&…...

zk(Zookeeper)实现分布式锁

Zookeeper实现分布式锁 1&#xff0c;zk中锁的种类&#xff1a; 读锁&#xff1a;大家都可以读&#xff0c;要想上读锁的前提&#xff1a;之前的锁没有写锁 写锁&#xff1a;只有得到写锁的才能写。要想上写锁的前提是&#xff1a;之前没有任何锁 2&#xff0c;zk如何上读锁 创…...

操作系统简要概述

操作系统是计算机系统的核心软件&#xff0c;它管理和控制计算机硬件与软件资源&#xff0c;为用户提供方便、高效、安全的使用环境。以下是关于操作系统的详细介绍&#xff1a; 一、定义 操作系统&#xff08;Operating System&#xff0c;简称 OS&#xff09;是计算机硬件与…...

开漏模式的触发条件和工作状态

MOS管的漏-栅-源三极 漏极开路--开漏 电路整体概述 这是开漏&#xff08;Open - Drain&#xff09;电路结构&#xff0c;核心由输出控制模块和一对互补的MOS管&#xff08;P - MOS和N - MOS&#xff09;组成。开漏电路的特点是MOS管漏极开路&#xff0c;这种结构常用于需要实现…...

【Java学习笔记】Java第一课,梦开始的地方!!!

目录 1. 基本内容介绍和软件安装 2. 快速入门之第一个程序 hello world 3. 学习方法 基本介绍和软件安装 一、 Java 岗位与应用场景 说明&#xff1a;java 基础也称javaSE 岗位 1. javaEE 软件工程师 电商领域 团购 众筹 sns&#xff08;社交网络&#xff09; 教育 金…...

共享内存技术

一、共享内存 共享内存是一种高效的 进程间通信&#xff08;IPC&#xff09; 机制&#xff0c;允许多个进程直接访问同一块物理内存区域&#xff0c;无需通过内核缓冲区或文件进行数据拷贝。它通常用于需要 低延迟、高吞吐量 的数据交换场景&#xff08;如实时系统、高频交易、…...

Lc 大数运算--快速幂 | 统计好数字的数目

快速幂算法是一种高效计算大数幂运算的方法&#xff0c;能将时间复杂度从传统算法的O(n)降低到O(log n)。它的核心思想是 分解指数分治思想&#xff0c;类似生活中的「拆快递」—— 把大包裹拆成小份&#xff0c;分批处理更高效。 一、生活示例&#xff1a;存钱罐的复利计算 假…...

Linux内存管理架构(2)

4.虚拟地址空间布局 4.1虚拟地址空间划分 对于64位处理器&#xff0c;目前不支持完全的64位虚拟地址 1.ARM64内核/用户虚拟地址划分 1. 虚拟地址的最大宽度 最大宽度&#xff1a;虚拟地址的最大宽度是48位。 内核虚拟地址&#xff1a; 在64位地址空间的顶部。高16位全是1。范围…...

图论基础理论

在我看来&#xff0c;想要掌握图的基础应用&#xff0c;仅需要三步走。 什么是图&#xff08;基本概念&#xff09;、图的构造&#xff08;打地基&#xff09;、图的遍历方式&#xff08;应用的基础&#xff09; 只要能OK的掌握这三步、就算图论入门了&#xff01;&#xff0…...

最大子序和问题——动态规划/贪心算法解决

目录 一&#xff1a;问题描述 二&#xff1a;解决思路1——动态规划思想 三&#xff1a;C 语言代码实现 四&#xff1a;复杂度分析 五&#xff1a;解决思路2——贪心算法思想 六&#xff1a;具体步骤 七: C语言代码实现 八&#xff1a;复杂度分析 一&#xff1a;问题描述 …...

车载以太网-SOMEIP

文章目录 基本概念SOME/IP的起源与核心定位核心定位设计目标协议栈架构与OSI模型映射报文结构与数据序列化SOME/IP的核心通信机制通信模式分类服务发现协议(SOME/IP-SD)服务发现流程服务质量(QoS)管理SOME/IP在智能汽车中的典型应用SOME/IP测试与验证体系SOME/IP测试环境构…...

DrissionPage详细教程

1. 基本概述 DrissionPage 是一个基于 python 的网页自动化工具。它既能控制浏览器&#xff0c;也能像requests一样收发数据包&#xff0c;更重要的是还能把两者合二为一。因此&#xff0c;简单来说DrissionPage可兼顾浏览器自动化的便利性和 requests 的高效率。 DrissionPa…...

6.1 GitHub亿级数据采集实战:双通道架构+三级容灾设计,破解API限制与反爬难题

GitHub 项目数据获取功能设计与实现 关键词:GitHub API 集成、网页爬虫开发、数据存储设计、定时任务调度、异常处理机制 1. 数据获取架构设计 采用双通道数据采集策略,同时使用 GitHub 官方 API 和网页爬虫技术确保数据完整性: #mermaid-svg-XUg7xhHrzFAozG4J {font-fami…...

LabVIEW 控制电机需注意的关键问题

在自动化控制系统中&#xff0c;LabVIEW 作为图形化编程平台&#xff0c;因其高度可视化、易于集成硬件等优势&#xff0c;被广泛应用于电机控制场景。然而&#xff0c;要实现稳定、精确、高效的电机控制&#xff0c;仅有软件并不足够&#xff0c;还需结合硬件选型、控制逻辑设…...

Linux系统远程操作和程序编译

目录 一、Linux远程终端登录、图形桌面访问、 X图形窗口访问和FTP文件传输操作 1.1 桥接模式 1.2 putty远程登录Ubuntu 1.3 win10远程登录并上传下载文件 1.4 X server仿真软件安装 1.5 树莓派在putty上的远程登录 1.6 使用ftp远程登录并实现文件上传下载 1.7 Linux下的…...

Mac配置开发环境

博主是一名Python后端开发&#xff0c;有时候环境太多 需要配置太多&#xff0c;故做此文章 环境Macbook &#xff0c;请注意自己的是ARM 还是x86 结构 Vscode/Cursor配置Python debug 配置Debug launch.json {"version": "0.2.0","configuratio…...

LabVIEW配电器自动测试系统

随着航天技术的迅猛发展&#xff0c;航天器供配电系统的结构越来越复杂&#xff0c;对配电器的功能完整性、稳定性和可靠性提出了更高要求。传统人工测试方式难以满足高效率、高精度、可重复的测试需求。本项目开发了一套基于LabVIEW平台的宇航配电器自动测试系统&#xff0c;融…...

生成与强化学习:赋予VLA系统物理行动能力

引言&#xff1a;从“理解世界”到“改变世界” 当机器能够“看懂”图像、“听懂”指令时&#xff0c;一个更根本的挑战浮现&#xff1a;如何让它们像人类一样&#xff0c;将认知转化为精准的物理动作&#xff1f;无论是机械臂抓取杯子&#xff0c;还是自动驾驶汽车紧急避障&a…...

基于Springboot+Mysql的闲一品(含LW+PPT+源码+系统演示视频+安装说明)

系统功能 管理员功能&#xff1a;首页、个人中心、用户管理、零食分类管理、零食信息管理、订单评价管理、系统管理、订单管理。用户功能&#xff1a;首页、个人中心、订单评价管理、我的收藏管理、订单管理。前台首页功能&#xff1a;首页、零食信息、零食资讯、个人中心、后…...

jupyter4.4安装使用

一、chrome谷歌浏览器 1. 安装 1.1 下载地址&#xff1a; 下载地址&#xff1a; https://www.google.cn/intl/zh-CN_ALL/chrome/fallback/ 2 插件markdown-viewer 2.1 下载地址&#xff1a; 下载地址&#xff1a;https://github.com/simov/markdown-viewer/releases 2.2…...

Linux虚拟内存详解

引言 虚拟内存是现代操作系统中的核心概念之一&#xff0c;它为进程提供了一个连续的、独立的地址空间&#xff0c;有效解决了物理内存限制问题&#xff0c;并大大简化了程序开发和执行。本文将深入探讨Linux系统中虚拟内存的工作原理、实现机制以及相关的内存管理技术&#x…...

数据库安装(基于Linux下centos7)(保姆级教程)

前言:笔者有段时间没写博客了&#xff0c;今天笔者要分享新的知识了&#xff0c;那就是数据库&#xff0c;笔者会通过博客系统的且通俗易懂的分享数据库知识&#xff0c;对于想要学习数据库和学习过数据库的老铁复习都是非常有用的&#xff0c;绝对干货满满&#xff0c;那么今天…...

【自动驾驶 机器人】速度规划 |梯形/S型速度曲线

参考文章&#xff1a; &#xff08;1&#xff09;【自动驾驶】运动规划丨速度规划丨T型/S型速度曲线 &#xff08;2&#xff09;一文教你快速搞懂速度曲线规划之S形曲线&#xff08;超详细图文推导附件代码&#xff09; 1 梯形速度曲线 如下图所示梯形速度/加速度/加加速度曲…...

Qt C++内存泄漏排查方法

在Qt C++中排查内存泄漏可以按照以下步骤进行,结合工具使用和代码审查: 1. 使用内存检测工具 Valgrind (Linux/macOS) 安装Valgrind:sudo apt-get install valgrind运行程序并检测内存泄漏:valgrind --leak-check=full ./your_qt_app分析输出结果,定位未释放的内存块。Dr…...

[redis进阶一]redis的持久化(2)AOF篇章

目录 一 为什么有了RDB持久化机制还要有AOF呢 板书介绍具体原因: ​编辑二 详细讲解AOF机制 (1)AOF的基本使用 1)板书如下 2)开启AOF机制: 3) AOF工作流程 (2)AOF是否会影响到redis性能 ​编辑 (3)AOF缓冲区刷新策略 (4)AOF的重写机制 板书如下: 为什么要有这个重写机…...

聊天室项目day4(redis实现验证码期限,实现redis连接池)

1.redis连接池操作和之前所学过的io_context连接池原理一样这里不多赘述&#xff0c;也是创建多个连接&#xff0c;使用时按顺序取出来。 2.知识补充redisConnect()函数建立与 Redis 服务器的非阻塞网络连接&#xff0c;成功返回 redisContext*&#xff08;连接上下文指针&…...

Redis之分布式锁

面试切入点 锁的分类 单机版同一个JVM虚拟机内&#xff0c;synchronized或者Lock接口分布式多个不同JVM虚拟机&#xff0c;单机的线程锁不再起作用&#xff0c;资源类在不同的服务器之间共享了 一个靠谱分布式锁需要具备的条件与刚需 独占性&#xff1a;onlyOne&#xff…...

AF3 ProteinDataset类的__getitem__方法解读

AlphaFold3 protein_dataset 模块 ProteinDataset 类 __getitem__ 方法用于从数据集中获取一个条目,并根据配置对数据进行处理。 源代码: def __getitem__(self, idx):"""Return an entry from the dataset.If a clusters file is provided, then the idx i…...

NLP 梳理02 — 标点符号和大小写

文章目录 一、说明二、为什么文本预处理中需要小写2.1 为什么小写在文本预处理中至关重要&#xff1f;2.2 区分大小写对 NLP 任务的影响 三、删除标点符号及其对 NLP 任务的影响3.1 什么是标点符号&#xff1f;3.2 为什么在文本预处理中删除标点符号&#xff1f;3.3 删除标点符…...

HarmonyOS中的多线程并发机制

目录 多线程并发1. 多线程并发概述2 多线程并发模型3 TaskPool简介4 Worker简介4.1 Woker注意事项4.2 Woker基本用法示例 5. TaskPool和Worker的对比5.1 实现特点对比5.2 适用场景对比 多线程并发 1. 多线程并发概述 并发模型是用来实现不同应用场景中并发任务的编程模型&…...

游戏引擎学习第221天:(实现多层次过场动画)

资产: intro_art.hha 已发布 在下载页面&#xff0c;你会看到一个新的艺术包。你将需要这个艺术包来进行接下来的开发工作。这个艺术包是由一位艺术家精心制作并打包成我们设计的格式&#xff0c;旨在将这些艺术资源直接应用到游戏中。它包含了许多我们会在接下来的直播中使用…...

Python | 在Pandas中按照中值对箱形图排序

箱形图是可视化数据分布的强大工具&#xff0c;因为它们提供了对数据集内的散布、四分位数和离群值的洞察。然而&#xff0c;当处理多个组或类别时&#xff0c;通过特定的测量&#xff08;如中位数&#xff09;对箱形图进行排序可以提高清晰度并有助于揭示模式。在本文中&#…...

openapi + knife4j的使用

一、依赖作用与关系 1. springdoc-openapi-starter-webmvc-api • 核心功能&#xff1a; 基于 OpenAPI 3 规范&#xff0c;自动生成 API 文档元数据&#xff08;JSON 格式&#xff09;&#xff0c;并集成 Spring MVC。 提供Tag Operation、Schema 等注解&#xff0c;支持通过…...

数据结构*包装类泛型

包装类 什么是包装类 在讲基本数据类型的时候&#xff0c;有提到过包装类。 基本数据类型包装类byteByteshortShortintIntegerlongLongfloatFloatdoubleDoublecharCharacterbooleanBoolean 我们知道&#xff1a;基本数据类型并不是对象&#xff0c;没有对象所具有的方法和属…...

Azure Synapse Dedicated SQL pool里大型表对大型表分批合并数据的策略

Azure Synapse Dedicated SQL pool中大型表的数据通过MERGE INTO语句合并到另一张大型表的时间很长&#xff0c;容易造成运行超时&#xff0c;而有的时候超时的时间是管理设置&#xff0c;由客户控制&#xff0c;无法修改。这种时候为了确保操作可以运行成功&#xff0c;需要将…...

Day81 | 灵神 | 快慢指针 链表的中间结点 环形链表

Day81 | 灵神 | 快慢指针 链表的中间结点 环形链表 876.链表的中间结点 876. 链表的中间结点 - 力扣&#xff08;LeetCode&#xff09; 思路&#xff1a; 设置两个指针&#xff0c;一个快指针r一个慢指针l 初始都是头结点 我们要求的是中间节点 所以快指针走两步&#x…...

【DDR 内存学习专栏 1.2 -- DDR Channel 介绍】

文章目录 1. DDR中的通道&#xff08;Channel&#xff09;概念1.1 DDR Channel 与 DDRC1.2 DIMM 内存插槽1.3 物理通道的定义1.3.1 多通道的作用 1.4 通道的硬件实现1.5 多核系统的DDR通道分配策略 1. DDR中的通道&#xff08;Channel&#xff09;概念 关于 DDR 通道&#xff…...

深入解析xDeepFM:结合压缩交互网络与深度神经网络的推荐系统新突破

今天是周日&#xff0c;我来解读一篇有趣的文章——xDeepFM。这篇文章由 Mao et al. 发表在SIGIR 2019会议。文章提出了一个新的网络模型——压缩交互网络&#xff08;CIN&#xff09;&#xff0c;用于显式地学习高阶特征交互。通过结合 CIN 和传统的深度神经网络&#xff08;D…...

Mybatis 中 <mappers> 标签四种配置方式

在MyBatis中,我们可以通过四种不同的方式来配置Mappers标签 : 1. 使用 <package name=""> 批量扫描包 这种方式通过指定一个包名,MyBatis 会自动扫描该包下的所有接口并注册为映射器。 <mappers><package name="com.example.mapper"/&…...

科技赋能记忆共生-郑州

故事背景 故事发生在中国河南郑州的现代城市环境中&#xff0c;这里描绘了人与科技的交融与共生。多样的场景展示了人与自然、历史与未来的互动&#xff0c;通过各种科技手段与古老文化相结合&#xff0c;展现出未来城市的独特魅力。 故事内容 在中国河南郑州&#xff0c;一座科…...