搜尋
首頁資料庫Redis一起聊聊使用redis實現分散式緩存

這篇文章為大家帶來了關於Redis的相關知識,其中主要整理了分散式快取的相關問題,分散式就是有多個應用程式組成,可能分佈在不同的伺服器上,最終都是在為web端提供服務,下面一起來看一下,希望對大家有幫助。

一起聊聊使用redis實現分散式緩存

推薦學習:Redis影片教學

分散式快取描述:

#分散式快取重點是在分散式上,相信大家接觸過的分散式有很多中,像分散式開發,分散式部署,分散式鎖定、事物、系統等有很多。使我們對分散式本身就有一個很明確的認識,分散式就是有多個應用程式組成,可能分佈在不同的伺服器上,最終都是在為web端提供服務。
分散式快取有以下幾點優點:

  1. 所有的Web伺服器上的快取資料都是相同的,不會因為應用程式不同,伺服器的不同導致快取資料的不一樣。
  2. 快取的是獨立的不受Web伺服器的重新啟動或被刪除加入的影響,也就是說這些Web的改變不到導致快取資料的改變。

傳統的單體應用程式架構因為使用者的訪問量的不高,快取的存在大多數都是儲存使用者的信息,以及一些頁面,大多數的操作都是直接和DB進行讀寫交互,這種架構簡單,也稱為簡單架構,
傳統的OA項目比如ERP,SCM,CRM等系統因為用戶量不大也是因為大多數公司業務的原因,單體應用架構還是很常用的架構,但有些系統隨著使用者量的增加,業務的擴張擴展,導致DB的瓶頸的出現。

以下我所了解到的關於這種情況的處理有以下兩種

(1):當使用者存取量不大,但是讀寫的資料量很大的時候,我們一般採取的是,對DB進行讀寫分離、一主多從、對硬體升級的方式來解決DB瓶頸的問題。
  這樣的缺點也同樣純在:

1、用戶量大的時候怎麼辦? ,
2、對於性能的提升有限,
3、性價比不高。要提升一點效能就需要花費很多代價,(打個比方,現在的I/O吞吐量是0.9的需要提升到1.0,我們在增加機器配置的情況下這個價格確實很可觀的)

# (2):當使用者訪問量也增加的時候,我們就需要引入快取了來解決了,一張圖描述快取的大致的作用。

快取主要針對的是不經常發生改變的並且訪問量很大的數據,DB資料庫可以理解為只作為數據固化的或只用來讀取經常發生改變的數據,上圖中我沒有畫SET的操作,就是想特意說明一下,緩存的存在可以作為一個臨時的數據庫,我們可以通過定時的任務的方式去同步緩存和數據庫中的數據,這樣做的好處是可以轉移資料庫的壓力到快取中。

快取的出現解決了資料庫壓力的問題,但是當以下情況發生的時候,快取就不在起到作用了,快取穿透、快取擊穿、快取雪崩這三種情況

快取穿透:我們的程式中用快取的時候一般採取的是先去快取中查詢我們想要的快取數據,如果快取中不存在我們想要的數據的話,快取就失去了做用(快取失效)我們就是需要伸手向DB庫去要數據,這個時候這種動作過多資料庫就崩潰了,這種情況需要我們去預防了。比如說:我們向快取獲取一個用戶信息,但是故意去輸入一個緩存中不存在的用戶信息,這樣就避過了緩存,把壓力重新轉移到數據上面了。對於這種問題我們可以採取,把第一次訪問的數據進行緩存,因為緩存查不到用戶信息,數據庫也查詢不到用戶信息,這個時候避免重複的訪問我們把這個請求緩存起來,把壓力重新轉向快取中,有人會有疑問了,當存取的參數有上萬個都是不重複的參數並且都是可以躲避快取的怎麼辦,我們同樣把資料存起來設定一個較短過期時間清理快取。

快取擊穿:事情是這樣的,對於一些設定了過期時間的快取KEY,在過期的時候,程式被高並發的存取了(快取失效),這個時候使用互斥鎖來解決問題,

互斥鎖原理:通俗的描述就是,一萬個使用者存取了,但是只有一個使用者可以拿到存取資料庫的權限,當這個用戶拿到這個權限之後重新建立緩存,這時候剩下的訪客因為沒有拿到權限,就原地等待著去存取快取。

永不過期:有人就會想了,我不設定過期時間不就行了嗎?可以,但是這樣做也是有缺點的,我們需要定期的取更新緩存,這個時候緩存中的資料比較延遲。

