基於.net ,使用幾種常見的NoSQL資料庫
阿新 • • 發佈:2020-01-10
目錄
- 0 .net中的快取物件
- 1.MemCached
- 2.Redis
- 3.MongoDB
- 示例完整原始碼地址
2020年1月10日 10:10:10
shanzm
0 .net中的快取物件
MemoryCache物件
HttpContext.Cache (Asp.net)物件
示例:(詳見:001MemoryCache)
//MemoryCache是存入到程式程序的記憶體中的,程式重啟之後就沒了 //新增引用:System.Runtime.Caching //新建一個快取物件,使用預設的快取物件 MemoryCache memCache = MemoryCache.Default; //快取以鍵值對的形式儲存,快取的生命期是10s memCache.Add("name", "shanzm", DateTimeOffset.Now.AddSeconds(10));
1.MemCached
安裝包下載:推薦一個編譯好的安裝包
NuGet:PM> Install-Package EnyimMemcached
MemCached中的Cas操作:(詳見:003Cas操作)
示例:(詳見:002MemCachedDemo)
//建立配置物件 MemcachedClientConfiguration memConfig = new MemcachedClientConfiguration(); memConfig.AddServer("127.0.0.1:11211"); //建立MemcachedClient物件 using (MemcachedClient memClient = new MemcachedClient(memConfig)) { //寫入MemCached中 memClient.Store(Enyim.Caching.Memcached.StoreMode.Set, "Name", "shanzm"); memClient.Store(Enyim.Caching.Memcached.StoreMode.Set, "Age", "100"); //讀取資料 string name = memClient.Get<string>("Name"); if (name == null) { Console.WriteLine("無快取"); } else { Console.WriteLine(name); } //刪除資料 Console.WriteLine(memClient.Get<string>("Age")); memClient.Remove("Age"); if (null == memClient.Get<string>("Age")) { Console.WriteLine("已經將Key為Age的資料從MemCached伺服器中清除"); } Console.ReadKey(); }
2.Redis
安裝Redis(官方為windows版,微軟自己維護一個開源版本)
常用的命令:參考
安裝Redis GUI客戶端:RedisDesktopManager (推薦一個cracked 2019.5版本)
NuGet:PM>Install-Package StackExchange.Redist(注意其所支援的dotnet版本)
官方地址Redis中的六種資料型別的具體操作及使用案例
005使用Redis計算新聞點選量
006Redis中的list使用
007模擬註冊傳送郵件驗證
008Redis中的set使用
009Redis中的sorted set使用
010Redis中使用sorted set實現熱搜
012Redis中的geo使用(注意只支援最新版本的Redis)
015Redis實現隨機分紅包
示例:(詳見:004RedisDemo)
//注意此處我們使用非同步方法
using (ConnectionMultiplexer conn = await ConnectionMultiplexer.ConnectAsync("127.0.0.1:6379"))
{
//預設是0號資料庫,若是其他資料庫,如3號資料庫,conn.GetDatabase(3)
IDatabase db = conn.GetDatabase();
//寫入資料
await db.StringSetAsync("Name", "張三", TimeSpan.FromSeconds(10));
//批量寫入(使用Redis中Batch物件 見013Redis的批量操作)
KeyValuePair<RedisKey, RedisValue>[] kvs = new KeyValuePair<RedisKey, RedisValue>[3];
kvs[0] = new KeyValuePair<RedisKey, RedisValue>("A", "a");
kvs[1] = new KeyValuePair<RedisKey, RedisValue>("B", "b");
kvs[2] = new KeyValuePair<RedisKey, RedisValue>("C", "c");
await db.StringSetAsync(kvs);
//讀取資料(查詢不到資料返回為null)
string name = await db.StringGetAsync("Name");
string A = await db.StringGetAsync("A");
//刪除資料
db.KeyDelete("A");
//判斷是否存在某條資料
if (!db.KeyExists("A"))
{
MessageBox.Show("已刪除Key值為‘A’的資料");
}
//對已經儲存的資料設定過期時間
db.KeyExpire("B", TimeSpan.FromSeconds(10));
}
3.MongoDB
安裝MongoDB(官方地址)
安裝MongoDB GUI客戶端:Robo3T
NuGet:PM>Install-Package MongoDB.Driver -Version 2.5.0
(注意預設安裝最新版本可能會報錯
親測2.5.0版本和 .net Framework版本是4.6.1完美支援)MongoDB中的完整的增刪改查,見:017MongoDB中的CURD
示例:(詳見:016MongoDBDemo)
//連線MongoDB服務,建立物件
MongoClient client = new MongoClient("mongodb://127.0.0.1:27017");
//獲取名為:TestDb1的資料庫,若是沒有則建立!
IMongoDatabase db = client.GetDatabase("TestDb1");
//獲取名為名為Personsde表(collection可以理解為表)若是沒有則建立!
IMongoCollection<Person> persons = db.GetCollection<Person>("Persons");
Person p1 = new Person() { Id = 0001, Name = "shanzm", Age = 25 };
Person p2 = new Person() { Id = 002, Name = "shanzm" };//MongoDB會對Age預設填充為0
persons.InsertOne(p1);
persons.InsertOne(p2);