2. 程式人生 > >stackExchange.redis的使用

stackExchange.redis的使用

阿新 • • 發佈：2017-08-16
shell bsp disabled dbr for 方式 shel point org

在StackExchange.Redis中最重要的對象是ConnectionMultiplexer類， 它存在於StackExchange.Redis命名空間中。 這個類隱藏了Redis服務的操作細節，ConnectionMultiplexer類做了很多東西， 在所有調用之間它被設計為共享和重用的。 不應該為每一個操作都創建一個ConnectionMultiplexer 。 ConnectionMultiplexer是線程安全的 ， 推薦使用下面的方法。 在所有後續示例中 ， 都假定你已經實例化好了一個ConnectionMultiplexer類，它將會一直被重用 ， 現在我們來創建一個ConnectionMultiplexer實例。它是通過ConnectionMultiplexer.Connect 或者 ConnectionMultiplexer.ConnectAsync，
傳遞一個連接字符串或者一個ConfigurationOptions 對象來創建的。 連接字符串可以是以逗號分割的多個服務的節點， 我們僅僅需要連接一個在本地計算機中的redis服務,redis服務的默認端口是6379. using StackExchange.Redis; ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");//127.0.0.1 // ^^^ store and re-use this!!! 註意 : ConnectionMultiplexer 實現了IDisposable接口當我們不再需要是可以將其釋放的 , 這裏我故意不使用 using 來釋放他。 簡單來講創建一個ConnectionMultiplexer是十分昂貴的 ， 一個好的主意是我們一直重用一個ConnectionMultiplexer對象。
一個復雜的的場景中可能包含有主從復制 ， 對於這種情況，只需要指定所有地址在連接字符串中（它將會自動識別出主服務器） ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("server1:6379,server2:6379"); 假設這裏找到了兩臺主服務器，將會對兩臺服務進行裁決選出一臺作為主服務器來解決這個問題 ， 這種情況是非常罕見的 ，我們也應該避免這種情況的發生。 現在你已經擁有了一個 ConnectionMultiplexer ， 下面三件事情可能是你想要做的。 1. 訪問數據庫。（註意在使用集群的情況下，一個數據庫可能會分部在多個節點中）
2. 使用redis的發布訂閱功能 3. 維護和監控一臺服務器 訪問數據庫 訪問數據庫的操作非常簡單: IDatabase db = redis.GetDatabase(); GetDatabase 返回一個IDatabase接口。 註意 redis允許配置多個數據庫，可以在調用GetDatabase() 時候指定數據庫.另外，如果你計劃使用異步的api ， Task.AsyncState 必須擁有一個值 ，也可以這樣指定。 int databaseNumber = ... object asyncState = ... IDatabase db = redis.GetDatabase(databaseNumber, asyncState); 現在你已經擁有了一個 IDatabase 對象 ， 他可以對redis數據庫進行操作。所有的方法都有同步和異步兩個版本 ， 按照微軟的命名約定 ，所有的異步方法都以Async結尾。 最簡單的操作 存儲和獲取一個值 。 string value = "abcdefg"; db.StringSet("mykey", value); ... string value = db.StringGet("mykey"); Console.WriteLine(value); // writes: "abcdefg" String前綴這裏代表的是Redis中的String類型 ， 和.net中的String類型有很大的區別 ， 盡管兩者都可以保存字符串類型。然後 ，Redis允許鍵值為二進制數據 ， 示例如下： byte[] key = ..., value = ...; db.StringSet(key, value); ... byte[] value = db.StringGet(key); StackExchange.Redis 支持所有的 redis shell命令, 具體可以參考redis官網。 StackExchange.Redis 使用-發布訂閱 使用Redis的發布訂閱功能 redis另一個常見的用途是發布訂閱功能 。 它非常的簡單 ，當連接失敗時 ConnectionMultiplexer 會自動重新進行訂閱 。 ISubscriber sub = redis.GetSubscriber(); GetSubscriber 方法返回一個 ISubscriber 類型的實例 。發布訂閱功能沒有數據庫的概念，我們可以為其提供一個 async-state 。所有的訂閱都是全局的： ISubscriber 實例不是他們的生命周期 , 發布訂閱的特性在redis中被定義為 “channels” ， 渠道不需要預先定義在數據庫中 。 訂閱操作需要一個渠道 名稱和一個回調函數來處理發布的消息。 sub.Subscribe("messages", (channel, message) => { Console.WriteLine((string)message); }); 你可以發布一個消息到指定的渠道中： sub.Publish("messages", "hello"); 他將會將 “hello” 這個消息發布到所有訂閱了messages渠道的客戶端（幾乎是實時的）。 和之前一樣渠道的名稱和消息也可以是二進制的。 指定消息發布的順序（Message Order） 當使用 pub/sub API 時，你可以指定消息是並行還是有序的。 有序的意味著你不需要考慮線程安全的問題 ，同時也意味著消息會通過隊列完全按照你發布的順序來進行傳遞，這必然導致消息的延遲。 並行處理，不能保證消息是按照發布的順序來進行處理的，你的代碼也要保證當存在並發時程序運行正常， 消息的順序通常是無關緊要的， 並行處理可以獲得更好的性能和擴展性。 為確保安全，消息的傳遞默認是有序的。為獲得更好的性能強烈建議你使用並行操作 。 這是非常簡單的。 multiplexer.PreserveAsyncOrder = false; 建議並非是你配置該選項的理由， 是否適合完全取決與你訂閱消息的代碼。 StackExchange.Redis 使用-同步 異步 即發即棄 訪問單個服務器 有時候需要為單個服務器指定特定的命令 。 IServer server = redis.GetServer("localhost", 6379); GetServer方法會接收一個EndPoint類或者一個唯一標識一臺服務器的鍵值對。GetServer 方法返回一個IServer對象。 方法也可以是異步的只需要傳入一個async-state 可以使用如下方法獲取所有可用的終結點： EndPoint[] endpoints = redis.GetEndPoints(); 使用IServer可以使用所有的shell命令，比如： DateTime lastSave = server.LastSave(); ClientInfo[] clients = server.ClientList(); 如果報錯在連接字符串後加 ,allowAdmin=true; 同步 、異步、即發即棄 這是StackExchange.Redis的三種主要使用機制： 同步-在方法返回之前阻塞調用方（雖然會阻塞調用方，但絕不會阻塞其他線程 ，StackExchange.Redis中的關鍵點是共享調用者之間的連接） 異步-在未來的某個時間點操作完成，會立刻返回一個 Task 或者 Task<T> : 之後可以調用 .Wait() 阻塞當前線程，直到處理完成。 ContinueWith 添加一個回調函數 使用 await 這是一個高級特性簡化了操作 即發即棄- 在上面的示例中已經演示同步調用的方法 。 異步調用： string value = "abcdefg"; await db.StringSetAsync("mykey", value); ... string value = await db.StringGetAsync("mykey"); Console.WriteLine(value); // writes: "abcdefg" 即發即棄：通過配置 CommandFlags 來實現即發即棄功能，在該實例中該方法會立即返回，如果是string則返回null 如果是int則返回0.這個操作將會繼續在後臺運行，一個典型的用法頁面計數器的實現： db.StringIncrement(pageKey, flags: CommandFlags.FireAndForget); StackExchange.Redis 使用-配置 Configuration redis有很多不同的方法來配置連接字符串 ， StackExchange.Redis 提供了一個豐富的配置模型，當調用Connect 或者 ConnectAsync 時需要傳入。 var conn = ConnectionMultiplexer.Connect(configuration); 這裏的 configuration 參數可以是： 1. 一個 ConfigurationOptions 實例 2. 一個字符串 第二種方式從根本上來說也是ConfigurationOptions。 通過字符串配置連接 最簡單的配置方式只需要一個主機名 var conn = ConnectionMultiplexer.Connect("localhost"); 它將會連接到本地的redis服務器 ， 默認6379端口 ，多個連接通過逗號分割 。 其他選項在名稱的後面包含了一個 “= ”。 例如 var conn = ConnectionMultiplexer.Connect("redis0:6380,redis1:6380,allowAdmin=true"); 可以將一個字符串轉換為ConfigurationOptions 或者 將一個ConfigurationOptions轉換為字符串 。 ConfigurationOptions options = ConfigurationOptions.Parse(configString); OR string configString = options.ToString(); 推薦的用法是將基礎信息保存在一個字符串中，然後在運行是通過ConfigurationOptions改變其他信息。 string configString = GetRedisConfiguration(); var options = ConfigurationOptions.Parse(configString); options.ClientName = GetAppName(); // only known at runtime options.AllowAdmin = true; conn = ConnectionMultiplexer.Connect(options); 也可以指定密碼 var conn = ConnectionMultiplexer.Connect("contoso5.redis.cache.windows.net,ssl=true,password=..."); 配置選項 ConfigurationOptions 包含大量的配置選項，一些常用的配置如下： abortConnect ： 當為true時，當沒有可用的服務器時則不會創建一個連接 allowAdmin ： 當為true時 ，可以使用一些被認為危險的命令 channelPrefix：所有pub/sub渠道的前綴 connectRetry ：重試連接的次數 connectTimeout：超時時間 configChannel： Broadcast channel name for communicating configuration changes defaultDatabase ： 默認0到-1 keepAlive ： 保存x秒的活動連接 name:ClientName password:password proxy:代理 比如 twemproxy resolveDns : 指定dns解析 serviceName ： Not currently implemented (intended for use with sentinel) ssl={bool} ： 使用sll加密 sslHost={string} ： 強制服務器使用特定的ssl標識 syncTimeout={int} ： 異步超時時間 tiebreaker={string}：Key to use for selecting a server in an ambiguous master scenario version={string} ： Redis version level (useful when the server does not make this available) writeBuffer={int} ： 輸出緩存區的大小 各配置項用逗號分割 自動和手動配置 在大部分的情況下StackExchange.Redis 會自動的幫我們配置很多選項。 比如 服務器類型，版本， 超時時間 ， 主從服務器等.. 盡管如此，有時候我們需要在服務器上面排除一些命令, 這種情況下有必要提供更多信息 ConfigurationOptions config = new ConfigurationOptions { EndPoints = { { "redis0", 6379 }, { "redis1", 6380 } }, CommandMap = CommandMap.Create(new HashSet<string> { // EXCLUDE a few commands "INFO", "CONFIG", "CLUSTER", "PING", "ECHO", "CLIENT" }, available: false), KeepAlive = 180, DefaultVersion = new Version(2, 8, 8), Password = "changeme" }; 也可以使用下面的字符串來設置： redis0:6379,redis1:6380,keepAlive=180,version=2.8.8,$CLIENT=,$CLUSTER=,$CONFIG=,$ECHO=,$INFO=,$PING= 重命名命令 你可以禁用或者重命名一個命令。 按照前面的示例這是通過 CommandMap 來完成的，不過上面使用Create( new HashSet<string> )來進行配置，我們使用Dictionary<string,string>。設置null時代表禁用該命令 var commands = new Dictionary<string,string> { { "info", null }, // disabled { "select", "use" }, // renamed to SQL equivalent for some reason }; var options = new ConfigurationOptions { // ... CommandMap = CommandMap.Create(commands), // ... } 也可以使用下面的字符串來設置： $INFO=,$SELECT=use StackExchange.Redis 使用 - 事件 ConnectionMultiplexer 可以註冊如下事件
  • ConfigurationChanged - 配置更改時
  • ConfigurationChangedBroadcast - 通過發布訂閱更新配置時
  • ConnectionFailed - 連接失敗 ， 如果重新連接成功你將不會收到這個通知
  • ConnectionRestored - 重新建立連接之前的錯誤
  • ErrorMessage - 發生錯誤
  • HashSlotMoved - 更改集群
  • InternalError - redis類庫錯誤
