Redis分布式锁的原理和实现（下）

2023-07-22 66

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

Redis 开源版，标准版 2GB

云数据库 Tair（兼容Redis），内存型 2GB

简介： Redis分布式锁的原理和实现（下）

业务调用（我们使用多线程模拟多用户秒杀的场景）

//业务：悲观锁方式
        public static void PessimisticLock()
        {
            int num = 10;  //总数量
            string lockkey = "xianseng";
            Console.WriteLine("我是【悲观锁】");
            //悲观锁开启20个人同时拿宝贝
            for (int i = 0; i < 20; i++)
            {
                Task.Run(() =>
                {
                    string selfmark = ""; 
                    try
                    {
                        if (Lock(lockkey, out selfmark))
                        {
                            if (num > 0)
                            {
                                num--;
                                Console.WriteLine($"我拿到了宝贝：宝贝剩余{num}个\t\t{selfmark}");
                            }
                            else
                            {
                                Console.WriteLine("宝贝已经没有了");
                            }
                            Thread.Sleep(100);
                        }
                    }
                    finally
                    {
                        UnLock(lockkey, selfmark);
                    }
                });
            }
            Console.ReadLine();
        }
        //业务：乐观锁方式
        public static void OptimisticLock()
        {
            int num = 10; //总数量
            string lockkey = "xianseng";
            Console.WriteLine("我是【乐观锁】");
            //乐观锁开启10个线程，每个线程拿5次
            for (int i = 0; i < 10; i++)
            {
                var lineOn = "线程" + (i + 1);
                Task.Run(() =>
                {
                    for (int j = 0; j < 5; j++)
                    {
                        string selfmark = "";
                        try
                        {
                            if (Lock(lockkey, out selfmark, 10, 0))
                            {
                                if (num > 0)
                                {
                                    num--;
                                    Console.WriteLine($"{lineOn} 第{(j+1)}次 我拿到了宝贝：宝贝剩余{num}个\t\t{selfmark}");
                                }
                                else
                                {
                                    Console.WriteLine($"{lineOn} 第{(j + 1)}次 宝贝已经没有了");
                                }
                                Thread.Sleep(1000);
                            }
                            else
                            {
                                Console.WriteLine($"{lineOn} 第{(j+1)}次 没有拿到，不想等了");
                            }
                        }
                        finally
                        {
                            UnLock(lockkey, selfmark);
                        }
                    }
                });
            }
            Console.ReadLine();
        }

然后在main函数里面调用查看展示效果

  static void Main(string[] args)
        {
            ////调用：悲观锁方式（认为我操作的时候，会出现问题，所以都加锁）
            PessimisticLock();
            ///调用：乐观锁方式（认为什么时候不会出问题，所以不上锁，更新的时候去查询判断一下，再此期间是否有人修改过这个数据。）
            //OptimisticLock();
        }