DataLock - 数据锁、单据号码锁、并发锁(C#源码)


DataLock - 数据锁、单据号码锁、并发锁-开发框架文库

DataLock - 数据锁、单据号码锁、并发锁

一、DataLock说明

数据机制用于管理对共享资源的并发访问,确保数据的完整性和一致性。DataLock数据锁主要用于在多用户操作环境下,避免多用户并发操作,导致脏写、脏读以及脏数据形成。

二、应用场景

  • 数据锁,用于处理特定的数据,比如用户A必须独占处理某种数据,执行数据锁后,用户B必须等待用户A处理完毕。
  • 单据号码锁,用于生成唯一的单据号码,不会并发操作!
  • 并发锁,处理有关并发方面的需求。

三、使用方法

3.1 数据锁标准使用方法

C# 全选
  public string DoSomething()
        {
            //实例化锁
            var dataLock = new DataLock(db_System, "LockName", "测试业务锁");

            try
            {
                dataLock.SetLock(); //锁定

                //
                //在这里编写处理逻辑
                //

                dataLock.Release();//处理完成:释放锁
                return "测试成功!";
            }
            catch (Exception ex)
            {
                dataLock.Release();
                throw ex;
            }
        }

3.2 生成唯一的单据号码、流水号码

C# 全选
  //获取最新的GroupNo,物流编号
        public long GetNewGroupNo()
        {
            //单据号码锁
            var dataLock = new DataLock(db_System, "LogisticGroup", "物流编号-单据号码锁");

            try
            {
                dataLock.SetLock(); //锁定

                long lastNo = GetLastGroupNo();//获取业务单据,最大的单据号码, MAX(NO)
                long groupNo;

                //第一次初始化锁
                if (String.IsNullOrEmpty(dataLock.LockData.Data))
                    dataLock.LockData.Data = lastNo.ToString();

                //获取数据锁最新的号码
                groupNo = ConvertEx.ToLong(dataLock.LockData.Data);//字符串转long
                if (groupNo == 0) groupNo = lastNo;

                //若数据锁中的号码小于单据最大的号码
                if (groupNo < lastNo) groupNo = lastNo;

                groupNo++;//号码加1

                dataLock.SetData(groupNo.ToString());//设置数据
                dataLock.Release();//释放锁

                return groupNo;
            }
            catch (Exception ex)
            {
                dataLock.Release();
                throw ex;
            }
        }

四、DataLock 源码

C# 全选
    /// <summary>
    /// DataLock - 数据锁、单据号码锁、并发锁(C#源码)
    /// </summary>
    public class DataLock
    {
        private DbFramework _EF;
        private string _lockName;
        private string _note;
        private string _token;
        private int _MAX_TRY_COUNT = 10;

        private sys_DataLock _Data = null;
        public sys_DataLock LockData { get { return _Data; } }

        /// <summary>
        /// 构造器
        /// </summary>
        /// <param name="db">CSFramework.DB数据库组件</param>
        /// <param name="lockName">数据锁名称</param>
        /// <param name="note">备注</param>
        /// <param name="maxTryCount">锁占用状态下, 尝试重新锁定的次数</param>
        public DataLock(IDatabase db, string lockName, string note = null, int maxTryCount = 10)
        {
            _lockName = lockName;
            _note = note;
            _MAX_TRY_COUNT = maxTryCount;
            _token = GetToken();//当前实例的token,重要!!!
            _EF = new DbFramework(db);
        }

        /// <summary>
        /// 是否锁定状态
        /// </summary>
        /// <returns></returns>
        public bool IsLock()
        {
            if (_Data == null)
            {
                _Data = GetLock();
                if (_Data == null) _Data = AddLock();//添加锁
            }

            return _Data.IsLock;
        }

        /// <summary>
        /// 锁定
        /// </summary>
        public void SetLock()
        {

            //尝试锁定10次
            for (int i = 1; i <= _MAX_TRY_COUNT; i++)
            {
                _Data = GetLock();//获取锁数据

                if (_Data == null) _Data = AddLock();//添加锁

                if (_Data.IsLock == false)
                {
                    _Data.IsLock = true;
                    _Data.AccessTime = DateTime.Now;
                    _Data.AccessToken = _token; //当前token
                    _EF.UpdateObject<sys_DataLock>(_Data);
                    return; //设置锁成功
                }
                else
                {
                    //已经是锁定状态,等待其他用户释放锁
                    Thread.Sleep(1000);
                }
            }

            throw new Exception($"设置数据锁<{_lockName}>失败");
        }

        /// <summary>
        /// 设置锁的关联数据
        /// </summary>
        /// <param name="data">关联数据</param>
        /// <param name="note">备注</param>        
        public void SetData(string data, string note = null)
        {
            _Data.Data = data;
            _Data.Note = String.IsNullOrEmpty(note) ? _Data.Note : note;
            _Data.AccessTime = DateTime.Now;

            //提交数据
            //_EF.UpdateObject<sys_DataLock>(_Data);
            _EF.UpdateObject<sys_DataLock>(_Data, null, null, new string[] { "Data", "Note", "AccessTime" });
        }

        /// <summary>
        /// 释放锁, 只可释放自己的锁!!!根据token判断
        /// </summary>
        public void Release()
        {
            _Data.IsLock = false;
            _Data.AccessTime = DateTime.Now;
            _EF.UpdateObject<sys_DataLock>(_Data, new string[] { "AccessToken" });
        }

        private sys_DataLock AddLock()
        {
            sys_DataLock o = new sys_DataLock
            {
                LockName = this._lockName,
                Note = this._note,
                IsLock = false,//默认不锁定
                AccessTime = DateTime.Now,
                AccessToken = _token,//当前token
            };

            bool ok = _EF.AddObject(o);
            if (ok)
                return o;
            else
                throw new Exception("添加锁失败!");
        }

        private sys_DataLock GetLock()
        {
            return _EF.Select<sys_DataLock>("LockName", _lockName);//根据key获取锁
        }

        private string GetToken()
        {
            long result = 1;
            int index = 1;
            byte[] bs = Guid.NewGuid().ToByteArray();

            foreach (byte b in bs)
            {
                result *= ((int)b + index * 2);
                index++;
            }

            var hex = string.Format("{0:x}", result);
            return hex;
        }

    }

五、sys_DataLock 表结构

C# 全选
    /// <summary>
    /// 数据锁的模型
    /// </summary>
    public class sys_DataLock
    {
        [IgnoreField]
        public int isid { get; set; }

        /// <summary>
        /// 锁名称
        /// </summary>
        [KeyField]
        public string LockName { get; set; }

        /// <summary>
        /// 是否锁定状态
        /// </summary>
        public bool IsLock { get; set; }

        /// <summary>
        /// 关联数据,自定义数据
        /// </summary>
        public string Data { get; set; }

        /// <summary>
        /// 备注信息
        /// </summary>
        public string Note { get; set; }

        /// <summary>
        /// 最新操作锁的时间
        /// </summary>
        public DateTime AccessTime { get; set; }

        /// <summary>
        /// 当前访问锁的用户标识(token)
        /// </summary>
        public string AccessToken { get; set; }

    }

 

六、依赖项目

CSFramework.DB

https://www.cscode.net/archive/csframework.db/1630589248.html

内容图片-底图-高效开发.追求卓越-宽-开发框架文库

 

版权声明:本文为开发框架文库发布内容,转载请附上原文出处连接
C/S框架网
上一篇:代码生成器生成查询窗体支持下拉选择存储过程
下一篇:无法升级数据库"CSFramework_WebAPITest",因为它是只读的,它具有只读文件,或是用户无权修改其中的某些文件
评论列表

发表评论

评论内容
昵称:
关联文章

DataLock - 数据单据号码并发C#
指定单据号码自动打开业务单据窗体并显示数据
号码规则管理 - 实例 - C/S快速开发框架旗舰版V5
CS开发框架获取生成流水号码单据号码)介绍
WinFramework轻量级开发框架 - 自动生成流水号码单据号码
新增记录时自动生成记录的序号号码(或单据号码)并填充文本框
ERP系统 - 单据号码维护 - 号码规则定义
手动和自动生成业务单据号码UpdateKeyMode详解(1)
DAL - 主从表业务单据数据访问层C#代码
C#导出数据到Excel 大全
C/S架构软件开发平台旗舰版V6.0迭代开发记录-单据号码规则
Form - 生产计划排程窗体C#
C# 数据窗体实现增删改查(CRUD)下载(原)
CSFrameworkV6旗舰版展示(C#,LINQ+EF)
使用[后台数据更新模型]保存主从表数据(C#)
数据日志配置 - 实例 - C/S快速开发框架旗舰版V5
组织架构数据权限 - 实例 - C/S快速开发框架旗舰版V5
ClassGenerator V2.01 生成的DAL
BLL - 主从表业务单据业务逻辑层C#代码
C/S架构快速开发框架SQL并发测试压力测试 | www.csframework.com

热门标签
.NET5 .NET6 .NET7 APP Auth-软件授权注册系统 Axios B/S B/S开发框架 Bug Bug记录 C#加密解密 C#源码 C/S CHATGPT CMS系统 CodeGenerator CSFramework.DB CSFramework.EF CSFrameworkV1学习版 CSFrameworkV2标准版 CSFrameworkV3高级版 CSFrameworkV4企业版 CSFrameworkV5旗舰版 CSFrameworkV6.0 CSFrameworkV6.1 DAL数据访问层 Database datalock DbFramework Demo教学 Demo下载 DevExpress教程 DOM EF框架 Element-UI EntityFramework ERP ES6 Excel FastReport GIT HR IDatabase IIS JavaScript LINQ MES MiniFramework MIS NavBarControl Node.JS NPM OMS ORM PaaS POS Promise API Redis SAP SEO SQL SQLConnector TMS系统 Token令牌 VS2022 VSCode VUE WCF WebApi WebApi NETCore WebApi框架 WEB开发框架 Windows服务 Winform 开发框架 Winform 开发平台 WinFramework Workflow工作流 Workflow流程引擎 版本区别 报表 踩坑日记 操作手册 代码生成器 迭代开发记录 基础资料窗体 架构设计 角色权限 开发sce 开发技巧 开发教程 开发框架 开发平台 开发指南 客户案例 快速搭站系统 快速开发平台 毛衫行业ERP 秘钥 密钥 权限设计 软件报价 软件测试报告 软件简介 软件开发框架 软件开发平台 软件开发文档 软件体系架构 软件下载 软著证书 三层架构 设计模式 生成代码 实用小技巧 收钱音箱 数据锁 数据同步 微信小程序 未解决问题 文档下载 喜鹊ERP 喜鹊软件 系统对接 详细设计说明书 新功能 行政区域数据库 需求分析 疑难杂症 蝇量级框架 蝇量框架 用户管理 用户开发手册 用户控件 在线支付 纸箱ERP 智能语音收款机 自定义窗体 自定义组件 自动升级程序