2. 程式人生 > 其它 >.NET Core使用Redis

.NET Core使用Redis

阿新 • • 發佈：2022-03-14

部署測試環境

本地啟動redis控制檯 && 安裝redis服務（用於除錯）
1.下載最新版redis，選擇.zip則是免安裝的版本
下載地址 (這是封裝好的基於windows的redis服務)

2.解壓到指定目錄，並執行cmd命令
3.在該資料夾下執行命令：

redis-server.exe redis.windows.conf

4.看到如下顯示，則表示啟動成功

5.將redis安裝成服務
在該資料夾下執行命令：redis-server.exe --service-install redis.windows.conf

去服務列表查詢服務，可以看到redis服務預設沒有開啟，開啟redis服務（可以設定為開機自動啟動）

之後會發現遠端訪問失敗，需要進行配置，在此不贅述，參考以下的第三篇文章
Tips:
也可以直接選擇安裝Redis-x64-3.0.504.msi

安裝管理工具(可選項)

Redis Desktop Manager

主要用於查詢db
1.連線redis

2.檢視/操作資料

Another Redis Desktop Manager

也可以使用Another Redis Desktop Manager，連結

使用

引用

StackExchange.Redis

建立連線

ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
var database = redis.GetDatabase();

使用String

var nameString = "name";
if (await database.StringSetAsync(nameString, "lulu"))
{
    var nameStringValue = await database.StringGetAsync(nameString);
    Console.WriteLine($"{nameString}的值為{nameStringValue}");

    //設定沒有時間限制的key
    await database.KeyIdleTimeAsync(nameString);
    await CheckIfKeyExist(database, nameString);

    //設定5秒後超時的key
    await database.KeyExpireAsync(nameString, DateTime.Now.AddSeconds(5));
    await CheckIfKeyExist(database, nameString);

    await Task.Delay(5000);
    await CheckIfKeyExist(database, nameString);
}

var name_not_exist = await database.StringGetAsync("name_not_exist");
if (name_not_exist.IsNull || name_not_exist.IsNullOrEmpty)
{
    Console.WriteLine($"{nameof(name_not_exist)}為空");
}

使用HashSet

string usersInfoHash = "usersInfo";
await database.HashSetAsync(usersInfoHash, new HashEntry[]
{
    new HashEntry ("number","1"),
    new HashEntry ("name","lulu"),
    new HashEntry ("sex","woman")
});
if (await database.HashExistsAsync(usersInfoHash, "name"))
{
    var count = database.HashLength(usersInfoHash);
    var nameValue = database.HashGet(usersInfoHash, "name");
    var keys = database.HashKeys(usersInfoHash);
    var values = await database.HashValuesAsync("usersInfo");

    await database.HashSetAsync(usersInfoHash, new HashEntry[] { new HashEntry("number", "2") });
    await database.HashSetAsync(usersInfoHash, new HashEntry[] { new HashEntry("age", "99") });
    count = database.HashLength(usersInfoHash);

    //key為HashIncrementTest的value，從1開始遞增，呼叫一次HashIncrement+1
    var hashIncrementTestKey = "HashIncrementTest";
    for (int i = 0; i < 3; i++)
        await database.HashIncrementAsync(usersInfoHash, hashIncrementTestKey);

    //每次呼叫遞減1
    for (int i = 0; i < 5; i++)
        await database.HashDecrementAsync(usersInfoHash, hashIncrementTestKey);

    if (await database.HashDeleteAsync(usersInfoHash, "name"))
    {
        Console.WriteLine($"刪除{usersInfoHash}中的name Field成功");
    }
    long deleteCount = await database.HashDeleteAsync(usersInfoHash, new RedisValue[] { "name", "number", "sex" });
    Console.WriteLine($"刪除{usersInfoHash}中的name/number/sex Field中的{deleteCount}個");

}

//重新命名
if (await database.KeyExistsAsync(usersInfoHash))
    await database.KeyRenameAsync(usersInfoHash, $"rename_{usersInfoHash}");

使用List

//push插入資料
var listKey = "ListKey1";
if (await database.KeyExistsAsync(listKey))
    await database.KeyDeleteAsync(listKey);

database.ListLeftPush(listKey, "Value1");
database.ListLeftPush(listKey, 2);
database.ListLeftPush(listKey, 3.33);

//指定資料後插入資料
await database.ListInsertAfterAsync(listKey, 2, 4);

//指定資料前插入資料
await database.ListInsertBeforeAsync(listKey, 2, 5);

