亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

RedisRepository 分享和糾錯

 更新時間：2017年01月23日 11:26:04   作者：坦蕩  
本文主要介紹了RedisRepository分享和糾錯。具有很好的參考價值，下面跟著小編一起來看下吧

一.   寫在前面

畢業(yè)工作后，今天終于能回家了，回想了一些這半年來所做的內容，總是覺得還停留在那么基礎的水平 ，在解決各種問題的過程中，自己的創(chuàng)新思路比較少，靠搜索來的比較多 。不想做16年的總結了 ，希望17年能學更多的我愛的技術，看更多的開源代碼，能學到更多的設計思想和代碼思路，能再更新這兩年來對代碼的理解。

這篇分享，主要是彌補我之前RedisRepository的不足。

半年前由于我StackExchange.Redis文檔閱讀不足，所分享的RedisRepository有所錯誤。下面列舉我的主要錯誤：

錯誤1，沒有單例化ConnectionMultiplexer Redis連接對象，并且我天真的以為給單例對象加鎖，在并發(fā)情況下，會限制了Redis的性能。

錯誤2，在主從情況下，我以為在發(fā)生手動切換的時候，我們要訂閱切換事件，并在事件發(fā)生后，動態(tài)改變連接對象指向的Endpoint。

當我再一次仔細閱讀文檔時，才明白我的錯誤，這是一篇遲到的修正，但是我自用的repository自我感覺還是有很多不足之處，所以我真的需要老司機的指點和建議。

修正1，Redis連接對象創(chuàng)建的代價很大，并且單例加鎖并不會影響Redis性能，因為在發(fā)生網絡請求的期間，連接對象并沒有在等待中。

修正2，Redis主從時，在哨兵切換主從關系后，StackExchange.Redis會為我們識別新的主從，不需要我們做任何操作。

目前為止我還有兩個疑問。

疑問1，在看文檔后沒有明確結果。當做主從讀寫分離時,  我們在Endpoint Collection集合中添加多個節(jié)點就會自動讀寫分離？還是說需要 我們在讀取命令的方法中指定CommandFlags.PreferSlave？  我認為是后者吧？所以我在我所有的讀取方法都指定了PreferSlave。    老司機們怎么說？

疑問2，我使用LuaScript.Prepare(lua)后再Load出來，執(zhí)行l(wèi)ua總是無效果，并且LuaScript.GetCachedScriptCount()為0. 不過我直接使用ScriptEvaluateAsync卻是好用的，老司機如果有好的例子，希望老司機給些指導或者分享。

二.   代碼結構，僅供參考

結構大概就是這樣，RedisAsyncHelper下的所有類都是部分類，他們的類名稱是RedisHelper。他們共同實現了IRedisHelper的接口，并且留下了詳細的注釋。

同步版本和異步版本的目錄結構是一樣的。

三.   預備階段

CommonHelper中的兩個幫助類：

RedisInnerTypeHelper.cs

using StackExchange.Redis;
using System.Collections.Generic;
using System.Linq;
namespace Fantasy.RedisRepository.CommonHelper
{
 internal class RedisInnerTypeHelper
 {
 public static List<T> RedisValuesToGenericList<T>(RedisValue[] redisValues)
 {
  var result = new List<T>();
  redisValues.ToList().ForEach(r => result.Add(SerializeHelper.Deserialize<T>(r)));
  return result;
 }
 public static RedisValue[] GenericListToRedisValues<T>(List<T> values)
 {
  var redisValues = new List<RedisValue>();
  values.ForEach(v => redisValues.Add(SerializeHelper.Serialize(values)));
  return redisValues.ToArray();
 }
 public static RedisKey[] GenericListToRedisKeys(List<string> keys)
 {
  var redisKeys = new List<RedisKey>();
  keys.ForEach(k => redisKeys.Add(k));
  return redisKeys.ToArray();
 }
 }
}

SerializeHelper.cs