快取雪崩:是指多種快取設定了同一時間過期,這個時候大批量的資料存取來了,(快取失效)資料庫DB的壓力又上來了。解決方法在設定過期時間的時候在過期時間的基礎上增加一個隨機數盡可能的保證緩存不會大面積的同事失效。

專案準備

1、先安裝Redis,可以參考這裡
2、然後下載安裝:客戶端工具:RedisDesktopManager(方便管理)
3.在我們的專案Nuget中引用 Microsoft.Extensions.Caching.Redis

為此我們新建一個ASP.NET Core MVC項目,在專案Startup類別的ConfigureServices方法中先註冊Redis服務:

public void ConfigureServices(IServiceCollection services)
{
    //将Redis分布式缓存服务添加到服务中
    services.AddDistributedRedisCache(options =>
    {
        //用于连接Redis的配置  Configuration.GetConnectionString("RedisConnectionString")读取配置信息的串
        options.Configuration = "localhost";// Configuration.GetConnectionString("RedisConnectionString");
        //Redis实例名DemoInstance
        options.InstanceName = "DemoInstance";
    });
    services.AddMvc();
}

也可以在上面註冊Redis服務的時候,指定Redis伺服器的IP位址、連接埠號碼和登入密碼:

public void ConfigureServices(IServiceCollection services)
{
    //将Redis分布式缓存服务添加到服务中
    services.AddDistributedRedisCache(options =>
    {
        //用于连接Redis的配置  Configuration.GetConnectionString("RedisConnectionString")读取配置信息的串
        options.Configuration = "192.168.1.105:6380,password=1qaz@WSX3edc$RFV";//指定Redis服务器的IP地址、端口号和登录密码
        //Redis实例名DemoInstance
        options.InstanceName = "DemoInstance";
    });
    services.AddMvc();
}

後面我們會解釋上面options.InstanceName設定的Redis實例名稱DemoInstance是用來做什麼的

此外還可以在services.AddDistributedRedisCache方法中指定Redis伺服器的逾時時間,如果呼叫後面介紹的IDistributedCache介面中的方法,對Redis伺服器進行的操作逾時了,會拋出RedisConnectionException和RedisTimeoutException異常,所以下面我們在註冊Redis服務的時候,指定了三個超時時間:

public void ConfigureServices(IServiceCollection services)
{
    //将Redis分布式缓存服务添加到服务中
    services.AddDistributedRedisCache(options =>
    {
        options.ConfigurationOptions = new StackExchange.Redis.ConfigurationOptions()
        {
            Password = "1qaz@WSX3edc$RFV",
            ConnectTimeout = 5000,//设置建立连接到Redis服务器的超时时间为5000毫秒
            SyncTimeout = 5000,//设置对Redis服务器进行同步操作的超时时间为5000毫秒
            ResponseTimeout = 5000//设置对Redis服务器进行操作的响应超时时间为5000毫秒
        };

        options.ConfigurationOptions.EndPoints.Add("192.168.1.105:6380");
        options.InstanceName = "DemoInstance";
    });
    services.AddMvc();
}

其中ConnectTimeout是建立連接到Redis伺服器的超時時間,而SyncTimeout和ResponseTimeout是對Redis伺服器進行數據操作的超時時間。注意上面我們使用了options.ConfigurationOptions屬性來設定Redis伺服器的IP位址、連接埠號碼和登入密碼

IDistributedCache 介面

在專案中引用:using Microsoft. Extensions.Caching.Distributed; 使用IDistributedCache

IDistributedCache介麵包含同步和非同步方法。介面允許在分散式快取實作中新增、檢索和刪除項目。 IDistributedCache介麵包含以下方法:
Get、 GetAsync
採用字串鍵並以byte[]形式檢索快取項目(如果在快取中找到)。
Set、SetAsync
使用字串鍵新增或變更項目(byte[]形式)。
Refresh、RefreshAsync
根據鍵刷新快取中的項,並重設其可調過期逾時值(如果有)。
Remove、RemoveAsync
根據鍵刪除快取項目。如果傳入Remove方法的鍵在Redis中不存在,Remove方法不會報錯,只是什麼都不會發生而已,但是如果傳入Remove方法的參數為null,則會拋出異常。

如上所述,由於IDistributedCache介面的Set和Get方法,是透過byte[]位元組數組來向Redis存取資料的,所以從某種意義上來說不是很方便,下面我封裝了一個RedisCache類,可以向Redis存取任何類型的資料。

其中用到了Json.NET Nuget包,來做Json格式的序列化與反序列化:

using Microsoft.Extensions.Caching.Distributed;
using Newtonsoft.Json;
using System.Text;

