StackExchange.Redis RedisHelper.cs

来源:http://www.cnblogs.com/recordman/archive/2016/11/11/6053312.html
-Advertisement-
Play Games

StackExchange.Redis RedisHelper.cs ...


 從 ServiceStack.Redis  V4 折騰到V3種種....，以前聽說過 StackExchange。終於下定決心換！！！網上查到一個 StackExchangeHelper.cs 具體地址忘了。

發現了一個問題：不同項目不同命名空間，同一個實體反序列化時會出錯，改成Json就OK了。代碼如下：

using My.Log;
using StackExchange.Redis;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.IO;
using System.Linq;
using System.Net;
using System.Runtime.Serialization.Formatters.Binary;
using Newtonsoft.Json;


namespace My.Redis
{ 
    /// <summary>
    ///  
    /// </summary>
    public static class RedisHelper
    {
        private static readonly string Coonstr = ConfigurationManager.ConnectionStrings["RedisExchangeHosts"].ConnectionString;
        
        private static object _locker = new Object();
        private static ConnectionMultiplexer _instance = null;

        /// <summary>
        /// 返回已連接的實例， 
        /// </summary>
        public static ConnectionMultiplexer Instance
        {
            get
            {
                if (_instance == null)
                {
                    lock (_locker)
                    {
                        if (_instance == null || !_instance.IsConnected)
                        {
                            _instance = ConnectionMultiplexer.Connect(Coonstr);
                        }
                    }
                }
                //註冊如下事件
                _instance.ConnectionFailed += MuxerConnectionFailed;
                _instance.ConnectionRestored += MuxerConnectionRestored;
                _instance.ErrorMessage += MuxerErrorMessage;
                _instance.ConfigurationChanged += MuxerConfigurationChanged;
                _instance.HashSlotMoved += MuxerHashSlotMoved;
                _instance.InternalError += MuxerInternalError; 
                return _instance;
            }
        }
        static RedisHelper()
        {
        }

        /// <summary>
        /// 獲取一個連接實例
        /// </summary>
        /// <returns></returns>
        public static IDatabase GetDatabase()
        {
            return Instance.GetDatabase();
        }

        /// <summary>
        /// 過期時間
        /// </summary>
        /// <param name="Min">分鐘</param>
        /// <returns></returns>
        private static TimeSpan ExpireTimeSpan(double Min)
        {
            bool bl = bool.Parse(ConfigurationManager.AppSettings["UseRedis"]);

            if (bl)
            {
                return TimeSpan.FromMinutes(Min);
            }
            else
            {
                return TimeSpan.FromMilliseconds(1);
            }
        }

        

        /// <summary>
        /// 清除 包含特定字元的所有緩存
        /// </summary>
        public static void RemoveSpeStr(string keyStr)
        {
            List<string> listKeys = GetAllKeys();
            foreach (string k in listKeys)
            {
                if (k.Contains(keyStr))
                {
                    Remove(k);
                }
            }
        }


        /// <summary>
        /// 判斷在緩存中是否存在該key的緩存數據
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public static bool Exists(string key)
        { 
            return GetDatabase().KeyExists(key);  //可直接調用
        }
         
         
        /// <summary>
        /// 移除指定key的緩存
        /// </summary>
        /// <param name="key"></param>
        /// <returns></returns>
        public static bool Remove(string key)
        {
            if (Exists(key))
            {
                return GetDatabase().KeyDelete(key);
            }
            return false;
        }

        /// <summary>
        ///  Set
        /// </summary>
        /// <typeparam name="T">類型</typeparam>
        /// <param name="key">鍵</param>
        /// <param name="t">值</param>
        /// <param name="timeout">多少分鐘後過期</param>
        /// <returns></returns>
        public static bool Set<T>(string key, T t, double minOut = 60*3)
        { 
            return GetDatabase().StringSet(key, Serialize(t), ExpireTimeSpan(minOut));
        }
         
        /// <summary>
        /// Get
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="key"></param>
        /// <returns></returns>
        public static T Get<T>(string key)
        { 
            return Deserialize<T>(GetDatabase().StringGet(key));
        }
         
        /// <summary>
        /// DataSet 緩存
        /// </summary> 
        public static bool SetData(string key, DataSet ds, double minOut = 60*3)
        {  
            return GetDatabase().StringSet(key, Serialize(ds), ExpireTimeSpan(minOut));
        }
         
        /// <summary>
        /// 獲取 DataSet 
        /// </summary> 
        public static DataSet GetDataSet(string key)
        { 
            return Deserialize<DataSet>(GetDatabase().StringGet(key)); 
        }

        /// <summary>
        /// 刷新緩存
        /// </summary>
        public static void FlushAll()
        {
            var endpoints = Instance.GetEndPoints();
            var server = Instance.GetServer(endpoints.First());

            server.FlushDatabase(); // to wipe a single database, 0 by default
            //server.FlushAllDatabases(); // to wipe all databases
        }


        /// <summary>
        /// 得到所有緩存鍵值
        /// </summary>
        /// <returns></returns>
        public static List<string> GetAllKeys()
        {
            List<string> lstKey = new List<string>();
            var endpoints = Instance.GetEndPoints();
            var server = Instance.GetServer(endpoints.First()); 
            var keys = server.Keys();
            foreach (var key in keys)
            {
                lstKey.Add(key);
            }
            return lstKey;
        }

        //----------------------------------------------------------------------------------------------------------
        static string JsonSerialize(object o)
        {
            if (o == null)
            {
                return null;
            } 
            return JsonConvert.SerializeObject(o);
        }

