Anno&Viper -分布式锁服务端怎么实现

1、Anno简介

　　Anno是一个微服务框架引擎。入门简单、安全、稳定、高可用、全平台可监控、依赖第三方框架少。底层通讯RPC(Remote Procedure Call)采用稳定可靠经过无数成功项目验证过的跨语言的thrift、 grpc。自带服务注册发现健康检查（不依赖于Etcd、Consul、Zookeeper）、调用链追踪、Cron 调度、限流、事件总线。插件化开发，业务模块以CQRS 、DDD作为指导思想。

　　一个不可监控的微服务平台是可怕的，出了问题 难以准确定位问题的根源， Anno则提供了一套完整的监控体系，包括链路追踪、服务占用的系统资源、系统自身 CPU、内存、硬盘使用率实时可监控等等。

github Anno:https://github.com/duyanming/Anno.Core

gitee :https://gitee.com/duyanming/anno.core

体验地址：http://140.143.207.244/Home/Login

2、Anno分布式锁服务端怎么实现

　　上一章节我们了解了分布式锁是为了解决什么问题以及客户端怎么使用，今天我们来看一下分布式锁协调中心是怎么实现的。不足之处望大佬们多多指正。如果还不了解怎么使用可以查看上一章节《.netcore 微服务快速开发框架 Anno&Viper -分布式锁是个什么鬼》

首先我们需要一个分布式锁服务端的入口类 DLockCenter

伪代码：

 public static class DLockCenter

    {

        private static List<LockerQueue> _lockerQueues = new List<LockerQueue>();

        private static readonly object Lock = new object();
　　　　　//进入分布式锁

　　　　　public static EngineData.ActionResult Enter(LockInfo info)

        {

            var locker = _lockerQueues.Find(l => l.MLoker.Key == info.Key);  
　　　　　　　　............
            return locker.Enter(info);

        }
　　　　//释放分布式锁

        public static void Free(LockInfo info)

        {

            _lockerQueues.Find(l => l.MLoker.Owner == info.Owner)?.Free();

        }

        /// <summary>

        /// 定时任务检测分布式锁是否超时， 超时直接抛弃

        /// </summary>

        public static void Detection()

        {

            if (_lockerQueues.Count > 0)

            {

                _lockerQueues.Where(l=>l.MLoker.IsTimeOut&&l.MLoker.Type!=ProcessType.Free).ToList().ForEach(l=>l.Detection());

            }

        }

    }

_lockerQueues:维护了一个分布式锁的列表。

释放超时锁：

分布式锁插件在加载的时候启动一个定时任务检测超时的分布式锁。

public class DLockBootstrap: IPlugsConfigurationBootstrap

    {

        private static readonly CronDaemon CronDaemon = new CronDaemon();

        public void ConfigurationBootstrap()

        {

            //分布式锁启动配置

            /*

             * 每个一段时间检测是否有锁超时，超时则释放锁

             */

            CronDaemon.AddJob("* * * * * ? *", DLockCenter.Detection);

            if (CronDaemon.Status == DaemonStatus.Stop)

            {

                CronDaemon.Start();

            }

        }

        public void PreConfigurationBootstrap()

        {

            //throw new NotImplementedException();

        }

    }

分布式锁服务Module：

 /// <summary>

    /// 分布式锁服务

    /// </summary>

    public class DLockModule : BaseModule

    {

        [AnnoInfo(Desc = "分布式锁服务 获取锁[DLKey][TimeOut:5000][Owner]")]

        public ActionResult EnterLock()

        {

            var dlKey = RequestString("DLKey");

            var timeOut = RequestInt32("TimeOut")??5000;

            var owner = RequestString("Owner");

            var locker=new  LockInfo()

            {

                Key = dlKey,

                Time = timeOut,

                Owner=owner,

                EnterTime=DateTime.Now,

                Type=ProcessType.Enter

            };

            var rlt = DLockCenter.Enter(locker);

            return rlt;

        }

        [AnnoInfo(Desc = "分布式锁服务 释放锁[DLKey][Owner]")]

        public ActionResult DisposeLock()

        {

            var dlKey = RequestString("DLKey");

            var owner = RequestString("Owner");

            var locker = new LockInfo();

            locker.Key = dlKey;

            locker.Owner = owner;

            DLockCenter.Free(locker);

            return new ActionResult(true, null, null, "DisposeLock Message");

        }

    }

关于分布式锁详细源码请查看：https://github.com/duyanming/Anno.Core/tree/master/samples/Packages/Anno.Plugs.DLockService

Anno核心源码:https://github.com/duyanming/Anno.Core

Viper示例项目:https://github.com/duyanming/Viper

体验地址：http://140.143.207.244/Home/Login