using System.IO;
using System.Runtime.Serialization.Formatters.Binary;
namespace Fantasy.RedisRepository.CommonHelper
{
 internal static class SerializeHelper
 {
 /// <summary>
 /// 字節(jié)數組序列化
 /// </summary>
 /// <param name="o"></param>
 /// <returns></returns>
 internal static byte[] Serialize(object o)
 {
  if (o == null)
  {
  return null;
  }
  BinaryFormatter binaryFormatter = new BinaryFormatter();
  using (MemoryStream memoryStream = new MemoryStream())
  {
  binaryFormatter.Serialize(memoryStream, o);
  byte[] objectDataAsStream = memoryStream.ToArray();
  return objectDataAsStream;
  }
 }
 /// <summary>
 /// 字節(jié)數組反序列化
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="stream"></param>
 /// <returns></returns>
 internal static T Deserialize<T>(byte[] stream)
 {
  if (stream == null)
  {
  return default(T);
  }
  BinaryFormatter binaryFormatter = new BinaryFormatter();
  using (MemoryStream memoryStream = new MemoryStream(stream))
  {
  T result = (T)binaryFormatter.Deserialize(memoryStream);
  return result;
  }
 }
 }
}

Config中的配置類：

ConfigHelper.cs

using System;
using System.Configuration;
namespace Fantasy.RedisRepository.Config
{
 internal class ConfigHelper
 {
 internal static T Get<T>(string appSettingsKey, T defaultValue)
 {
  string text = ConfigurationManager.AppSettings[appSettingsKey];
  if (string.IsNullOrWhiteSpace(text))
  return defaultValue;
  try
  {
  var value = Convert.ChangeType(text, typeof(T));
  return (T)value;
  }
  catch
  {
  return defaultValue;
  }
 }
 }
}

RedisClientConfig.cs

namespace Fantasy.RedisRepository.Config
{
 internal class RedisClientConfig
 {
 private static string _server = ConfigHelper.Get("RedisServer", "115.xx.xx.31");
 /// <summary>
 /// 節(jié)點IP
 /// </summary>
 public static string Server
 {
  get { return _server; }
  set { _server = value; }
 }
 private static int _port = ConfigHelper.Get("RedisPort", 6380);
 /// <summary>
 /// 節(jié)點端口
 /// </summary>
 public static int Port
 {
  get { return _port; }
  set { _port = value; }
 }
 private static string _slaveServer = ConfigHelper.Get("SlaveServer", "115.xx.xx.31");
 /// <summary>
 /// 節(jié)點IP
 /// </summary>
 public static string SlaveServer
 {
  get { return _slaveServer; }
  set { _slaveServer = value; }
 }
 private static int _slavePort = ConfigHelper.Get("SlavePort", 6381);
 /// <summary>
 /// 節(jié)點端口
 /// </summary>
 public static int SlavePort
 {
  get { return _slavePort; }
  set { _slavePort = value; }
 }
 private static string _auth = ConfigHelper.Get("RedisAuth", "fantasy..");
 /// <summary>
 /// 節(jié)點密碼
 /// </summary>
 public static string RedisAuth
 {
  get { return _auth; }
  set { _auth = value; }
 }
 private static int _defaultDatabase = ConfigHelper.Get("RedisDataBase", 0);
 /// <summary>
 /// redis默認0號庫
 /// </summary>
 public static int DefaultDatabase
 {
  get { return _defaultDatabase; }
  set { _defaultDatabase = value; }
 }
 private static int _connectTimeout = 10000;
 public static int ConnectTimeout
 {
  get { return _connectTimeout; }
  set { _connectTimeout = value; }
 }
 private static int _connectRetry = 3;
 public static int ConnectRetry
 {
  get { return _connectRetry; }
  set { _connectRetry = value; }
 }
 private static bool _preserveAsyncOrder = false;
 public static bool PreserveAsyncOrder
 {
  get { return _preserveAsyncOrder; }
  set { _preserveAsyncOrder = value; }
 }
 }
}

RedisConnection.cs

