通用的序列號生成器庫

来源:http://www.cnblogs.com/shanyou/archive/2016/02/04/5180594.html

正如文章《通用的業務編號規則設計實現(附源碼)》 文章里需要一個多實例和線程安全的序列化生成器,在SQL Server 2012+ 版本 有一個通過.NET程式集的序列號transact-sql 函數 http://msdn.microsoft.com/zh-cn/library/ff878091.

正如文章《通用的業務編號規則設計實現(附源碼)》 文章里需要一個多實例和線程安全的序列化生成器,在SQL Server 2012+ 版本 有一個通過.NET程式集的序列號transact-sql 函數 http://msdn.microsoft.com/zh-cn/library/ff878091.aspx。 這篇文章向大家介紹一個使用SQL Server 和Sql Azure 以及Mongodb 實現的序列號生成器。

 

在Github上有個項目 https://github.com/getAddress/Sequence ,我Fork了一份,增加了一個Mongodb 實現,地址是https://github.com/geffzhang/Sequence。下麵我介紹下使用Mongodb實現的sequence 存儲,主要就是實現介面IstateStore

 

這裡實現的關鍵點就是在更新數據的時候如何保證原子性的操作,Mongo 可以使用findAndModify命令, findAndModify可以從資料庫查找返回一個文檔的同時更新/插入/刪除文檔,原子操作,線程安全,功能強大,原型複雜。

 

public async Task<bool> UpdateAsync(SequenceKey sequenceKey, ISequence sequence)

{

var sequenceEntity = sequence as Sequences;

sequenceEntity.Id = sequenceKey.Value;

 

var query = Query.And(Query.EQ("_id", ObjectId.Parse(sequenceKey.Value)));

var update = MongoDB.Driver.Builders.Update < Sequences>.Set( c => c.CurrentValue , sequenceEntity.CurrentValue);

 

var updatedSequenceEntity = this.Collection.FindAndModify(new FindAndModifyArgs() { Query = query, Update = update, VersionReturned = FindAndModifyDocumentVersion.Original, SortBy = null });

var doc = updatedSequenceEntity.ModifiedDocument;

return doc != null;

 

}

findAndModify命令中每個鍵對應的值如下所示。

findAndModify 字元竄,集合名。

query 查詢文檔,用來檢索文檔的條件。

sort 排序結果的條件。

update 修改器文檔,對所找到的文檔執行的更新。

remove 布爾類型,表示是否刪除文檔。

new 布爾類型,表示返回的是更新前的文檔還是更新後的文檔。預設是更新前的文檔。

"update"和"remove"必須有一個,也只能有一個。要是匹配不到文檔,這個命令會返回一個錯誤。

 

這個命令有些限制。它一次只能處理一個文檔,也不能執行upsert操作,只能更新已有文檔。

相比普通更新來說,findAndModify速度要慢一些。大概耗時相當於一次查找,一次更新和一次getLastError順序執行所需的時間。

 

使用起來非常簡單,下麵我們使用Mongodb 作為代碼示例:

通過Nuget 安裝getAddress.Sequence.Mongo:

 

  1. 根據業務需求創建一個序列化生成器,也就是SequenceKey ,Mongo 使用它的ObjectId 來作為Key

var stateProvider = GetStateProvider();

var sequenceGenerator = new SequenceGenerator(stateProvider);

var sequence = await CreateSequence(stateProvider,increment: 0, startAt: 5);

var sequenceKey = await stateProvider.AddAsync(sequence);

 

  1. 使用這個SequenceKey 就可以用調用了

    var stateProvider = GetStateProvider();

var sequenceGenerator = new SequenceGenerator(stateProvider);

var nextValue1 = await sequenceGenerator.NextAsync(new SequenceKey { Value = "56af206c7c2a5827389ad412"});

項目里有完整的單元測試用例,跑完整個單元測試用例,Mongodb的數據展示一下:

我們把數據存儲在一個叫做Sequences的Collection里,_id 列就是我們的sequenceKey。StartAt 表示起點, Increment 表示步長, MaxValue 表示最大值, MinValue 表示最小值,Cycle 表示達到最大值,從頭開始迴圈,CurrentValue 表示當前值。