QQ交流群：478399354

Anno&Viper -分布式锁服务端怎么实现的更多相关文章

解读Google分布式锁服务
解读Google分布式锁服务背景介绍在2010年4月,Google的网页索引更新实现了实时更新,在今年的OSDI大会上,Google首次公布了有关这一技术的论文. 在此之前,Google的索引更 ...
[转载] zookeeper 分布式锁服务
转载自http://www.cnblogs.com/shanyou/archive/2012/09/22/2697818.html 分布式锁服务在大家的项目中或许用的不多,因为大家都把排他放在数据库那 ...
Redis分布式锁服务(八)
阅读目录: 概述分布式锁多实例分布式锁总结概述在多线程环境下,通常会使用锁来保证有且只有一个线程来操作共享资源.比如: object obj = new object(); lock (ob ...
Redis分布式锁服务（转）
原文:http://www.cnblogs.com/mushroom/p/4752499.html 概述在多线程环境下,通常会使用锁来保证有且只有一个线程来操作共享资源.比如: object obj ...
redis实现分布式锁服务
译自Redis官方文档在多线程共享临界资源的场景下,分布式锁是一种非常重要的组件.许多库使用不同的方式使用redis实现一个分布式锁管理.其中有一部分简单的实现方式可靠性不足,可以通过一些简单的修改 ...
DIOCP开源项目-利用队列+0MQ+多进程逻辑处理，搭建稳定,高效,分布式的服务端
最近头脑里面一直在想怎么样让能让大家基于DIOCP上写出稳定的服务端程序.很多朋友问我,你DIOCP稳定吗,我可以用他来做三层服务器吗? 当时我是这样回答的,我只能保证DIOCP底层通信的稳定. 说实 ...
Redis分布式锁服务
阅读目录: 概述分布式锁多实例分布式锁总结概述在多线程环境下,通常会使用锁来保证有且只有一个线程来操作共享资源.比如: object obj = new object(); lock (ob ...
Zookeeper实现分布式锁服务（Chubby）
在分布式系统中,如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥来防止彼此干扰,来保证一致性,在这种情况下,便需要使用到分布式锁例如有N台服务器同时 ...
zookeeper实现分布式锁服务
A distributed lock base on zookeeper. zookeeper是hadoop下面的一个子项目, 用来协调跟hadoop相关的一些分布式的框架, 如hadoop, hiv ...
DIOCP开源项目-高效稳定的服务端解决方案(DIOCP + 无锁队列 + ZeroMQ + QWorkers) 出炉了
[概述] 自从上次发布了[DIOCP开源项目-利用队列+0MQ+多进程逻辑处理,搭建稳定,高效,分布式的服务端]文章后,得到了很多朋友的支持和肯定.这加大了我的开发动力,经过几个晚上的熬夜,终于在昨天 ...

随机推荐

李洪强iOS经典面试题140-UI
李洪强iOS经典面试题140-UI UI viewcontroller的一些方法的说明viewDidLoad,viewWillDisappear, viewWillAppear方法的顺序和作用? ...
C语言位操作（转）
http://www.cnblogs.com/cpoint/category/524132.html
【golang】go语言，进行并发请求的wrap变参封装
package main import ( "fmt" "sync" "time" ) type WaitGroupWrapper stru ...
[Javascript] Ex: concatAll, map and filter
concatAll: Array.prototype.concatAll = function() { var results = []; this.forEach(function(subArray ...
Stripies（POJ 1862 贪心）
Stripies Time Limit: 1000MS Memory Limit: 30000K Total Submissions: 14151 Accepted: 6628 Descrip ...
Mybatis基本用法--上
Mybatis基本用法--上本文只是为自己查漏补缺.全面的请看官方文档,支持中英文原理参考:http://blog.csdn.net/luanlouis/article/details/40422 ...
Java解释执行和编译执行
以前有句话说:“Java是解释执行的 ” .现在看来确实不是很准确,至于原因,在此简略解释: 首先,我们先解释一下在Java中解释执行和编译执行的区别. 解释执行:将编译好的字节码一行一行地翻译为机器 ...
shell常用测试命令
预定义变量: 预定义变量是由Bash程序预先定义好的一类特殊变量,用户只能使用预定义变量,而不能创建新的预定义变量,也不能直接为预定义变量赋值.预定义比变量使用"$"符合和另一个符 ...
Django模板语言之组合搜索
url.py from django.conf.urls import url from django.contrib import admin from app01 import views url ...
TypeError: cannot perform reduce with flexible type
想要解决这个错误,最好先明白numpy数据类型的dtype转换生成一个浮点数组 a=np.random.random(4) 输出 a array([0.0945377,0.52199916,0.62 ...