//可以從佇列兩邊取出資料
//取ID最小的值
var leftPopValue = await database.ListLeftPopAsync(listKey);
//取ID最大的值
var rightPopValue = await database.ListRightPopAsync(listKey);

//可以從佇列兩邊插入資料
//ID最小
await database.ListLeftPushAsync(listKey, 6);
await database.ListLeftPushAsync(listKey, 8);
//ID最大
await database.ListRightPushAsync(listKey, 7.77);
//小數數字不精確
var val_7_77 = await database.ListGetByIndexAsync(listKey, 5);
await database.ListRightPushAsync(listKey, "9.99");


//修改指定位置value
Console.WriteLine($"{ await database.ListGetByIndexAsync(listKey, 1)}");
database.ListSetByIndex(listKey, 1, 999);
Console.WriteLine($"{ await database.ListGetByIndexAsync(listKey, 1)}");

var values = database.ListRange(listKey, 1, 10);
Console.WriteLine($"{JsonConvert.SerializeObject(values)}");

var length = database.ListLengthAsync(listKey);

//根據值移除資料
var deleteCount1 = await database.ListRemoveAsync(listKey, 999);

//根據位置移除資料
await database.ListTrimAsync(listKey, 0, 3);

//List允許加入重複值
database.ListLeftPush(listKey, "Value1");
database.ListLeftPush(listKey, "Value1");
database.ListLeftPush(listKey, "Value1");

使用Set

var setKey = "SetKey1";
var setKey2 = "SetKey2";
if (await database.KeyExistsAsync(setKey))
    await database.KeyDeleteAsync(setKey);
if (await database.KeyExistsAsync(setKey2))
    await database.KeyDeleteAsync(setKey2);

await database.SetAddAsync(setKey, "1.223");
await database.SetAddAsync(setKey, "2");
for (decimal i = 0; i < 10;)
{
    await database.SetAddAsync(setKey, i.ToString());
    i = i + (decimal)0.5;
}
if (await database.SetContainsAsync(setKey, 1))
    Console.WriteLine($"{setKey}包含value：1");
else
    Console.WriteLine($"{setKey}不包含value：1");
if (await database.SetContainsAsync(setKey, "2"))
    Console.WriteLine($"{setKey}包含value：2");
else
    Console.WriteLine($"{setKey}不包含value：2");

var length = await database.SetLengthAsync(setKey);
var values = await database.SetMembersAsync(setKey);
Console.WriteLine($"{JsonConvert.SerializeObject(values)}");

//取出資料，資料被移除
var val = await database.SetPopAsync(setKey);

//隨機取出一個數據，資料不被移除
var randomValue = await database.SetRandomMemberAsync(setKey);
//隨機取出n個數據，資料不被移除
var randomValues = await database.SetRandomMembersAsync(setKey, 5);

//set不允許插入相同資料
if (await database.SetAddAsync(setKey, "999"))
    Console.WriteLine($"{setKey}插入資料999：成功");
else
    Console.WriteLine($"{setKey}插入資料999：失敗");
if (await database.SetAddAsync(setKey, "999"))
    Console.WriteLine($"{setKey}插入資料999：成功");
else
    Console.WriteLine($"{setKey}插入資料999：失敗");

var scan1Result = database.SetScan(setKey, "2", 100, 0, 0);
foreach (var redisValue in scan1Result)
{
    Console.WriteLine($"{redisValue}");
}
await database.SetRemoveAsync(setKey, "999");

if (database.SetMove(setKey, setKey2, "2"))
    Console.WriteLine($"將2從{setKey}遷移到{setKey2}：成功(在{setKey}中2被移除)");
else
    Console.WriteLine($"將2從{setKey}遷移到{setKey2}：失敗");

使用SortSet

var sortSetKey = "SortSetKey1";
if (await database.KeyExistsAsync(sortSetKey))
    await database.KeyDeleteAsync(sortSetKey);

await database.SortedSetAddAsync(sortSetKey, 111, 111);
for (double i = 0; i < 10;)
{
    await database.SortedSetAddAsync(sortSetKey, i.ToString(), i);
    i = i + (double)0.5;
}

var sortSetValues = await database.SortAsync(sortSetKey);
Console.WriteLine($"{JsonConvert.SerializeObject(sortSetValues)}");


if (await database.SortedSetAddAsync(sortSetKey, "999", 999))
    Console.WriteLine($"{sortSetKey}插入資料999(分數999)：成功");
else
    Console.WriteLine($"{sortSetKey}插入資料999(分數999)：失敗");
//失敗
if (await database.SortedSetAddAsync(sortSetKey, "999", 999))
    Console.WriteLine($"{sortSetKey}插入資料999(分數999)：成功");
