using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Options;
|
using WIDESEAWCS_RedisService.Connection;
|
using WIDESEAWCS_RedisService.Options;
|
|
namespace WIDESEAWCS_RedisService.Counter
|
{
|
public class RedisCounterService : ICounterService
|
{
|
private readonly IRedisConnectionManager _connectionManager;
|
private readonly RedisOptions _options;
|
private readonly ILogger<RedisCounterService> _logger;
|
|
public RedisCounterService(
|
IRedisConnectionManager connectionManager,
|
IOptions<RedisOptions> options,
|
ILogger<RedisCounterService> logger)
|
{
|
_connectionManager = connectionManager;
|
_options = options.Value;
|
_logger = logger;
|
}
|
|
private string BuildKey(string key) => $"{_options.KeyPrefix}counter:{key}";
|
|
public long Increment(string key, long value = 1)
|
{
|
return _connectionManager.GetDatabase().StringIncrement(BuildKey(key), value);
|
}
|
|
public long Decrement(string key, long value = 1)
|
{
|
return _connectionManager.GetDatabase().StringDecrement(BuildKey(key), value);
|
}
|
|
public long GetCount(string key)
|
{
|
var val = _connectionManager.GetDatabase().StringGet(BuildKey(key));
|
return val.IsNullOrEmpty ? 0 : (long)val;
|
}
|
|
public bool Reset(string key)
|
{
|
return _connectionManager.GetDatabase().KeyDelete(BuildKey(key));
|
}
|
|
public long IncrementWithExpiry(string key, TimeSpan expiry, long value = 1)
|
{
|
var db = _connectionManager.GetDatabase();
|
var fullKey = BuildKey(key);
|
var result = db.StringIncrement(fullKey, value);
|
if (result == value)
|
db.KeyExpire(fullKey, expiry);
|
return result;
|
}
|
}
|
}
|