        static T JsonDeserialize<T>(string json)
        {
            if (json == null)
            {
                return default(T);
            }
            return JsonConvert.DeserializeObject<T>(json);
        }

         
        /// <summary>
        /// 序列化對象
        /// </summary>
        /// <param name="o"></param>
        /// <returns></returns>
        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>
        /// 反序列化對象
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="stream"></param>
        /// <returns></returns>
        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;
            }
        }

        /// <summary>
        /// 配置更改時
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void MuxerConfigurationChanged(object sender, EndPointEventArgs e)
        {
            LogHelper.LogExceRun("Configuration changed: " + e.EndPoint, new Exception());
        }

        /// <summary>
        /// 發生錯誤時
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void MuxerErrorMessage(object sender, RedisErrorEventArgs e)
        { 
            LogHelper.LogExceRun("ErrorMessage: " + e.Message, new Exception());
        }

        /// <summary>
        /// 重新建立連接之前的錯誤
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void MuxerConnectionRestored(object sender, ConnectionFailedEventArgs e)
        { 
            LogHelper.LogExceRun("ConnectionRestored: " + e.EndPoint, new Exception());
        }

        /// <summary>
        /// 連接失敗 ， 如果重新連接成功你將不會收到這個通知
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void MuxerConnectionFailed(object sender, ConnectionFailedEventArgs e)
        {
            LogHelper.LogExceRun("重新連接：Endpoint failed: " + e.EndPoint + ", " + e.FailureType + (e.Exception == null ? "" : (", " + e.Exception.Message)), new Exception()); 
        }

        /// <summary>
        /// 更改集群
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void MuxerHashSlotMoved(object sender, HashSlotMovedEventArgs e)
        { 
            LogHelper.LogExceRun("HashSlotMoved:NewEndPoint" + e.NewEndPoint + ", OldEndPoint" + e.OldEndPoint, new Exception()); 
        }

        /// <summary>
        /// redis類庫錯誤
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        private static void MuxerInternalError(object sender, InternalErrorEventArgs e)
        {
            LogHelper.LogExceRun("InternalError:Message" + e.Exception.Message, new Exception()); 
        }
         
        /// <summary>
        /// GetServer方法會接收一個EndPoint類或者一個唯一標識一臺伺服器的鍵值對
        /// 有時候需要為單個伺服器指定特定的命令
        /// 使用IServer可以使用所有的shell命令，比如：
        /// DateTime lastSave = server.LastSave();
        /// ClientInfo[] clients = server.ClientList();
        /// 如果報錯在連接字元串後加 ,allowAdmin=true;
        /// </summary>
        /// <returns></returns>
        public static IServer GetServer(string host, int port)
        {
            IServer server = Instance.GetServer(host, port);
            return server;
        }

        /// <summary>
        /// 獲取全部終結點
        /// </summary>
        /// <returns></returns>
        public static EndPoint[] GetEndPoints()
        {
            EndPoint[] endpoints = Instance.GetEndPoints();
            return endpoints;
        }

    }
}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 【C#Windows 服務】 《一》初入門
    【C#Windows 服務】 《一》初入門 目錄： 1.【C#Windows 服務】 《一》初入門 2.【C#Windows 服務】 《二》INI配置文件 一、工具： VS2015+NET Framework4.5。 二、操作： 1、新建windows服務的項目： 2、修改windows服務相關內容 ...
  • c#下volatile關鍵字
    volatile多用於多線程的環境，當一個變數定義為volatile時，讀取這個變數的值時候每次都是從momery裡面讀取而不是從cache讀。這樣做是為了保證讀取該變數的信息都是最新的，而無論其他線程如何更新這個變數。 volatile多用於多線程的環境，當一個變數定義為volatile時，讀取這 ...
  • Asp.net mvc5引用ExtJS6【全網首發】
    摘要：VisualStuio2015 asp.net mvc如何引用ExtJS6，使用BundleConfig。 首先下載ExtJS6.0 gpl版。ExtJS有自己的程式框架，但我們需要asp.net mvc5，ExtJS只用作界面庫。 接下來要把下載好的ExtJS6的核心部分抽取出來，目錄結構是... ...
  • Dapper學習 - Dapper的基本用法(二) - 存儲過程/函數
    上一篇貌似少介紹了自定義函數和存儲過程, 因為這兩個也可以使用查詢的方式來實現功能, 這一篇就補上 一、自定義函數的創建和調用 (mysql的) 註意在mysql中, delimiter $$ 這個的使用, 起一個分割功能, 有些編譯器中, 如果不寫這個, 是不會把這些當做方法,存儲過程去處理的, ...
  • winform列印預覽條形碼
    預覽效果 源碼下載地址：http://files.cnblogs.com/files/luoxiaozhao/PrintDemo.rar ...
  • 執行插入語句，object val = cmd.ExecuteScalar() val = null
    在寫介面的過程中遇到錯誤：空對象不能轉換為值類型 因為我們使用的是petapoco，經過調試後發現是 object val = cmd.ExecuteScalar() 這一句造成的報錯， val = null 因為我執行的是insert語句，而這個方法的功能是：只返回數據集的第一行第一列 解決方案： ...
  • 從一個父級控制項找到某一個子級控制項
    /// <summary> /// 刷新圖層列表,添加素材子元素時間控制項TimeRange /// </summary> public void RefreshListView() { for (int i = 0; i < lstCoverage.Items.Count; i++) //lstCo ...
  • asp.net實現圖片線上上傳併在線裁剪
    asp.net實現圖片線上上傳併在線裁剪，線上上傳使用的是uploadify，線上裁剪使用的是jcrop，兩者結合併使用jquery ajax一般處理程式完美結合 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類