using Fantasy.RedisRepository.Config;
using StackExchange.Redis;
namespace Fantasy.RedisRepository
{
 /// <summary>
 /// Redis連接類
 /// </summary>
 public static class RedisConnection
 {
 private static ConnectionMultiplexer _connection;
 private static readonly object SyncObject = new object();
 /// <summary>
 /// redis連接對象，單例加鎖不影響性能
 /// </summary>
 public static ConnectionMultiplexer GenerateConnection
 {
  get
  {
  if (_connection == null || !_connection.IsConnected)
  {
   lock (SyncObject)
   {
   var configurationOptions = new ConfigurationOptions()
   {
    Password = RedisClientConfig.RedisAuth,
    EndPoints =
    {
{RedisClientConfig.Server, RedisClientConfig.Port},
    {RedisClientConfig.SlaveServer, RedisClientConfig.SlavePort}
    }
   };
   _connection = ConnectionMultiplexer.Connect(configurationOptions);
   }
  }
  return _connection;
  }
 }
 }
}

四.   RedisHelper

實際上就是做了層序列化包裝而已。

IRedisHelper：

using System;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// <summary>
 /// 異步方法接口 --Author 吳雙 www.cnblogs.com/tdws
 /// 存入數據均為方法內部序列化后的byte,所以取數據的時候需要反序列化時，請指定正確的數據類型
 /// </summary>
 public partial interface IRedisHelper
 {
 #region Redis數據類型—String
 /// <summary>
 /// 將任何數據以redis string存儲
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <param name="timeout"></param>
 /// <returns></returns>
 Task<bool> StringSetAsync<T>(string key, T value, TimeSpan? timeout = null);
 /// <summary>
 /// 對數值進行減法操作，默認-1
 /// </summary>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns>操作后的結果</returns>
 Task<long> StringDecrementAsync(string key, long value = 1L);
 /// <summary>
 /// 對數值進行加法操作，默認+1
 /// </summary>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns>操作后的結果</returns>
 Task<long> StringIncrementAsync(string key, long value = 1L);
 /// <summary>
 /// 從redis string中以指定類型取出
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<T> StringGetAsync<T>(string key);
 #endregion
 #region Redis數據類型—Hash
 /// <summary>
 /// 向Hash key中存儲任意類型任意值
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <param name="value"></param>
 /// <returns>是否成功</returns>
 Task<bool> HashSetAsync<T>(string key, string field, T value);
 /// <summary>
 /// 批量 向Hash key中存儲任意類型任意值
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="hashFields"></param>
 /// <returns>無返回值</returns>
 Task HashMultiSetAsync<T>(string key, Dictionary<string, T> hashFields);
 /// <summary>
 /// 對指定hash key中制定field做數量增加操作 默認自增1 
 /// 如果此操作前key不存在 則創(chuàng)建。 如果此操作前該field不存在或者非數字 則先被置0，再被繼續(xù)操作
 /// </summary>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <param name="incrCount"></param>
 /// <returns>操作后的結果</returns>
 Task<long> HashIncrementAsync(string key, string field, long incrCount = 1);
 /// <summary>
 /// 對指定hash key中制定field做數量增加操作 默認自減1 
 /// 如果此操作前key不存在 則創(chuàng)建。 如果此操作前該field不存在或者非數字 則先被置0，再被繼續(xù)操作
 /// </summary>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <param name="decrCount"></param>
 /// <returns>操作后的結果</returns>
 Task<long> HashDecrementAsync(string key, string field, long decrCount = 1);
 /// <summary>
 /// 從指定Hash中 刪除指定field
 /// 如果key或者field不存在，則false
 /// </summary>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <returns>是否成功</returns>
 Task<bool> HashDeleteFieldAsync(string key, string field);
 /// <summary>
 /// 從指定Hash key中 批量刪除指定field
 /// 如果key或者field不存在，則false
 /// </summary>
 /// <param name="key"></param>
 /// <param name="fields"></param>
 /// <returns>移除數量</returns>
 Task<long> HashMultiDeleteFieldAsync(string key, List<string> fields);
 /// <summary>
 /// 從指定Hash key中獲取指定field值
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <returns></returns>
 Task<T> HashGetAsync<T>(string key, string field);
 /// <summary>
 /// 從指定Hash key中判斷field是否存在
 /// </summary>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <returns></returns>
 Task<bool> HashFieldExistAsync(string key, string field);
 /// <summary>
 /// 獲取指定Hash key中的所有field的值 
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<List<T>> HashValuesAsync<T>(string key);
 /// <summary>
 /// 獲取指定Hash key中所有 field名稱及其Value
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<Dictionary<string, T>> HashGetAllAsync<T>(string key);
 /// <summary>
 /// 獲取指定Hash key中所有field
 /// </summary>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<List<string>> HashFieldsAsync(string key);
 #endregion
 #region Redis數據類型—List 
 /// <summary>
 /// 在指定pivot后插入value, 如果pivot不存在，則返回-1, 如果key不存在，則返回0
 /// 如果存在多個相同指定的的pivot,則插入第一個指定pivot后面.
 /// 即鏈表從左向右查找，遇到指定pivot，則確定位置
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="pivot">list中的一個值</param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<long> ListInsertAfterAsync<T>(string key, string pivot, T value);
 /// <summary>
 /// 在指定pivot前插入value, 如果pivot不存在，則返回-1, 如果key不存在，則返回0
 /// 如果存在多個相同指定的的pivot,則插入第一個指定pivot前面.
 /// 即鏈表從左向右查找，遇到指定pivot，則確定位置
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="pivot"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<long> ListInsertBeforeAsync<T>(string key, string pivot, T value);
 /// <summary>
 /// 從鏈表左側彈出第一個元素（彈出能獲取到該元素并且被刪除）
 /// 如果key不存在 或者鏈表為空 則為null
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<T> ListLeftPopAsync<T>(string key);
 /// <summary>
 /// 從鏈表左側增加一個元素,key不存在則被創(chuàng)建
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns>返回操作后的鏈表長度</returns>
 Task<long> ListLeftPushAsync<T>(string key, T value);
 /// <summary>
 /// 從鏈表左側批量增加元素，如果 a b c 則c會在鏈表左側第一位 b第二位 a第三位
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="values"></param>
 /// <returns>返回操作后的鏈表長度</returns>
 Task<long> ListLeftMultiPushAsync<T>(string key, List<T> values);
 /// <summary>
 /// 獲取鏈表長度，不存在key則為0
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<long> ListLengthAsync<T>(string key);
 /// <summary>
 /// 獲取鏈表中所有數據，從左側start開始到stop結束，從0—-1則認為獲取全部，默認獲取全部
 /// start為負數則代表從鏈表右側開始，-1為右側第一位，-2為右側第二位
 /// start要小于stop,否則返回null
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="start"></param>
 /// <param name="stop"></param>
 /// <returns></returns>
 Task<List<T>> ListRangeAsync<T>(string key, long start = 0L, long stop = -1L);
 /// <summary>
 /// 從鏈表中一處count數量的value. count大于0則從左至右，count小于0則從右至左，count=0則移除全部
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <param name="count"></param>
 /// <returns></returns>
 Task<long> ListRemoveAsync<T>(string key, T value, long count = 0L);
 /// <summary>
 /// 從右側彈出第一個元素（彈出能獲取到該元素并且被刪除）
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<T> ListRightPopAsync<T>(string key);
 /// <summary>
 /// 從鏈表右側加入元素，如果 rpush a b c 則c為右側第一位 b第二位 c第三位
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<long> ListRightPushAsync<T>(string key, T value);
 /// <summary>
 /// 從右側批量插入，和左側相反
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="values"></param>
 /// <returns></returns>
 Task<long> ListRightMultiPushAsync<T>(string key, List<T> values);
 /// <summary>
 /// 在鏈表指定索引處，插入元素
 /// 正數索引從0開始，代表左側。負數從-1開始 代表從右側。-1為右側第一位
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="index"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task ListSetByIndexAsync<T>(string key, int index, T value);
 /// <summary>
 /// 留下start到stop之間的數據。負數代表從右側尋找 -1為右側第一位
 /// </summary>
 /// <param name="key"></param>
 /// <param name="start"></param>
 /// <param name="stop"></param>
 /// <returns></returns>
 Task ListTrimAsync(string key, long start, long stop);
 /// <summary>
 /// 獲取指定index的值，負數代表從右側尋找 -1為右側第一位
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="index"></param>
 /// <returns></returns>
 Task<T> ListGetByIndexAsync<T>(string key, long index);
 #endregion
 #region Redis數據類型—Set
 /// <summary>
 /// 向指定集合中增加一個元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<bool> SetAddAsync<T>(string key, T value);
 /// <summary>
 /// 指定集合計算操作operation枚舉，指定計算結果將存的目標destKey，指定需要參與計算的多個key
 /// </summary>
 /// <param name="operation"></param>
 /// <param name="destKey"></param>
 /// <param name="combineKeys"></param>
 /// <returns></returns>
 Task<long> SetCombineAndStoreAsync(SetOperation operation, string destKey, List<string> combineKeys);
 /// <summary>
 /// 指定集合計算操作operation枚舉，指定需要參與計算的多個key
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="operation"></param>
 /// <param name="combineKeys"></param>
 /// <returns></returns>
 Task<List<T>> SetCombineAsync<T>(SetOperation operation, List<string> combineKeys);
 /// <summary>
 /// 指定值是否存在于指定集合中
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<bool> SetContainsAsync<T>(string key, T value);
 /// <summary>
 /// 獲取指定集合中元素個數
 /// </summary>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<long> SetLengthAsync(string key);
 /// <summary>
 /// 獲取指定集合中的所有元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<List<T>> SetMembersAsync<T>(string key, T value);
 /// <summary>
 /// 從sourceKey移除指定value到目標distKey集合當中
 /// 如果sourceKey存在指定value則返回true，否則不做任何操作返回false
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="sourcekey"></param>
 /// <param name="distKey"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<bool> SetMoveAsync<T>(string sourcekey, string distKey, T value);
 /// <summary>
 /// 從指定集合當中隨機取出一個元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<T> SetRandomMemberAsync<T>(string key);
 /// <summary>
 /// 從指定集合隨機彈出（刪除并獲?。┮粋€元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<T> SetPopAsync<T>(string key);
 /// <summary>
 /// 從集合中隨機彈出（刪除并獲取）多個元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<List<T>> SetRandomMembersAsync<T>(string key);
 /// <summary>
 /// 從集合中移除指定元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <returns></returns>
 Task<bool> SetRemoveAsync<T>(string key, T value);
 /// <summary>
 /// 從集合中批量移除元素
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="values"></param>
 /// <returns></returns>
 Task<long> SetMultiRemoveAsync<T>(string key, List<T> values);
 #endregion
 #region Redis數據類型—SortSet
 #endregion
 #region Redis Key操作
 /// <summary>
 /// 刪除指定key
 /// </summary>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<bool> KeyDeleteAsync(string key);
 /// <summary>
 /// 設置key過期時間具體DateTime
 /// </summary>
 /// <param name="key"></param>
 /// <param name="expireAt"></param>
 /// <returns></returns>
 Task<bool> KeyExpireAtAsync(string key, DateTime expireAt);
 /// <summary>
 /// 設置key在將來的timeout后過期（TimeSpan）
 /// </summary>
 /// <param name="key"></param>
 /// <param name="timeout"></param>
 /// <returns></returns>
 Task<bool> KeyExpireInAsync(string key, TimeSpan timeout);
 /// <summary>
 /// key重命名
 /// </summary>
 /// <param name="key"></param>
 /// <param name="newKey"></param>
 /// <returns></returns>
 Task<bool> KeyRenameAsync(string key, string newKey);
 /// <summary>
 /// 判斷key是否已存在
 /// </summary>
 /// <param name="key"></param>
 /// <returns></returns>
 Task<bool> KeyExistsAsync(string key);
 #endregion
 #region Redis Transcation
 /// <summary>
 /// 在事務中執(zhí)行一系列redis命令。注意：在委托中的一系列命令的所有 值 都需要進行字節(jié)數組序列化
 /// </summary>
 /// <param name="ranOperations"></param>
 /// <returns></returns>
 Task<bool> DoInTranscationAsync(Action<ITransaction> ranOperations);
 #endregion
 Task<RedisResult> Test();
 }
}

