starter-redis代码整理

yangys

2024-04-24 11b76c76bcd4f235fb75959b53b64c6d9a2dd71e

starter-redis代码整理

 smart-starter-redis/src/main/java/com/qianwen/core/redis/cache/BladeRedis.java

@@ -21,7 +21,6 @@
import org.springframework.lang.Nullable;
import org.springframework.util.Assert;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/cache/BladeRedis.class */
public class BladeRedis {
    private final RedisTemplate<String, Object> redisTemplate;
    private final ValueOperations<String, Object> valueOps;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/cache/CacheKey.java

@@ -3,7 +3,6 @@
import java.time.Duration;
import org.springframework.lang.Nullable;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/cache/CacheKey.class */
public class CacheKey {
    private final String key;
    @Nullable

 smart-starter-redis/src/main/java/com/qianwen/core/redis/cache/ICacheKey.java

@@ -5,7 +5,6 @@
import com.qianwen.core.tool.utils.StringUtil;
import org.springframework.lang.Nullable;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/cache/ICacheKey.class */
public interface ICacheKey {
    String getPrefix();


 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/BladeRedisCacheAutoConfiguration.java

@@ -23,7 +23,6 @@
@AutoConfigureBefore({JwtRedisConfiguration.class})
@EnableConfigurationProperties({CacheProperties.class})
@Configuration(proxyBeanMethods = false)
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/BladeRedisCacheAutoConfiguration.class */
public class BladeRedisCacheAutoConfiguration {
    private final RedisSerializer<Object> redisSerializer;
    private final CacheProperties cacheProperties;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/BladeRedisProperties.java

@@ -3,11 +3,11 @@
import org.springframework.boot.context.properties.ConfigurationProperties;

@ConfigurationProperties("blade.redis")
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/BladeRedisProperties.class */

public class BladeRedisProperties {
    private SerializerType serializerType = SerializerType.ProtoStuff;

    /* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/BladeRedisProperties$SerializerType.class */
    