您的分享是我們最大的動力!

更多相關文章
  • 上一篇,我們對hive的數據導出,以及集群Hive數據的遷移進行描述。瞭解到了基本的hive導出操作。這裡,我們將對hive的CLI及JDBC這些實用性很強的兩個方便進行簡要的介紹。 下麵我們開始介紹hive的CLI和JDBC。
  • 一、安裝 目前,官方最新穩定版本為3.0.7 # wget http://download.redis.io/releases/redis-3.0.7.tar.gz # cd /usr/local/ # tar xvf /root/redis-3.0.7.tar.gz # cd redis-3.0.
  • 以後我們會看到越來越多的機器人。春晚上也有。
  • 關於正則表達式
  • SQL(根據自己需要改列名、表名): delete from tableA where id not in (select min(id) from tableA group by name,age)
一周排行
  • 如題 報錯提示: 使用 JSON JavaScriptSerializer 進行序列化或反序列化時出錯。字元串的長度超過了為 maxJsonLength 屬性設置的值。","StackTrace 解決方案 在web.config 中configuration節點 插入 ...
  • 前言 這是一個國內TOP1000000000000學校畢業生的個人感想啊~~~ 最近真的很熱啊,自己在公司附近租的房子也沒有空調,淚奔。。。大學畢業也有半個月的時間了,墨跡了很長時間,才用github page把博客搭個差不多。歡迎大家去我的博客去看看啊~~~ 點擊這裡,去看看我的博客啊~~~ 從大 ...
  • EF Core中Fluent Api如何刪除指定數據表中的行 ...
  • 概述 Windows Community Toolkit 3.0 於 2018 年 6 月 2 日 Release,同時正式更名為 Windows Community Toolkit,原名為 UWP Community Toolkit。顧名思義,3.0 版本會更註重整個 Windows 平臺的工具實 ...
  • 1、前言 分散式已經成為了當前最熱門的話題,分散式框架也百花齊放,群雄逐鹿。從中心化服務治理框架,到去中心化分散式服務框架,再到分散式微服務引擎,這都是通過技術不斷積累改進而形成的結果。esb,網關,nginx網關 這些中心化服務治理框架現在都是各個公司比較主流的架構,而最近幾年大家炒的比較火的去中 ...
  • 推薦加【QQ49300063】專業盜取微信密碼,破解微信密碼,查詢微信聊天記錄,不成功不收費!!!! 隨著信息時代的來臨,很多人使用上了微信,微信的出現使得人們的生活變的十便利。人們不僅在工作中使用它,在社交中也讓其發揮了重要的作用。微信現在已經漸漸成為了人們生活中不能缺少的一部分。使用微信除了其方 ...
  • 寫在前面 本文地址:http://www.cnblogs.com/yilezhu/p/9315644.html 作者:yilezhu 上一篇關於Asp.Net Core Web Api圖片上傳的文章使用的是mongoDB進行圖片的存儲,文章發佈後,張隊就來了一句,說沒有使用GridFS。的確博主只是 ...
  • 2.矩陣專欄¶ 吐槽一下:矩陣本身不難,但是矩陣的寫作太蛋疼了 (⊙﹏⊙)汗 還好有Numpy,不然真的崩潰了... LaTex有沒有一個集成了很多常用公式以及推導或者含題庫的線上編輯器? 代碼褲子:https://github.com/lotapp/BaseCode 線上編程系:https://m ...
  • 上兩篇文章我向大家介紹了一些線程間的基本通信方式,那麼這篇文章就和大家聊聊volatile關鍵字的相關知識。這個關鍵字在我們的日常開發中很少會使用到,而在JDK的Lock包和Concurrent包下的類則大量的使用了這個關鍵字,因為它有如下兩個特性: 1.確保記憶體可見性 2.禁止指令重排序 接下來就 ...
  • JRE(Java Runtime Environment Java運行環境) 包括Java虛擬機(JVM Java Virtual Machine)和Java程式所需的核心類庫等,如果想要運行一個開發好的Java程式,電腦中只需要安裝JRE即可。 JDK(Java Development Kit ...