RedisHelper部分類RedisStringHelperAsync.cs

using System;
using Fantasy.RedisRepository.CommonHelper;
using StackExchange.Redis;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// <summary>
 /// Redis異步操作類 String部分類
 /// </summary>
 internal partial class RedisHelper// : IRedisHelper
 {
 private static IDatabase _client;

 internal RedisHelper()
 {
  _client = RedisConnection.GenerateConnection.GetDatabase();
 }
 #region String 寫操作
 /// <summary>
 /// 將任何數據添加到redis中
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <param name="value"></param>
 /// <param name="timeout"></param>
 /// <returns></returns>
 public async Task<bool> StringSetAsync<T>(string key, T value, TimeSpan? timeout = null)
 {
  return await _client.StringSetAsync(key, SerializeHelper.Serialize(value), timeout); 
 }
 public async Task<long> StringDecrementAsync(string key, long value = 1L)
 {
  return await _client.StringDecrementAsync(key, value);
 }
 public async Task<long> StringIncrementAsync(string key, long value = 1L)
 {
  return await _client.StringIncrementAsync(key, value);
 }
 #endregion
 #region String 讀操作
 /// <summary>
 /// 根據key獲取指定類型數據
 /// </summary>
 /// <typeparam name="T"></typeparam>
 /// <param name="key"></param>
 /// <returns></returns>
 public async Task<T> StringGetAsync<T>(string key)
 {
  return SerializeHelper.Deserialize<T>(await _client.StringGetAsync(key, CommandFlags.PreferSlave));
 }
 #endregion
 }
}

