C#連接阿里雲KVStore

時間 2019-11-25

標籤 c# 連接阿里 kvstore 欄目 C# 简体版

原文原文鏈接

KVStore的簡單介紹

　　阿里雲KVStore兼容Redis。由於KVStore就至關於Redis的服務器端，咱們代碼只是看成客戶端，連接上服務器端就好了，阿里雲的KVStore詳情文檔見，https://docs.aliyun.com/#/pub/kvstore/key-value-store/kvstore-introduction。git

C#客戶端連接OCS

　　1.阿里雲文檔上介紹的是用ServiceStack去連接KVStore。那咱們項目中就用nuget去下載ServiceStack包。nuget搜索ServiceStack，搜索到的結果以下圖，安裝圖中標識的就能夠了。這個應該是最新的V4版本，當提醒你須要用商業版的時候，能夠去還原以前的V3版本，具體還原方法見，https://github.com/ServiceStackV3/ServiceStackV3。github

　　nuget搜索結果以下：redis

　　2.安裝好之後，寫連接和調用kvstore的代碼。其中_setting.AccessId, _setting.AccessKey, _setting.HostAddress，分別是KVStore的實例ID，連接密碼和連接地址。數據庫

  1 using ServiceStack.Redis;  2 //using ServiceStack.Text;  3 using ServiceStack.Common;  4 using System;  5 using System.Collections.Generic;  6 using System.Linq;  7 using System.Text;  8 using System.Threading.Tasks;  9 using System.Web.Script.Serialization;  10 using Zupo.Core.Caching;  11 using System.Text.RegularExpressions;  12  13  14 namespace KVStore  15 {  16 public class KVStoreService  17  {  18  19  IKVStoreSetting _setting;  20 private IRedisClient redisClient;  21 private bool linkServer = true;  22  23 public KVStoreService(IKVStoreSetting setting)  24  {  25 try  26  {  27 this._setting = setting;  28 //鏈接池模式  29 //string[] testReadWriteHosts = new[] {  30 //string.Format("redis://:{0}:{1}@{2}:6379",_setting.AccessId,_setting.AccessKey,_setting.HostAddress)/*redis://:實例id:密碼@訪問地址:端口*/  31 //};  32 //RedisClientManagerConfig RedisConfig = new RedisClientManagerConfig();  33 //RedisConfig.AutoStart = true;  34 //RedisConfig.MaxReadPoolSize = 60;  35 //RedisConfig.MaxWritePoolSize = 60;  36 ////RedisConfig.VerifyMasterConnections = false;//須要設置  37 ////PooledRedisClientManager redisPoolManager = new PooledRedisClientManager(10/*鏈接池個數*/, 10/*鏈接池超時時間*/, testReadWriteHosts);  38 //PooledRedisClientManager redisPoolManager = new PooledRedisClientManager(10/*鏈接池個數*/, 10/*鏈接池超時時間*/, testReadWriteHosts);  39 //redisClient = redisPoolManager.GetClient();//獲取鏈接  40 ////RedisNativeClient redisNativeClient = (RedisNativeClient)redisClient;  41 ////redisNativeClient.Client = null;//KVStore不支持client setname因此這裏須要顯示的把client對象置爲null  42 //var dbSize = redisClient.DbSize;  43  44 //單連接模式  45 //string host = _setting.HostAddress;/*訪問host地址*/  46 //string password = string.Format("{0}:{1}", _setting.AccessId, _setting.AccessKey);/*實例id:密碼*/  47 //redisClient = new RedisClient(host, 6379, password);  48 //var dbSize = redisClient.DbSize;  49  50 RedisClientManagerConfig RedisConfig = new RedisClientManagerConfig();  51 RedisConfig.AutoStart = true;  52 RedisConfig.MaxReadPoolSize = 60;  53 RedisConfig.MaxWritePoolSize = 60;  54 RedisConfig.DefaultDb = 1; //默認第一個db  55  56 PooledRedisClientManager prcm = new PooledRedisClientManager(new List<string>() { string.Format("{0}:{1}@{2}:6379", _setting.AccessId, _setting.AccessKey, _setting.HostAddress) },  57 new List<string>() { string.Format("{0}:{1}@{2}:6379", _setting.AccessId, _setting.AccessKey, _setting.HostAddress) }, RedisConfig);  58 redisClient = prcm.GetClient();  59  }  60 catch (Exception)  61  {  62 linkServer = false;  63  }  64  }  65  66 /// <summary>  67 /// 是否處於連接狀態  68 /// </summary>  69 protected bool LinkServer  70  {  71 get  72  {  73 return linkServer;  74  }  75  }  76  77 /// <summary>  78 /// 根據傳入的key-value添加一條記錄，當key已存在返回false  79 /// </summary>  80 /// <typeparam name="T"></typeparam>  81 /// <param name="key"></param>  82 /// <param name="value"></param>  83 /// <returns></returns>  84 protected bool Add<T>(string key, T value)  85  {  86 return redisClient.Add<T>(key, value);  87  }  88  89 /// <summary>  90 /// 根據傳入的key-value添加一條記錄，當key已存在返回false  91 /// </summary>  92 /// <typeparam name="T"></typeparam>  93 /// <param name="key"></param>  94 /// <param name="value"></param>  95 /// <param name="expiresIn">TimeSpan</param>  96 /// <returns></returns>  97 protected bool AddExpires<T>(string key, T value, TimeSpan expiresIn)  98  {  99 return redisClient.Add<T>(key, value, expiresIn); 100  } 101 102 /// <summary> 103 /// 獲取 104 /// </summary> 105 /// <typeparam name="T"></typeparam> 106 /// <param name="key"></param> 107 /// <returns></returns> 108 protected T Get<T>(string key) 109  { 110 try 111  { 112 return redisClient.Get<T>(key); 113  } 114 catch(Exception ex) 115  { 116 throw ex; 117  } 118  } 119 120 protected List<T> GetList<T>(string key) 121  { 122 return redisClient.Get<List<T>>(key); 123  } 124 125 /// <summary> 126 /// 根據傳入的多個key獲取多條記錄的值 127 /// </summary> 128 /// <typeparam name="T"></typeparam> 129 /// <param name="keys"></param> 130 /// <returns></returns> 131 protected IDictionary<string, T> GetAll<T>(IEnumerable<string> keys) 132  { 133 return redisClient.GetAll<T>(keys); 134  } 135 136 /// <summary> 137 /// 根據傳入的key移除一條記錄 138 /// </summary> 139 /// <param name="key"></param> 140 /// <returns></returns> 141 public void Remove(string key) 142  { 143  redisClient.Remove(key); 144  } 145 146 /// <summary> 147 /// 根據傳入的多個key移除多條記錄 148 /// </summary> 149 /// <param name="keys"></param> 150 protected void RemoveAll(IEnumerable<string> keys) 151  { 152  redisClient.RemoveAll(keys); 153  } 154 155 /// <summary> 156 /// Removes items by pattern 157 /// </summary> 158 /// <param name="pattern">pattern</param> 159 public void RemoveByPattern(string pattern) 160  { 161 var regex = new Regex(pattern, RegexOptions.Singleline | RegexOptions.Compiled | RegexOptions.IgnoreCase); 162 var keysToRemove = new List<String>(); 163 164 var allkeys = redisClient.GetAllKeys(); 165 foreach (var key in allkeys) 166 if (regex.IsMatch(key)) 167  keysToRemove.Add(key); 168 169 foreach (string key in keysToRemove) 170  { 171  Remove(key); 172  } 173  } 174 175 176 /// <summary> 177 /// 清空kv-store緩存 178 /// </summary> 179 /// <returns></returns> 180 public void Clear() 181  { 182 var allkeys = redisClient.GetAllKeys(); 183  redisClient.RemoveAll(allkeys); 184  } 185 186 /// <summary> 187 /// 根據傳入的key覆蓋一條記錄的值，當key不存在不會添加 188 /// </summary> 189 /// <typeparam name="T"></typeparam> 190 /// <param name="key"></param> 191 /// <param name="value"></param> 192 /// <returns></returns> 193 protected bool Replace<T>(string key, T value) 194  { 195 return redisClient.Replace<T>(key, value); 196  } 197 198 /// <summary> 199 /// 根據傳入的key修改一條記錄的值，當key不存在則添加 200 /// </summary> 201 /// <typeparam name="T"></typeparam> 202 /// <param name="key"></param> 203 /// <param name="value"></param> 204 /// <returns></returns> 205 protected bool Set<T>(string key, T value) 206  { 207 try 208  { 209 return redisClient.Set<T>(key, value); 210  } 211 catch(Exception ex) 212  { 213 throw ex; 214  } 215  } 216 217 protected bool Set<T>(string key, List<T> value) 218  { 219 try 220  { 221 JavaScriptSerializer jsonSerializer = new JavaScriptSerializer(); 222 //執行序列化 223 string objectStr = jsonSerializer.Serialize(value); 224 225 return redisClient.Set(key, value); 226  } 227 catch (Exception ex) 228  { 229 throw ex; 230  } 231  } 232 233 /// <summary> 234 /// 根據傳入的key修改一條記錄的值，當key不存在則添加 235 /// </summary> 236 /// <typeparam name="T"></typeparam> 237 /// <param name="key"></param> 238 /// <param name="value"></param> 239 /// <param name="expiresIn">TimeSpan</param> 240 /// <returns></returns> 241 protected bool SetExpires<T>(string key, T value, TimeSpan expiresIn) 242  { 243 return redisClient.Set<T>(key, value, expiresIn); 244  } 245 246 /// <summary> 247 /// 根據傳入的多個key覆蓋多條記錄 248 /// </summary> 249 /// <typeparam name="T"></typeparam> 250 /// <param name="values"></param> 251 protected void SetAll<T>(IDictionary<string, T> values) 252  { 253 redisClient.SetAll<T>(values); 254  } 255 256 /// <summary> 257 /// 判斷Key在本數據庫內是否已被使用(包括各類類型、內置集合等等) 258 /// </summary> 259 /// <param name="key"></param> 260 /// <returns></returns> 261 public bool Contains(string key) 262  { 263 return redisClient.ContainsKey(key); 264  } 265 266 /// <summary> 267 /// 獲取全部的Keys集合 268 /// </summary> 269 /// <returns></returns> 270 protected List<string> GetAllKeys() 271  { 272 return redisClient.GetAllKeys(); 273  } 274 275 /// <summary> 276 /// 重命名一個Key，值不變 277 /// </summary> 278 /// <param name="fromName"></param> 279 /// <param name="toName"></param> 280 protected void RenameKey(string fromName, string toName) 281  { 282  redisClient.RenameKey(fromName, toName); 283  } 284 285 /// <summary> 286 /// 清除本數據庫的全部數據 287 /// </summary> 288 protected void FlushDb() 289  { 290  redisClient.FlushAll(); 291  } 292 293 /// <summary> 294 /// 根據Key獲取當前存儲的值是什麼類型： 295 /// </summary> 296 /// <param name="key">None = 0 String = 1 List = 2 Set = 3 SortedSet = 4 Hash = 5</param> 297 /// <returns></returns> 298 protected RedisKeyType GetEntryType(string key) 299  { 300 return redisClient.GetEntryType(key); 301  } 302 303 /// <summary> 304 /// 添加一個項到內部的List<T> 305 /// </summary> 306 /// <param name="listId"></param> 307 /// <param name="value"></param> 308 protected void AddItemToList(string listId, string value) 309  { 310  redisClient.AddItemToList(listId, value); 311  } 312 313 /// <summary> 314 /// 添加一個項到內部的HashSet<T> 315 /// </summary> 316 /// <param name="setId"></param> 317 /// <param name="item"></param> 318 protected void AddItemToSet(string setId, string item) 319  { 320  redisClient.AddItemToSet(setId, item); 321  } 322 323 /// <summary> 324 /// 一次過將參數中的List<T>中的多個值添加入內部的List<T> 325 /// </summary> 326 /// <param name="listId"></param> 327 /// <param name="values"></param> 328 protected void AddRangeToList(string listId, List<string> values) 329  { 330  redisClient.AddRangeToList(listId, values); 331  } 332 333 /// <summary> 334 /// 一次過將參數中的HashSet<T>中的多個值添加入內部的HashSet<T> 335 /// </summary> 336 /// <param name="setId"></param> 337 /// <param name="items"></param> 338 protected void AddRangeToSet(string setId, List<string> items) 339  { 340  redisClient.AddRangeToSet(setId, items); 341  } 342 343 /// <summary> 344 /// 獲取指定ListId的內部List<T>的全部值 345 /// </summary> 346 /// <param name="listId"></param> 347 /// <returns></returns> 348 protected List<string> GetAllItemsFromList(string listId) 349  { 350 return redisClient.GetAllItemsFromList(listId); 351  } 352 353 /// <summary> 354 /// 獲取指定SetId的內部HashSet<T>的全部值 355 /// </summary> 356 /// <param name="setId"></param> 357 /// <returns></returns> 358 protected HashSet<string> GetAllItemsFromSet(string setId) 359  { 360 return redisClient.GetAllItemsFromSet(setId); 361  } 362 363 /// <summary> 364 /// 根據ListId和下標獲取一項 365 /// </summary> 366 /// <param name="listId"></param> 367 /// <param name="listIndex"></param> 368 /// <returns></returns> 369 protected string GetItemFromList(string listId, int listIndex) 370  { 371 return redisClient.GetItemFromList(listId, listIndex); 372  } 373  } 374 }