12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667 |
- using OASystem.RedisRepository.CommonHelper;
- using OASystem.RedisRepository.Config;
- using StackExchange.Redis;
- using System;
- using System.Collections.Generic;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- namespace OASystem.RedisRepository.RedisAsyncHelper
- {
-
-
- internal partial class RedisHelper : IRedisHelper
- {
- private static IDatabase _client;
- internal RedisHelper()
- {
- _client = RedisConnection.GenerateConnection.GetDatabase();
- }
- #region String 写操作
-
-
-
-
-
-
-
-
- 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 读操作
-
-
-
-
-
-
- public async Task<T> StringGetAsync<T>(string key)
- {
- return SerializeHelper.Deserialize<T>(await _client.StringGetAsync(key, CommandFlags.PreferSlave));
- }
- #endregion
- }
- }
|