namespace AspNetCoreRedis.Assembly
{
    /// <summary>
    /// RedisCache缓存操作类
    /// </summary>
    public class RedisCache
    {
        protected IDistributedCache cache;

        /// <summary>
        /// 通过IDistributedCache来构造RedisCache缓存操作类
        /// </summary>
        /// <param>IDistributedCache对象
        public RedisCache(IDistributedCache cache)
        {
            this.cache = cache;
        }

        /// <summary>
        /// 添加或更改Redis的键值,并设置缓存的过期策略
        /// </summary>
        /// <param>缓存键
        /// <param>缓存值
        /// <param>设置Redis缓存的过期策略,可以用其设置缓存的绝对过期时间(AbsoluteExpiration或AbsoluteExpirationRelativeToNow),也可以设置缓存的滑动过期时间(SlidingExpiration)
        public void Set(string key, object value, DistributedCacheEntryOptions distributedCacheEntryOptions)
        {
            //通过Json.NET序列化缓存对象为Json字符串
            //调用JsonConvert.SerializeObject方法时,设置ReferenceLoopHandling属性为ReferenceLoopHandling.Ignore,来避免Json.NET序列化对象时,因为对象的循环引用而抛出异常
            //设置TypeNameHandling属性为TypeNameHandling.All,这样Json.NET序列化对象后的Json字符串中,会包含序列化的类型,这样可以保证Json.NET在反序列化对象时,去读取Json字符串中的序列化类型,从而得到和序列化时相同的对象类型
            var stringObject = JsonConvert.SerializeObject(value, new JsonSerializerSettings()
            {
                ReferenceLoopHandling = ReferenceLoopHandling.Ignore,
                TypeNameHandling = TypeNameHandling.All
            });

            var bytesObject = Encoding.UTF8.GetBytes(stringObject);//将Json字符串通过UTF-8编码,序列化为字节数组

            cache.Set(key, bytesObject, distributedCacheEntryOptions);//将字节数组存入Redis
            Refresh(key);//刷新Redis
        }

        /// <summary>
        /// 查询键值是否在Redis中存在
        /// </summary>
        /// <param>缓存键
        /// <returns>true:存在,false:不存在</returns>
        public bool Exist(string key)
        {
            var bytesObject = cache.Get(key);//从Redis中获取键值key的字节数组,如果没获取到,那么会返回null

            if (bytesObject == null)
            {
                return false;
            }

            return true;
        }

        /// <summary>
        /// 从Redis中获取键值
        /// </summary>
        /// <typeparam>缓存的类型</typeparam>
        /// <param>缓存键
        /// <param>是否获取到键值,true:获取到了,false:键值不存在
        /// <returns>缓存的对象</returns>
        public T Get<t>(string key, out bool isExisted)
        {
            var bytesObject = cache.Get(key);//从Redis中获取键值key的字节数组,如果没获取到,那么会返回null

            if (bytesObject == null)
            {
                isExisted = false;
                return default(T);
            }

            var stringObject = Encoding.UTF8.GetString(bytesObject);//通过UTF-8编码,将字节数组反序列化为Json字符串

            isExisted = true;

            //通过Json.NET反序列化Json字符串为对象
            //调用JsonConvert.DeserializeObject方法时,也设置TypeNameHandling属性为TypeNameHandling.All,这样可以保证Json.NET在反序列化对象时,去读取Json字符串中的序列化类型,从而得到和序列化时相同的对象类型
            return JsonConvert.DeserializeObject<t>(stringObject, new JsonSerializerSettings()
            {
                TypeNameHandling = TypeNameHandling.All
            });
        }

        /// <summary>
        /// 从Redis中删除键值,如果键值在Redis中不存在,该方法不会报错,只是什么都不会发生
        /// </summary>
        /// <param>缓存键
        public void Remove(string key)
        {
            cache.Remove(key);//如果键值在Redis中不存在,IDistributedCache.Remove方法不会报错,但是如果传入的参数key为null,则会抛出异常
        }

        /// <summary>
        /// 从Redis中刷新键值
        /// </summary>
        /// <param>缓存键
        public void Refresh(string key)
        {
            cache.Refresh(key);
        }
    }
}</t></t>

使用測試

然後我們在ASP.NET Core MVC專案中,新建一個CacheController,然後在其Index方法中來測試RedisCache類別的相關方法:

public class CacheController : Controller
{
    protected RedisCache redisCache;

