如何实现一个分布式单例对象?什么场景需要分布式单例?
单例模式确保一个类在同一个进程中只有一个实例,并提供一个全局访问点。这意味着无论在哪里调用该类的实例化方法,返回的都是同一个对象实例。
在分布式系统中,无论是单台机器多个实例,还是多台机器多个实例,每个实例通常运行在独立的进程中,分布式单例是在这些多进程环境中,确保某个类的实例对象在整个分布式系统中是唯一的,即所有进程访问的都是同一个对象实例。
按照这个思路,需要确保在任意时刻,只有一个进程能够访问和修改单例对象。,而分布式场景下的分布式锁就很容易实现这个功能。
多个进程竞争分布式锁,谁抢到锁,谁此时就可以使用这个单例对象,用完之后释放这个对象,并且释放锁这样不就保证多进程中实例对象唯一了吗?
分布式锁可以用 redis 实现,三方外部存储也可以用 redis 实现。
-
选择合适的分布式锁机制:使用Redis的
SETNX命令或者Redlock算法来实现分布式锁。SETNX命令可以尝试设置一个键,如果键不存在,则成功设置并返回1;如果键已经存在,则不执行任何操作并返回0。这可以用来模拟锁的行为。 -
获取锁:在尝试访问单例对象前,每个进程都需要先尝试获取分布式锁。只有成功获取锁的进程才能继续下一步操作。
-
从Redis加载数据:成功获取锁的进程需要从Redis中加载单例对象的数据。如果这是第一次加载,Redis中可能没有相关数据,此时可以初始化一个新的对象。
-
反序列化:将从Redis获取的数据反序列化为对象实例。如果Redis中没有数据,则创建一个新的对象实例。
-
使用对象:使用反序列化后的对象实例执行所需的操作。
-
序列化并存储:完成对象的使用后,将对象的数据序列化,并将其存储回Redis中,覆盖之前的版本。
-
释放锁:最后,释放分布式锁,允许其他进程竞争锁以使用单例对象。
-
异常处理:在整个过程中,还需要考虑异常处理,确保即使发生错误也能正确释放锁,避免死锁的发生。
public class DistributedSingleton {private static final String LOCK_KEY = "singleton_lock";private static final String INSTANCE_KEY = "singleton_instance";public Object getInstance() {// 尝试获取分布式锁boolean lockAcquired = acquireDistributedLock(LOCK_KEY);if (lockAcquired) {try {// 从Redis加载数据String serializedData = getFromRedis(INSTANCE_KEY);// 反序列化Object instance;if (serializedData == null) {instance = new SingletonObject(); // 如果是第一次加载,创建新的实例} else {instance = deserialize(serializedData); // 否则,反序列化已有的数据} // 使用对象useInstance(instance); // 序列化并存储String newData = serialize(instance);saveToRedis(INSTANCE_KEY, newData);return instance;} finally {// 释放锁releaseDistributedLock(LOCK_KEY);}} else {throw new RuntimeException("Failed to acquire lock");}}private void useInstance(Object instance) {// 执行对象的具体操作}private boolean acquireDistributedLock(String key) {// 实现获取分布式锁的逻辑return true; // 假设获取成功}private void releaseDistributedLock(String key) {// 实现释放分布式锁的逻辑}private String getFromRedis(String key) {// 从Redis获取数据return null; // 返回数据或null}private void saveToRedis(String key, String value) {// 将数据保存到Redis}private String serialize(Object obj) {// 序列化对象return ""; // 返回序列化后的字符串}private Object deserialize(String str) {// 反序列化对象return null; // 返回反序列化后的对象}
}
应用场景
-
全局配置管理:在分布式系统中,可能需要一个全局的配置中心来统一管理应用的配置信息。这些配置信息需要被所有节点共享,并且在更新时保持一致性。
-
会话管理:在Web应用中,用户会话信息通常需要跨多个服务器共享。使用分布式单例可以确保所有服务器访问相同的会话数据,提供一致的用户体验。
-
缓存管理:为了提高性能,应用可能会使用缓存来存储频繁访问的数据。在分布式环境中,确保所有节点都能访问相同的缓存数据是非常重要的。
-
计数器或统计信息:当需要在多个节点之间同步计数器或统计信息时,使用分布式单例可以帮助保持数据的一致性。
相关文章:
如何实现一个分布式单例对象?什么场景需要分布式单例?
单例模式确保一个类在同一个进程中只有一个实例,并提供一个全局访问点。这意味着无论在哪里调用该类的实例化方法,返回的都是同一个对象实例。 在分布式系统中,无论是单台机器多个实例,还是多台机器多个实例,每个实例…...
Elasticsearch8.17 集群重启操作
一、全集群重启步骤 1. 禁用分片分配 在关闭数据节点前,需禁用副本分片的分配,避免不必要的 I/O 操作。通过以下命令将分片分配限制为仅主分片: resp = client.cluster.put_settings(persistent={"cluster.routing.allocation.enable": "primaries"}…...
VBA常见的知识都有哪些,让AI编写的VBA经常 报错,所以VBA的基础还是要学习的
掌握这些能够大大的提高VBA的编写效率,欢迎来到涛涛聊AI。 1. 异常处理 Cleanup:是VBScript的错误处理标签,用于标记程序执行失败或退出时需要执行的清理操作(如关闭文件、释放对象)。这段代码会在遇到错误或用户取消操作时跳转…...
dify重磅升级:从0.15.3安全升级1.1.0新手避坑指南
Docker Compose 部署 备份自定义的 docker-compose YAML 文件(可选) cd docker cp docker-compose.yaml docker-compose.yaml.-$(date +%Y-%m-%d-%H-%M).bak从 main 分支获取最新代码 git checkout main git pull origin main停止服务,命令,请在 docker 目录下执行...
NLP高频面试题(六)——decoder-only、encoder-only和encoder-decoder的区别与联系
一、基本概念与代表模型 1. Encoder-only 架构 Encoder-only 架构最具代表性的模型是 BERT。BERT 使用 masked language modeling(MLM)进行预训练,即随机遮蔽部分输入词汇,让模型预测被遮蔽的词汇。由于这种架构能够同时看到输入…...
DeepSeek(8):结合Kimi-PPT助手一键生成演示报告
1 生成内容 在Deepseek中生成内容: 帮我创建年度计划,描述《智能枕头》产品的如何在全国销售,计划切分到每个月。从而让我们的老板和团队对报告充满信息。输出的内容我需要放到ppt中进行展示。 使用Deepseek R1模型,如下&#x…...
【MySQL】MySQL如何存储元数据?
目录 1.数据字典的作用 2. MySQL 8.0 之前的数据字典 3. MySQL 8.0 及之后的数据字典 4.MySQL 8 中的事务数据字典的特征 5.数据字典的序列化 6. .sdi文件的作用: 7..sdi的存储方式 在 MySQL 中,元数据(Metadata) 是描述数…...
《基于自适应正负样本对比学习的特征提取框架》-核心公式提炼简洁版 2022年neural networks
论文源地址 以下是从文档中提取的关于“基于对比学习的特征提取框架(CL-FEFA)”中正负样本对比学习实现的技术细节,包括详细的数学公式、特征提取过程以及特征表示方式的说明。 1. 正负样本的定义与构造 在CL-FEFA框架中,正负样…...
8.4《同一直线上二力的合成》
教会什么:合力与分力、同一直线上二力的合成 培养什么:实验抓共同点为突破口 课标: (二)运动和相互作用 2.2 机械运动和力 2.2.4 能用示意图描述力。会测量力的大小。了解同一直线上的二力合成。 零、导入 提问: 在前面我们探究了物体处于匀速直线运动/静止状态时,即处于…...
用ASCII字符转化图片
代码 from PIL import Image# 定义 ASCII 字符集,从最暗到最亮 ASCII_CHARS "%#*-:. "def resize_image(image, new_width100):width, height image.sizeratio height / widthnew_height int(new_width * ratio)resized_image image.resize((new_wi…...
zookeepernacoskafka之间的联系
一、ZooKeeper与Kafka的协同工作原理 1. 核心关系:Kafka对ZooKeeper的依赖 在Kafka 2.8版本之前,ZooKeeper是Kafka集群的“大脑”,负责管理集群元数据、协调节点状态和故障恢复。两者的协同主要通过以下关键机制实现: Broker注册…...
力扣 797. 所有可能的路径 解析JS、Java、python、Go、c++
深度优先搜索解所有可能的路径问题 题目描述 力扣链接 给你一个有 n 个节点的 有向无环图(DAG),请你找出所有从节点 0 到节点 n-1 的路径并输出(不要求按特定顺序) graph[i] 是一个从节点 i 可以访问的所有节点的列…...
蓝桥与力扣刷题(蓝桥 组队)
题目:作为篮球队教练,你需要从以下名单中选出 1 号位至 5 号位各一名球员,组成球队的首发阵容。 每位球员担任 1号位至 5号位时的评分如下表所示。请你计算首发阵容 1 号位至 5 号位的评分之和最大可能是多少? 本题为填空题&…...
python函数的多种参数使用形式
目录 1. 位置参数(Positional Arguments) 2. 关键字参数(Keyword Arguments) 3. 默认参数(Default Arguments) 4. 可变参数(Variable Positional Arguments) 5. 关键字可变参数&…...
天梯赛 PTAL2-009 抢红包
很简单的一道模拟题,使用map统计每个用户的钱数和红包数,最后在使用结构体存储,重载小于号,sort排序即可。 #include <bits/stdc.h> using namespace std; #define endl \n #define int long long typedef long long ll; c…...
【京东API开发指南】三步获取商品详情页实时数据:SKU、价格、销量全解析
以下是使用京东 API 获取商品详情页实时数据(SKU、价格、销量)的一般步骤: 注册与认证 注册开发者账号:访问京东开放平台官网,完成企业实名认证(仅支持企业开发者)。这是使用京东 API 的前提&am…...
深入探讨TK矩阵系统:创新的TikTok运营工具
TK矩阵的应用场景 TK矩阵系统适用于多个场景,尤其是在以下几个方面有显著优势: 批量账号管理与内容发布:对于需要管理多个TikTok账号的内容创作者或营销人员,TK矩阵提供了高效的账号管理工具,支持批量发布视频、评论、…...
AI Agent系列(六) -基于ReAct架构搭建LLM Agent(Deepseek)
AI Agent系列【六】 一、 ReAct1.1 ReAct 的处理过程:1.1 代码结构 二、 Python代码实现2.1 通过Zero-shot 实现python代码实例Python代码示例1:python代码实现示例2 一、 ReAct ReAct 是 Reseaning 和 Action 两个词的前缀合成,代表着先推…...
零基础上手Python数据分析 (6):Python 异常处理,告别程序崩溃的烦恼!
回顾一下,前几篇博客我们学习了 Python 的基本语法、数据结构和文件操作。 现在,我们已经掌握了 Python 编程的基础知识,可以开始编写更复杂的数据分析代码了。 但是,在实际的数据分析工作中,程序并非总能一帆风顺地运行,总会遇到各种 意外情况,例如: 文件找不到: 程序…...
AnyTouch:跨多个视觉触觉传感器学习统一的静态动态表征
25年3月来自人大、武汉科技大学和北邮的论文“AnyTouch: Learning Unified Static-dynamic Representation Across Multiple Visuo-tactile Sensors”。 视觉触觉传感器旨在模拟人类的触觉感知,使机器人能够精确地理解和操纵物体。随着时间的推移,许多精…...
关于stm32mp157
目录 设备树: 内核移植: 编写一个驱动的过程: 编写i2c传感器驱动的过程: 从arm11后,命名改为cortex, 1.cortex A:高端应用型领域 2.cortex R:实时性要求 3.cortex M:…...
关于单项梯度冻结小记
单项权重冻结(Partial Weight Freezing)详解 单项权重冻结(Partial Weight Freezing) 是深度学习模型训练中的一种技巧,指的是在训练过程中,只冻结(固定)部分网络权重,而…...
Ubuntu20.04安装Nvidia显卡驱动
Ubuntu20.04安装Nvidia显卡驱动 安装环境为Dell R540服务器 官网下载Nvidia显卡驱动 https://www.nvidia.cn/geforce/drivers/ 安装显卡驱动 chmod x NVIDIA-Linux-x86_64-470.63.01.run sudo ./NVIDIA-Linux-x86_64-470.63.01.run 遇到nouveau报错 lsmod查看nouveau驱动…...
YOLOv11 目标检测
本文章不再赘述anaconda的下载以及虚拟环境的配置,博主使用的python版本为3.8 1.获取YOLOv11的源工程文件 链接:GitHub - ultralytics/ultralytics: Ultralytics YOLO11 🚀 直接下载解压 2.需要自己准备的文件 文件结构如下:红…...
VSCode C/C++ 环境搭建指南
一、前言 Visual Studio Code(简称 VSCode)是一款轻量级且功能强大的跨平台代码编辑器,凭借丰富的插件生态和高度的可定制性,深受开发者喜爱。对于 C/C 开发者而言,在 VSCode 中搭建开发环境,能够获得灵活…...
Python-docx库详解:轻松实现Word文档自动化生成与图片尺寸控制
Python-docx库详解:轻松实现Word文档自动化生成与图片尺寸控制 在现代办公自动化的浪潮中,文档处理是一项不可或缺的任务。Python作为一种强大的编程语言,提供了丰富的库来简化这些任务。其中,python-docx库是处理Word文档的有力…...
Python大疆导出csv文件转化大地2000的dxf文件
大疆导出三维模型里面有个models\pc\0\terra_grid\csv\terra_grid.csv文件,里面记录所有点的坐标和高程,但坐标是经纬度坐标,需要转化为大地2000坐标。 我参照了:经纬度坐标转换为CGCS2000大地坐标系对应XY值(PYTHON实…...
Python 中下划线 “_” 的多面性:从变量到约定
# Python中下划线“_”的多面性:从变量到约定 在Python的语法体系里,下划线“_”看似毫不起眼,实则扮演着极为重要且多样化的角色。它不仅能作为普通变量参与编程,更在多个特殊场景下有着独特的用途与约定。深入理解下划线的各种…...
Vue3项目开发:状态管理实践指南
# Vue3项目开发:状态管理实践指南 一、引言 背景介绍 在Vue项目中,状态管理是一个非常重要的话题。合理的状态管理能够帮助我们更好地组织和管理数据,提升项目的可维护性和可扩展性。本文将深入探讨Vue3项目中状态管理的最佳实践,…...
JVM-JAVA编译到执行全过程
源码文件(.java)到代码执行的全过程: 该过程主要分为四个阶段,“编译-》加载-》解释-》执行”。 在编译阶段需要将源码文件(.java)通过语法分析、语义分析、注解处理后得到class文件; 在加载…...