    public enum SerializerType {
        ProtoStuff,
        JSON,

 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/BladeRedisSerializerConfigAble.java

@@ -1,11 +1,11 @@
package com.qianwen.core.redis.config;

import com.qianwen.core.redis.config.BladeRedisProperties;
import com.qianwen.core.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializer;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/BladeRedisSerializerConfigAble.class */
import com.qianwen.core.redis.serializer.GenericJackson2JsonRedisSerializer;


public interface BladeRedisSerializerConfigAble {
    public static final String TYPE_NAME = "@class";


 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/ProtoStuffSerializerConfiguration.java

@@ -1,7 +1,5 @@
package com.qianwen.core.redis.config;

import com.qianwen.core.redis.config.BladeRedisProperties;
import com.qianwen.core.redis.serializer.ProtoStuffSerializer;
import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
@@ -9,10 +7,12 @@
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.serializer.RedisSerializer;

import com.qianwen.core.redis.serializer.ProtoStuffSerializer;

@AutoConfigureBefore({RedisTemplateConfiguration.class})
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(name = {"io.protostuff.Schema"})
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/ProtoStuffSerializerConfiguration.class */

public class ProtoStuffSerializerConfiguration implements BladeRedisSerializerConfigAble {
    @Override // org.springblade.core.redis.config.BladeRedisSerializerConfigAble
    @ConditionalOnMissingBean

 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/RedisAutoCacheManager.java

@@ -12,7 +12,6 @@
import org.springframework.lang.NonNull;
import org.springframework.lang.Nullable;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/RedisAutoCacheManager.class */
public class RedisAutoCacheManager extends RedisCacheManager {
    public RedisAutoCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration, Map<String, RedisCacheConfiguration> initialCacheConfigurations, boolean allowInFlightCacheCreation) {
        super(cacheWriter, defaultCacheConfiguration, initialCacheConfigurations, allowInFlightCacheCreation);

 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/RedisCacheManagerConfig.java

@@ -10,7 +10,6 @@

@ConditionalOnMissingBean({CacheManagerCustomizers.class})
@Configuration(proxyBeanMethods = false)
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/RedisCacheManagerConfig.class */
public class RedisCacheManagerConfig {
    @Bean
    public CacheManagerCustomizers cacheManagerCustomizers(ObjectProvider<List<CacheManagerCustomizer<?>>> customizers) {

 smart-starter-redis/src/main/java/com/qianwen/core/redis/config/RedisTemplateConfiguration.java

@@ -19,7 +19,6 @@
@EnableConfigurationProperties({BladeRedisProperties.class})
@Configuration(proxyBeanMethods = false)
@EnableCaching
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/config/RedisTemplateConfiguration.class */
public class RedisTemplateConfiguration implements BladeRedisSerializerConfigAble {
    @Override // org.springblade.core.redis.config.BladeRedisSerializerConfigAble
    @ConditionalOnMissingBean({RedisSerializer.class})

 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/BladeLockAutoConfiguration.java

@@ -7,8 +7,6 @@
import org.redisson.config.MasterSlaveServersConfig;
import org.redisson.config.SentinelServersConfig;
import org.redisson.config.SingleServerConfig;
import com.qianwen.core.redis.lock.BladeLockProperties;
import com.qianwen.core.tool.utils.StringUtil;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@@ -16,11 +14,12 @@
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import com.qianwen.core.tool.utils.StringUtil;

@EnableConfigurationProperties({BladeLockProperties.class})
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass({RedissonClient.class})
@ConditionalOnProperty(value = {"blade.lock.enabled"}, havingValue = "true")
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/BladeLockAutoConfiguration.class */
public class BladeLockAutoConfiguration {
    private static Config singleConfig(BladeLockProperties properties) {
        Config config = new Config();

 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/BladeLockProperties.java

@@ -3,7 +3,6 @@
import org.springframework.boot.context.properties.ConfigurationProperties;

@ConfigurationProperties(BladeLockProperties.PREFIX)
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/BladeLockProperties.class */
public class BladeLockProperties {
    public static final String PREFIX = "blade.lock";
    private String password;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/LockType.java

@@ -1,6 +1,5 @@
package com.qianwen.core.redis.lock;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/LockType.class */
public enum LockType {
    REENTRANT,
    FAIR

 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/RedisLock.java

@@ -10,7 +10,6 @@
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/RedisLock.class */
public @interface RedisLock {
    String value();


 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/RedisLockAspect.java

@@ -16,7 +16,6 @@
import org.springframework.util.Assert;

@Aspect
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/RedisLockAspect.class */
public class RedisLockAspect implements ApplicationContextAware {
    private static final BladeExpressionEvaluator EVALUATOR = new BladeExpressionEvaluator();
    private final RedisLockClient redisLockClient;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/RedisLockClient.java

@@ -3,7 +3,7 @@
import java.util.concurrent.TimeUnit;
import com.qianwen.core.tool.function.CheckedSupplier;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/RedisLockClient.class */

public interface RedisLockClient {
    boolean tryLock(String lockName, LockType lockType, long waitTime, long leaseTime, TimeUnit timeUnit) throws InterruptedException;


 smart-starter-redis/src/main/java/com/qianwen/core/redis/lock/RedisLockClientImpl.java

@@ -7,7 +7,7 @@
import org.slf4j.LoggerFactory;
import com.qianwen.core.tool.function.CheckedSupplier;
import com.qianwen.core.tool.utils.Exceptions;
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/lock/RedisLockClientImpl.class */

public class RedisLockClientImpl implements RedisLockClient {
    private static final Logger log = LoggerFactory.getLogger(RedisLockClientImpl.class);
    private final RedissonClient redissonClient;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/ratelimiter/RateLimiter.java

@@ -10,7 +10,6 @@
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/ratelimiter/RateLimiter.class */
public @interface RateLimiter {
    String value();


 smart-starter-redis/src/main/java/com/qianwen/core/redis/ratelimiter/RateLimiterClient.java

@@ -4,7 +4,6 @@
import com.qianwen.core.tool.function.CheckedSupplier;
import com.qianwen.core.tool.utils.Exceptions;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/ratelimiter/RateLimiterClient.class */
public interface RateLimiterClient {
    boolean isAllowed(String key, long max, long ttl, TimeUnit timeUnit);


 smart-starter-redis/src/main/java/com/qianwen/core/redis/ratelimiter/RateLimiterException.java

@@ -2,7 +2,6 @@

import java.util.concurrent.TimeUnit;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/ratelimiter/RateLimiterException.class */
public class RateLimiterException extends RuntimeException {
    private final String key;
    private final long max;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/ratelimiter/RedisRateLimiterAspect.java

@@ -17,7 +17,6 @@
import org.springframework.util.Assert;

@Aspect
/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/ratelimiter/RedisRateLimiterAspect.class */
public class RedisRateLimiterAspect implements ApplicationContextAware {
    private final BladeExpressionEvaluator evaluator = new BladeExpressionEvaluator();
    private final RedisRateLimiterClient rateLimiterClient;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/ratelimiter/RedisRateLimiterClient.java

@@ -7,7 +7,6 @@
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.RedisScript;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/ratelimiter/RedisRateLimiterClient.class */
public class RedisRateLimiterClient implements RateLimiterClient {
    private static final String REDIS_KEY_PREFIX = "limiter:";
    private static final long FAIL_CODE = 0;

 smart-starter-redis/src/main/java/com/qianwen/core/redis/serializer/BytesWrapper.java

@@ -1,6 +1,5 @@
package com.qianwen.core.redis.serializer;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/serializer/BytesWrapper.class */
public class BytesWrapper<T> implements Cloneable {
    private T value;


 smart-starter-redis/src/main/java/com/qianwen/core/redis/serializer/GenericJackson2JsonRedisSerializer.java

@@ -18,7 +18,6 @@
import org.springframework.util.Assert;
import org.springframework.util.StringUtils;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/serializer/GenericJackson2JsonRedisSerializer.class */
public class GenericJackson2JsonRedisSerializer implements RedisSerializer<Object> {
    private final ObjectMapper mapper;


 smart-starter-redis/src/main/java/com/qianwen/core/redis/serializer/ProtoStuffSerializer.java

@@ -8,7 +8,7 @@
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.SerializationException;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/serializer/ProtoStuffSerializer.class */

public class ProtoStuffSerializer implements RedisSerializer<Object> {
    private final Schema<BytesWrapper> schema = RuntimeSchema.getSchema(BytesWrapper.class);


 smart-starter-redis/src/main/java/com/qianwen/core/redis/serializer/RedisKeySerializer.java

@@ -8,7 +8,6 @@
import org.springframework.core.convert.support.DefaultConversionService;
import org.springframework.data.redis.serializer.RedisSerializer;

/* loaded from: blade-starter-redis-9.3.0.0-SNAPSHOT.jar:org/springblade/core/redis/serializer/RedisKeySerializer.class */
public class RedisKeySerializer implements RedisSerializer<Object> {
    private final Charset charset;
    private final ConversionService converter;