else
    Console.WriteLine($"{sortSetKey}插入資料999(分數999)：失敗");
//成功 可以加入同分數不同值的資料
if (await database.SortedSetAddAsync(sortSetKey, "888", 999))
    Console.WriteLine($"{sortSetKey}插入資料888(分數999)：成功");
else
    Console.WriteLine($"{sortSetKey}插入資料888(分數999)：失敗");
//失敗
if (await database.SortedSetAddAsync(sortSetKey, "999", 888))
    Console.WriteLine($"{sortSetKey}插入資料999(分數888)：成功");
else
    Console.WriteLine($"{sortSetKey}插入資料999(分數888)：失敗");

var length = await database.SortedSetLengthAsync(sortSetKey);

//根據排名條件讀取value
var rankValues = await database.SortedSetRangeByRankAsync(sortSetKey, start: 0, stop: 10, order: Order.Descending);
Console.WriteLine($"{JsonConvert.SerializeObject(rankValues)}");

//條件同上，讀取value+scroe
var rankWithScoresValues = await database.SortedSetRangeByRankWithScoresAsync(sortSetKey, start: 0, stop: 10, order: Order.Descending);
Console.WriteLine($"{JsonConvert.SerializeObject(rankWithScoresValues)}");

//降序讀取分數在0-10之間的資料value
var scoreValues = await database.SortedSetRangeByScoreAsync(sortSetKey, start: 0, stop: 10, order: Order.Descending);
Console.WriteLine($"{JsonConvert.SerializeObject(scoreValues)}");

//條件同上，讀取value+scroe
var scoreWithScoresValues = database.SortedSetRangeByScoreWithScoresAsync(sortSetKey, start: 0, stop: 10, order: Order.Descending);
Console.WriteLine($"{JsonConvert.SerializeObject(scoreWithScoresValues)}");

//根據value篩選
var rangeByValues = await database.SortedSetRangeByValueAsync(sortSetKey, 0, 998);
Console.WriteLine($"{JsonConvert.SerializeObject(rangeByValues)}");

//返回排名，預設從低到高，從0開始
var rank1 = await database.SortedSetRankAsync(sortSetKey, "888");
//不存在，返回null
var rank2 = await database.SortedSetRankAsync(sortSetKey, "325435435");


if (await database.SortedSetRemoveAsync(sortSetKey, "888"))
{
    Console.WriteLine($"刪除888:成功");
}
else
{
    Console.WriteLine($"刪除888:失敗");
}

//遞增2
var testMember = "testMember";
for (int i = 0; i < 10; i++)
    await database.SortedSetIncrementAsync(sortSetKey, testMember, 2);

for (int i = 0; i < 10; i++)
    await database.SortedSetDecrementAsync(sortSetKey, testMember, 3.6);

示例程式碼

RedisTestDemo

參考資料

Windows下搭建Redis伺服器
windows下安裝Redis並部署成服務

相關推薦

入門 Node.js Net 模組構建 TCP 網路服務

想做一個簡單的 Web API，這個時候就需要搭建一個 Web 伺服器，在 ASP.NET 中需要 IIS 來搭建伺服器，PHP 中需要藉助 Apache/Nginx 來實現，對於新手在還沒開始之前看到這麼多步驟，也許就要放棄了，但是在 Node.js

.NET進階篇06-async非同步、thread多執行緒2

知識需要不斷積累、總結和沉澱，思考和寫作是成長的催化劑 內容目錄 一、執行緒Thread

【譯】單頁面應用與ASP.NET Core 3.0

原文連結 隨著Angular,React,Vue以及其他一些前端技術的成熟，Web開發在過去的幾年中已經發生了很大的改變，從建立Web頁面轉向建立應用程式，同時從在服務端渲染標記，轉向直接在瀏覽器中渲染。大部分情況下，這使得

【譯】Pulumi：.NET Core雲架構

原文連結 本月伊始，Pulumi宣佈在他們支援的語言中新增了.NET Core。Pulumi是一個開源工具，支援在多個雲供應商上以程式碼的形式建立，開發並管理基礎架構，類似於HashiCorp Terraform。

ASP.NET Core的幾種託管方式

Kestrel Kestrel 是一個跨平臺的適用於 ASP.NET Core 的 Web 伺服器,預設包括在 ASP.NET Core 專案模板中。

.net core 3.0 Signalr - 03 使用MessagePack壓縮傳輸內容

