基於.net ,使用幾種常見的NoSQL數據庫

目錄

• 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實現熱搜
  011Redis中使用hash使用
  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);