RedisHelper部分類RedisHashHelperAsync.cs

using Fantasy.RedisRepository.CommonHelper;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// <summary>
 /// Redis異步操作類 Hash部分類
 /// </summary>
 internal partial class RedisHelper
 {
 #region Hash 寫操作
 public async Task<bool> HashSetAsync<T>(string key, string field, T value)
 {
  return await _client.HashSetAsync(key, field, SerializeHelper.Serialize(value));
 }
 public async Task HashMultiSetAsync<T>(string key, Dictionary<string, T> hashFields)
 {
  List<HashEntry> entries = new List<HashEntry>();
  hashFields.ToList().ForEach(d => entries.Add(new HashEntry(d.Key, SerializeHelper.Serialize(d.Value))));
  await _client.HashSetAsync(key, entries.ToArray());
 }
 public async Task<long> HashIncrementAsync(string key, string field, long incrCount = 1)
 {
  return await _client.HashIncrementAsync(key, field, incrCount);
 }
 public async Task<long> HashDecrementAsync(string key, string field, long decrCount = 1)
 {
  return await _client.HashDecrementAsync(key, field, decrCount);
 }
 public async Task<bool> HashDeleteFieldAsync(string key, string field)
 {
  return await _client.HashDeleteAsync(key, field);
 }
 public async Task<long> HashMultiDeleteFieldAsync(string key, List<string> fields)
 {
  List<RedisValue> values = new List<RedisValue>();
  fields.ForEach(f => values.Add(f));
  return await _client.HashDeleteAsync(key, values.ToArray());
 }
 #endregion
 #region Hash 讀操作
 /// <summary>
 /// Redis 指定hash類型key中field是否存在
 /// </summary>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <returns></returns>
 public async Task<bool> HashFieldExistAsync(string key, string field)
 {
  return await _client.HashExistsAsync(key, field, CommandFlags.PreferSlave);
 }
 public async Task<List<string>> HashFieldsAsync(string key)
 {
  RedisValue[] values = await _client.HashKeysAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList<string>(values);
 }
 public async Task<List<T>> HashValuesAsync<T>(string key)
 {
  var values = await _client.HashValuesAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList<T>(values);
 }
 public async Task<T> HashGetAsync<T>(string key, string field)
 {
  return SerializeHelper.Deserialize<T>(await _client.HashGetAsync(key, field, CommandFlags.PreferSlave));
 }
 public async Task<Dictionary<string, T>> HashGetAllAsync<T>(string key)
 {
  HashEntry[] entries = await _client.HashGetAllAsync(key, CommandFlags.PreferSlave);
  Dictionary<string, T> dic = new Dictionary<string, T>();
  entries.ToList().ForEach(e => dic.Add(e.Name, SerializeHelper.Deserialize<T>(e.Value)));
  return dic;
 }
 #endregion
 }
}

