| | |
| | | * 限流 |
| | | * |
| | | * @param key 限流key |
| | | * @param limitType 限流类型 |
| | | * @param rateType 限流类型 |
| | | * @param rate 速率 |
| | | * @param rateInterval 速率间隔 |
| | | * @return -1 表示失败 |
| | | */ |
| | | public static boolean rateLimiter(String key, RateType rateType, int rate, int rateInterval) { |
| | | public static long rateLimiter(String key, RateType rateType, int rate, int rateInterval) { |
| | | RRateLimiter rateLimiter = client.getRateLimiter(key); |
| | | rateLimiter.trySetRate(rateType, rate, rateInterval, RateIntervalUnit.SECONDS); |
| | | return rateLimiter.tryAcquire(); |
| | | if (rateLimiter.tryAcquire()) { |
| | | return rateLimiter.availablePermits(); |
| | | } else { |
| | | return -1L; |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 获取实例id |
| | | */ |
| | | public static String getClientId() { |
| | | return client.getId(); |
| | | } |
| | | |
| | | /** |
| | |
| | | * @param value 缓存的值 |
| | | */ |
| | | public static <T> void setCacheObject(final String key, final T value) { |
| | | client.getBucket(key).set(value); |
| | | setCacheObject(key, value, false); |
| | | } |
| | | |
| | | /** |
| | | * 缓存基本的对象,保留当前对象 TTL 有效期 |
| | | * |
| | | * @param key 缓存的键值 |
| | | * @param value 缓存的值 |
| | | * @param isSaveTtl 是否保留TTL有效期(例如: set之前ttl剩余90 set之后还是为90) |
| | | * @since Redis 6.0.0 以上有效 |
| | | */ |
| | | public static <T> void setCacheObject(final String key, final T value, final boolean isSaveTtl) { |
| | | RBucket<Object> bucket = client.getBucket(key); |
| | | if (isSaveTtl) { |
| | | bucket.setAndKeepTTL(value); |
| | | } else { |
| | | bucket.set(value); |
| | | } |
| | | } |
| | | |
| | | /** |
| | |
| | | } |
| | | |
| | | /** |
| | | * 删除Hash中的数据 |
| | | * |
| | | * @param key Redis键 |
| | | * @param hKey Hash键 |
| | | * @return Hash中的对象 |
| | | */ |
| | | public static <T> T delCacheMapValue(final String key, final String hKey) { |
| | | RMap<String, T> rMap = client.getMap(key); |
| | | return rMap.remove(hKey); |
| | | } |
| | | |
| | | /** |
| | | * 获取多个Hash中的数据 |
| | | * |
| | | * @param key Redis键 |