    //由于我们前面在Startup类的ConfigureServices方法中调用了services.AddDistributedRedisCache来注册Redis服务,所以ASP.NET Core MVC会自动依赖注入下面的IDistributedCache cache参数
    public CacheController(IDistributedCache cache)
    {
        redisCache = new RedisCache(cache);
    }

    public IActionResult Index()
    {
        bool isExisted;
        isExisted = redisCache.Exist("abc");//查询键值"abc"是否存在
        redisCache.Remove("abc");//删除不存在的键值"abc",不会报错

        string key = "Key01";//定义缓存键"Key01"
        string value = "This is a demo key !";//定义缓存值

        redisCache.Set(key, value, new DistributedCacheEntryOptions()
        {
            AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(10)
        });//设置键值"Key01"到Redis,使用绝对过期时间,AbsoluteExpirationRelativeToNow设置为当前系统时间10分钟后过期

        //也可以通过AbsoluteExpiration属性来设置绝对过期时间为一个具体的DateTimeOffset时间点
        //redisCache.Set(key, value, new DistributedCacheEntryOptions()
        //{
        //    AbsoluteExpiration = DateTimeOffset.Now.AddMinutes(10)
        //});//设置键值"Key01"到Redis,使用绝对过期时间,AbsoluteExpiration设置为当前系统时间10分钟后过期

        var getVaue = redisCache.Get<string>(key, out isExisted);//从Redis获取键值"Key01",可以看到getVaue的值为"This is a demo key !"

        value = "This is a demo key again !";//更改缓存值

        redisCache.Set(key, value, new DistributedCacheEntryOptions()
        {
            SlidingExpiration = TimeSpan.FromMinutes(10)
        });//将更改后的键值"Key01"再次缓存到Redis,这次使用滑动过期时间,SlidingExpiration设置为10分钟

        getVaue = redisCache.Get<string>(key, out isExisted);//再次从Redis获取键值"Key01",可以看到getVaue的值为"This is a demo key again !"

        redisCache.Remove(key);//从Redis中删除键值"Key01"

        return View();
    }
}</string></string>

前面我們在專案的Startup類別ConfigureServices方法中,呼叫services.AddDistributedRedisCache註冊Redis服務的時候,有設定options.InstanceName = "DemoInstance",那麼這個InstanceName到底有什麼用呢?

當我們在上面的CacheController中呼叫Index方法的下面程式碼後:

string key = "Key01";//定义缓存键"Key01"
string value = "This is a demo key !";//定义缓存值

redisCache.Set(key, value, new DistributedCacheEntryOptions()
{
    AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(10)
});//设置键值"Key01"到Redis,使用绝对过期时间,AbsoluteExpirationRelativeToNow设置为当前系统时间10分钟后过期

我們使用redis-cli登入到Redis伺服器中,使用Keys *指令查看目前Redis服務中儲存的所有按鍵時,可以看到結果如下:

可以看到雖然我們程式碼中存入Redis的鍵是"Key01",但實際上在Redis服務中儲存的鍵是"DemoInstanceKey01",所以實際上真正存入Redis服務中的鍵是「InstanceName 鍵」這種組合鍵,因此我們可以透過設定不同的InstanceName來為不同的Application在Redis中做資料隔離,這就是InstanceName的作用

推薦學習:Redis影片教學

#

以上是一起聊聊使用redis實現分散式緩存的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述
本文轉載於:CSDN。如有侵權,請聯絡admin@php.cn刪除
為什麼要使用redis?利益和優勢為什麼要使用redis?利益和優勢Apr 14, 2025 am 12:07 AM

Redis是一個強大的數據庫解決方案,因為它提供了極速性能、豐富的數據結構、高可用性和擴展性、持久化能力以及廣泛的生態系統支持。 1)極速性能:Redis的數據存儲在內存中,讀寫速度極快,適合高並發和低延遲應用。 2)豐富的數據結構:支持多種數據類型,如列表、集合等,適用於多種場景。 3)高可用性和擴展性:支持主從復制和集群模式,實現高可用性和水平擴展。 4)持久化和數據安全:通過RDB和AOF兩種方式實現數據持久化,確保數據的完整性和可靠性。 5)廣泛的生態系統和社區支持:擁有龐大的生態系統和活躍社區,

了解NOSQL:Redis的關鍵特徵了解NOSQL:Redis的關鍵特徵Apr 13, 2025 am 12:17 AM

Redis的關鍵特性包括速度、靈活性和豐富的數據結構支持。 1)速度:Redis作為內存數據庫,讀寫操作幾乎瞬時,適用於緩存和會話管理。 2)靈活性:支持多種數據結構,如字符串、列表、集合等,適用於復雜數據處理。 3)數據結構支持:提供字符串、列表、集合、哈希表等,適合不同業務需求。