RedisHelper部分類RedisListHelperAsync.cs

using Fantasy.RedisRepository.CommonHelper;
using StackExchange.Redis;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 /// <summary>
 /// Redis異步操作類 Hash部分類
 /// </summary>
 internal partial class RedisHelper
 {
 #region Hash 寫操作
 public async Task<bool> HashSetAsync<T>(string key, string field, T value)
 {
  return await _client.HashSetAsync(key, field, SerializeHelper.Serialize(value));
 }
 public async Task HashMultiSetAsync<T>(string key, Dictionary<string, T> hashFields)
 {
  List<HashEntry> entries = new List<HashEntry>();
  hashFields.ToList().ForEach(d => entries.Add(new HashEntry(d.Key, SerializeHelper.Serialize(d.Value))));
  await _client.HashSetAsync(key, entries.ToArray());
 }
 public async Task<long> HashIncrementAsync(string key, string field, long incrCount = 1)
 {
  return await _client.HashIncrementAsync(key, field, incrCount);
 }
 public async Task<long> HashDecrementAsync(string key, string field, long decrCount = 1)
 {
  return await _client.HashDecrementAsync(key, field, decrCount);
 }
 public async Task<bool> HashDeleteFieldAsync(string key, string field)
 {
  return await _client.HashDeleteAsync(key, field);
 }
 public async Task<long> HashMultiDeleteFieldAsync(string key, List<string> fields)
 {
  List<RedisValue> values = new List<RedisValue>();
  fields.ForEach(f => values.Add(f));
  return await _client.HashDeleteAsync(key, values.ToArray());
 }
 #endregion
 #region Hash 讀操作
 /// <summary>
 /// Redis 指定hash類型key中field是否存在
 /// </summary>
 /// <param name="key"></param>
 /// <param name="field"></param>
 /// <returns></returns>
 public async Task<bool> HashFieldExistAsync(string key, string field)
 {
  return await _client.HashExistsAsync(key, field, CommandFlags.PreferSlave);
 }
 public async Task<List<string>> HashFieldsAsync(string key)
 {
  RedisValue[] values = await _client.HashKeysAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList<string>(values);
 }
 public async Task<List<T>> HashValuesAsync<T>(string key)
 {
  var values = await _client.HashValuesAsync(key, CommandFlags.PreferSlave);
  return RedisInnerTypeHelper.RedisValuesToGenericList<T>(values);
 }
 public async Task<T> HashGetAsync<T>(string key, string field)
 {
  return SerializeHelper.Deserialize<T>(await _client.HashGetAsync(key, field, CommandFlags.PreferSlave));
 }
 public async Task<Dictionary<string, T>> HashGetAllAsync<T>(string key)
 {
  HashEntry[] entries = await _client.HashGetAllAsync(key, CommandFlags.PreferSlave);
  Dictionary<string, T> dic = new Dictionary<string, T>();
  entries.ToList().ForEach(e => dic.Add(e.Name, SerializeHelper.Deserialize<T>(e.Value)));
  return dic;
 }
 #endregion
 }
}