分類: Redis http://www.cnblogs.com/skig/p/redis-lua-batch.html

stackExchange.redis的使用

相關推薦

在.Net下使用redis基於StackExchange.Redis

sof sel setting null pep inf syn url 討論 研究了下redis在.net下的使用，因為以前在java上用redis用的是jedis操作，在.net不是很熟悉，在網站上也看了一部分的.net下redis的使用，大部分都是ServiceSta

功能比較全的StackExchange.Redis封裝幫助類(.Net/C#)

fault wke setting ret stack gin lex sortedset each Redis官網https://redis.io/ 以下內容未全部驗證，如有問題請指出 //static NewtonsoftSerializer serializer

StackExchange.Redis 官方文檔(一) Basics

pass abc ocs 維護 cpp ber mas msd nds 基本使用方法： StackExchange.Redis的核心是 StackExchange.Redis 命名空間的 ConnectionMultiplexer 類;它隱藏了多服務器的實現細節.Conne

Jexus~mono中使用StackExchange.redis的問題

nbsp linux環境 hang 感謝 下載 sta dll ref bsp 在windows平臺的vs裏，添加包包時，可以選擇StackExchange.redis，而如果你的應該程序需要部署到linux的mono環境上，使用這個StackExchange.redis是

stackExchange.redis的使用

shell bsp disabled dbr for 方式 shel point org 在StackExchange.Redis中最重要的對象是ConnectionMultiplexer類， 它存在於StackExchange.Redis命名空間中。 這個類隱藏了Redi

Redis 詳解 (一) StackExchange.Redis Client

pack 線程 ttr 使用場景 sdk ins get http arc 這期我們來看StackExchange.Redis,這是redis 的.net客戶端之一。Redis是一個開源的內存數據存儲,可以用來做數據庫,緩存或者消息代理服務。目前有不少人在使用Service

StackExchange.Redis的使用 Redis五種數據類型的應用

help ack images man rest 進行 shel param 同時 ConnectionMultiplexer ConnectionMultiplexer 是StackExchange.Redis的核心對象，用這個類的實例來進行Redis的一系列操作，對於一

StackExchange.Redis學習筆記(四) 事務控制和Batch批量操作

成了 pan arp 展示 關於 public 連續 因此 用戶 Redis事物 Redis命令實現事務 Redis的事物包含在multi和exec（執行）或者discard（回滾）命令中 和sql事務不同的是，Redis調用Exec只是將所有的命令變成一個單元一起執行，期

StackExchange.Redis下清空DB

class com nbsp 出現 tac edi body 技術 change 由於項目需求，需要每天定時將數據庫中某張表的數據全量寫入Redis，每次寫入之前需要清空一下DB，清空代碼如下： 註意事項：如果出現如下圖所示錯誤 解決方案：在redis連接字符串中增加a

C# StackExchange.Redis 簡單使用

span 關系型數據庫 try lis 利用 info 聊天 ron 訂閱者 安裝 StackExchange.Redis 在 NuGet 中搜索 StackExchange.Redis 和 Newtonsoft.Json，直接點擊按鈕安裝即可。 StackExchan

StackExchange.Redis性能調優

發送 2.0 保護 1.2 stack 參考 nds 沒有 exceptio 大家經常出現同步調用Redis超時的問題，但改成異步之後發現錯誤非常少了，但卻可能通過前後記日誌之類的發現Redis命令非常慢。 PS: 以後代碼都在Windows bash中運行，St

StackExchange.redis 封裝幫助類

using ModelLibrary.quotedata; using Newtonsoft.Json; using StackExchange.Redis; using System; using System.Collections.Generic; using System.Configura

StackExchange.Redis TimeOut

不知道大家在用 StackExchange.Redis 時是否遇到過 TimeOut的錯誤，有人說： 【 　　　　這不是BUG，這是StackExchange.Redis有意這麼設計的，因為StackExchange.Redis採用單執行緒，如果一個請求耗時太長會阻塞後面的請求，所以它加了請求超

c#使用 StackExchange.Redis 封裝 RedisHelper

1.定義ICache介面。 2.Redis類和Memcached類，以後想用那個快取修改一下配置就可以了，非常方便。 3.CacheHelper的實現。 上程式碼： ICache.cs using System; using System.Collections.Gener

Redis幫助類，引用StackExchange.Redis

using StackExchange.Redis; using System; using System.Collections.Concurrent; using System.Collections.Generic; using System.Linq;

StackExchange.Redis客戶端讀寫主從配置，以及哨兵配置

今天簡單分享一下StackExchange.Redis客戶端中配置主從分離以及哨兵的配置。 為什麼要有這篇分享呢，是因為我之前也有一些疑問，相信學習Redis的朋友都有過相同的疑問。 在程式碼中，如何分別操作主從資料庫?，也就是說，如何只向主資料庫寫，而讀取

Redis叢集~StackExchange.redis連線Sentinel伺服器並訂閱相關事件

對於redis-sentinel我在之前的文章中Redis叢集~StackExchange.redis連線Twemproxy代理伺服器 已經說過，它是一個仲裁者，當主master掛了後，它將在所有slave伺服器中進行選舉，選舉的原則當然可以看它的官方文章，這與我們使用者沒有什麼關係，而對於se

Redis叢集~StackExchange.Redis(10月6號版1.1.608.0)連線Twemproxy支援Auth指令了

回到目錄 對於StackExchange.Redis這個驅動來說，之前的版本在使用Proxy為Twemproxy代理時，它是不支援Password屬性的，即不支援原始的Auth指令，而我也修改過原始碼，為CommandMap添加了Auth但最後測試的結果還是失敗了，就在１０月１過完後的第一天，我升級了Sta

Redis學習筆記~StackExchange.Redis實現分散式Session

回到目錄 對於多WEB的環境現在已經是必須的了，很難想像一臺WEB伺服器面對百萬併發的響應，所以，我們需要多臺WEB伺服器叢集合作，來緩解這種高併發，高吞吐的場景，而對於多WEB的場景又會有個問題出現，即session儲存的問題，如一個使用者登陸後，把一個狀態資訊儲存到當前WEB伺服器的session裡，而

Redis叢集~StackExchange.redis連線Twemproxy代理伺服器

回到目錄 本文是Redis集群系列的一篇文章，主要介紹使用StackExchange.Redis進行Twemproxy（文中簡稱TW）代理服務的連線過程，事務上，對於ＴＷ來說，我們需要理解一下它的物理架構，它類似於Nugix，主要實現的是請求轉發，但它還有一個重要的功能，那就是自動分片，這對於大資料是很必要