REDIS:確定其主要功能REDIS:確定其主要功能Apr 12, 2025 am 12:01 AM

Redis的核心功能是高性能的內存數據存儲和處理系統。 1)高速數據訪問:Redis將數據存儲在內存中,提供微秒級別的讀寫速度。 2)豐富的數據結構:支持字符串、列表、集合等,適應多種應用場景。 3)持久化:通過RDB和AOF方式將數據持久化到磁盤。 4)發布訂閱:可用於消息隊列或實時通信系統。

REDIS:流行數據結構指南REDIS:流行數據結構指南Apr 11, 2025 am 12:04 AM

Redis支持多種數據結構,具體包括:1.字符串(String),適合存儲單一值數據;2.列表(List),適用於隊列和棧;3.集合(Set),用於存儲不重複數據;4.有序集合(SortedSet),適用於排行榜和優先級隊列;5.哈希表(Hash),適合存儲對像或結構化數據。

redis計數器怎麼實現redis計數器怎麼實現Apr 10, 2025 pm 10:21 PM

Redis計數器是一種使用Redis鍵值對存儲來實現計數操作的機制,包含以下步驟:創建計數器鍵、增加計數、減少計數、重置計數和獲取計數。 Redis計數器的優勢包括速度快、高並發、持久性和簡單易用。它可用於用戶訪問計數、實時指標跟踪、遊戲分數和排名以及訂單處理計數等場景。

redis命令行怎麼用redis命令行怎麼用Apr 10, 2025 pm 10:18 PM

使用 Redis 命令行工具 (redis-cli) 可通過以下步驟管理和操作 Redis:連接到服務器,指定地址和端口。使用命令名稱和參數向服務器發送命令。使用 HELP 命令查看特定命令的幫助信息。使用 QUIT 命令退出命令行工具。

redis集群模式怎麼搭建redis集群模式怎麼搭建Apr 10, 2025 pm 10:15 PM

Redis集群模式通過分片將Redis實例部署到多個服務器,提高可擴展性和可用性。搭建步驟如下:創建奇數個Redis實例,端口不同;創建3個sentinel實例,監控Redis實例並進行故障轉移;配置sentinel配置文件,添加監控Redis實例信息和故障轉移設置;配置Redis實例配置文件,啟用集群模式並指定集群信息文件路徑;創建nodes.conf文件,包含各Redis實例的信息;啟動集群,執行create命令創建集群並指定副本數量;登錄集群執行CLUSTER INFO命令驗證集群狀態;使

redis怎麼讀取隊列redis怎麼讀取隊列Apr 10, 2025 pm 10:12 PM

要從 Redis 讀取隊列,需要獲取隊列名稱、使用 LPOP 命令讀取元素,並處理空隊列。具體步驟如下:獲取隊列名稱:以 "queue:" 前綴命名,如 "queue:my-queue"。使用 LPOP 命令:從隊列頭部彈出元素並返回其值,如 LPOP queue:my-queue。處理空隊列:如果隊列為空,LPOP 返回 nil,可先檢查隊列是否存在再讀取元素。

See all articles

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

AI Hentai Generator

AI Hentai Generator

免費產生 AI 無盡。

熱門文章

R.E.P.O.能量晶體解釋及其做什麼(黃色晶體)
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.最佳圖形設置
3 週前By尊渡假赌尊渡假赌尊渡假赌
R.E.P.O.如果您聽不到任何人,如何修復音頻
3 週前By尊渡假赌尊渡假赌尊渡假赌
WWE 2K25:如何解鎖Myrise中的所有內容
4 週前By尊渡假赌尊渡假赌尊渡假赌

熱工具

ZendStudio 13.5.1 Mac

ZendStudio 13.5.1 Mac

強大的PHP整合開發環境

SublimeText3 英文版

SublimeText3 英文版

推薦:為Win版本,支援程式碼提示!

DVWA

DVWA

Damn Vulnerable Web App (DVWA) 是一個PHP/MySQL的Web應用程序,非常容易受到攻擊。它的主要目標是成為安全專業人員在合法環境中測試自己的技能和工具的輔助工具,幫助Web開發人員更好地理解保護網路應用程式的過程,並幫助教師/學生在課堂環境中教授/學習Web應用程式安全性。 DVWA的目標是透過簡單直接的介面練習一些最常見的Web漏洞,難度各不相同。請注意,該軟體中

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

EditPlus 中文破解版

EditPlus 中文破解版

體積小,語法高亮,不支援程式碼提示功能