RedisLuaHelper.cs 這里打算裝一些功能行l(wèi)ua腳本， 外部依然是傳key一類的參數，這個不完整，只是個實例。

using StackExchange.Redis;
using System.Threading.Tasks;
namespace Fantasy.RedisRepository.RedisHelpers
{
 internal partial class RedisHelper
 {
 public async Task<RedisResult> LuaMutilGetHash()
 {
  string lua = @"local result={}
  for i, v in ipairs(KEYS) do
   result[i] = redis.call('hgetall',v) 
  end
  return result";
  var res = await _client.ScriptEvaluateAsync(lua, new RedisKey[] { "people:1", "people:2", "people:3" });
  var res1= LuaScript.GetCachedScriptCount();
  return res;
 }
 }
}

關于Transcation的封裝，我個人沒有什么好的方法，提供了這樣一個方法

public async Task<bool> DoInTranscationAsync(Action<ITransaction> runOperations)
 {
  var tran = RedisConnection.GenerateConnection.GetDatabase().CreateTransaction();
  runOperations(tran);
  return await tran.ExecuteAsync();
 }

RedisFactory.cs

using Fantasy.RedisRepository.RedisHelpers;

namespace Fantasy.RedisRepository
{
 public class RedisFactory
 {
 /// <summary>
 /// 外部訪問redis入口，暫時只暴露異步方法
 /// </summary>
 /// <returns></returns>
 public static IRedisHelper CreateRedisRepository()
 {
  return new RedisHelper();
 }
 }
}