MessagePack基礎介紹 Signalr預設使用的是json形式傳遞資料，但是signalr提供了靈活的擴充套件，支援MessagePack形式序列化資料，以增加效能降低網路傳輸的效果，極大的提高響應速度。

.net core 3.0 Signalr - 04 使用Redis做底板來支援橫向擴充套件

在實際的系統中，可能需要多臺機器部署;然而，Signalr的連線資訊是跟站點走的，舉個例子推送系統部署了A、B兩個伺服器，張三訪問A伺服器，李四訪問B伺服器，當張三通過A伺服器向李四推送的時候，A伺服器上是找不到李

.net core 3.0 Signalr - 05 使用jwt將使用者跟signalr關聯

Signalr是以Group、Connect為核心來進行推送，比如，給某個組、某個連線來推送，但實際場景中，核心應該是某個組、某個人；然而一個人可以對應多個連線(瀏覽器多個tab頁)；本節就來介紹下自行管理人、組、連線這些關

.net core 3.0 Signalr - 06 業務實現-業務分析

業務需求 人-專案關係一個人可以屬於多個專案，一個專案可以有多個人加入，通知的時候，可以通知專案內的所有人，也可以通知部分人或者某個責任人。

在 ASP.NET Core 專案中使用 AutoMapper 進行實體對映

前言         在實際專案開發過程中，我們使用到的各種 ORM 元件都可以很便捷的將我們獲取到的資料繫結到對應的 List<T> 集合中，因為我們最終想要在頁面上展示的資料與資料庫實體類之間可能存在很大的

.NET進階篇02-Delegate委託、Event事件

知識只有經過整理才能形成技能 一、概述 先說下委託，委託我們也經常用到。詳盡瞭解委託是必要的，不然在非同步多執行緒的程式設計中會一頭霧水。委託本質就是一個類，和我們平常定義的類沒多大區別。只是這個類的作

.NET進階篇03-Reflection反射、Attribute特性

知識需要不斷積累、總結和沉澱，思考和寫作是成長的催化劑 一、概述 反射其實無處不在，我們用VS進行除錯時候，檢視成員列表、修改變數值都是通過反射來實現的。我們寫業務程式碼可能很少去寫反射，但理解反射是從菜

.NET進階篇01-Generic泛型深入

知識只有經過整理才能形成技能 一、概述 泛型我們一定都用過，最常見的List<T>集合。.NET2.0開始支援泛型，建立的目的就是為了不同型別建立相同的方法或類，也包括介面，委託的泛型。比如常見的ORM對映，一個方

.NET進階篇-醜話先說，Flag先立

知識只有經過整理才能形成技能　　 一、煩惱絲 1、技術池太淺 作為開發者，工作了幾年，也總覺得技術棧和剛畢業區別不大，用的技術還都是N年前的，每每看到新東西，也只心裡哇塞驚歎一下，然後就迴歸於忙碌。怪自己的

.NET進階篇04-Serialize序列化、加密解密

知識需要不斷積累、總結和沉澱，思考和寫作是成長的催化劑 這篇很輕鬆，沒有什麼費腦子的，所以解析較少，程式碼較多，為數不多的拿來即用篇

如何使用Swagger為.NET Core 3.0應用新增JWT授權說明檔案

簡介 本教程採用WHY-WHAT-HOW黃金圈思維模式編寫，黃金圈法則強調的是從WHY為什麼學，到WHAT學到什麼，再到HOW如何學。從模糊到清晰的學習模式。大家的時間都很寶貴，我們做事前先想清楚為什麼要做，學完能達到什麼樣

net/http - 學習

Introduction 什麼是函式登記中心 跳轉 登記中心裡的處理函式是什麼 跳轉 登記中心裡的處理工具是什麼 跳轉

C# ODP.NET 呼叫Oracle函式返回值時報錯的一個解決方案

有人在社群問到：C#呼叫Oracle中自定義函式的返回值時，無法正常呼叫。但在PL/SQL中正常呼叫返回。

mysql8.0忘記密碼修改與net命令服務名無效問題

cmd中輸入net start mysql 提示：服務名無效 請進入MySQL的bin目錄，並在bin目錄開啟命令列視窗，或設定系統環境變數，在命令列視窗輸入：mysqld --install，回車，提示：Service successfully installed。

oracle net manager 資料傳輸安全步驟詳解

簡介 Net Manger可以管理服務命名和監聽程式。 所謂監聽程式就是一個Oracle伺服器上程序，負責監聽/響應客戶端對Oracle服務的請求。之前我們在安裝資料庫例項時，同時已經安裝了一個監聽程式，這點我們知道就行。