以上就是本文的全部內容，希望本文的內容對大家的學習或者工作能帶來一定的幫助，同時也希望多多支持腳本之家！

相關文章

  • asp.NET連接數的設置方法

    asp.NET連接數的設置方法

    asp.NET連接數的設置方法，需要的朋友可以參考下
    2012-12-12
  • .NET的DateTime函數獲取上個月的起始和截止時間的方法

    .NET的DateTime函數獲取上個月的起始和截止時間的方法

    這篇文章主要介紹了NET的DateTime函數獲取上個月的起始和截止時間的方法,可廣泛使用于報表中的時間自動選擇功能,是非常實用的技巧,需要的朋友可以參考下
    2015-01-01
  • .NET使用?OpenTelemetry?Traces?追蹤應用程序的方法

    .NET使用?OpenTelemetry?Traces?追蹤應用程序的方法

    OpenTelemetry Traces是OpenTelemetry提供的一種遙測數據類型,用于記錄和描述在分布式系統(tǒng)中的單個操作或工作單元的生命周期,這篇文章主要介紹了.NET中使用OpenTelemetry Traces追蹤應用程序,需要的朋友可以參考下
    2024-06-06
  • asp.net在事件中啟動線程來打開一個頁面的實現方法

    asp.net在事件中啟動線程來打開一個頁面的實現方法

    點擊一個按鈕做兩件事情，一件需要點擊按鈕馬上完成，另一件事情是點擊按鈕后做其他事情，不會的朋友一起來看看下面是如何實現的
    2014-11-11
  • VS2010發(fā)布Web網站技術攻略

    VS2010發(fā)布Web網站技術攻略

    本篇文章主要包含了完整的發(fā)布網站步驟、發(fā)布網站過程中可能遇到的問題，以及配套的解決方法，相信感興趣的朋友一定會喜歡這篇文章的
    2015-07-07
  • .net core利用orm如何操作mysql數據庫詳解

    .net core利用orm如何操作mysql數據庫詳解

    這篇文章主要給大家介紹了關于.net core利用orm如何操作mysql數據庫的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
    2018-05-05
  • asp.net中的GridView分頁問題

    asp.net中的GridView分頁問題

    這篇文章主要介紹了asp.net中的GridView分頁問題,實例講述了采用GridView分頁出現的問題及對應的解決方案,非常具有實用價值,需要的朋友可以參考下
    2014-11-11
  • ASP.NET實現Web網站本地化

    ASP.NET實現Web網站本地化

    這篇文章介紹了ASP.NET實現Web網站本地化的方法，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
    2022-06-06
  • 在.NET程序崩潰時自動創(chuàng)建Dump的思路詳解

    在.NET程序崩潰時自動創(chuàng)建Dump的思路詳解

    本文主要是介紹了如何在dotNet程序崩潰時自動創(chuàng)建Dump，Windows上的方法對于.NET Freamwork和.NET Core版本都適用,.NET Core全平臺版本的話需要注意環(huán)境變量支持的.NET版本，對.net程序崩潰自動創(chuàng)建Dump相關知識感興趣的朋友一起看看吧
    2022-11-11

最新評論