feat: add redis config

redis serialization: Jackson2JsonRedisSerializer maven 打包只需要执行父类的package即可。

Author: Zeemann Lin

activity/pom.xml

@@ -10,6 +10,7 @@
  </parent>
 
  <artifactId>activity</artifactId>
+ <packaging>jar</packaging>
 
  <properties>
  <maven.compiler.source>17</maven.compiler.source>
@@ -21,7 +22,7 @@
 
  <dependency>
  <groupId>com.example</groupId>
- <artifactId>core</artifactId>
+ <artifactId>common-core</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  </dependency>
 
@@ -44,6 +45,27 @@
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  </dependency>
+
  </dependencies>
 
+ <build>
+ <plugins>
+ <plugin>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-maven-plugin</artifactId>
+ <configuration>
+ <mainClass>com.example.activity.ActivityApplication</mainClass>
+ </configuration>
+ <executions>
+ <execution>
+ <goals>
+ <goal>repackage</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+
+
 </project>

activity/src/main/java/com/example/activity/ActivityApplication.java

@@ -3,8 +3,7 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
-@SpringBootApplication(scanBasePackages = {"com.example.common",
- "com.example.activity"})
+@SpringBootApplication
 public class ActivityApplication {
 
  public static void main(String[] args) {

activity/src/main/java/com/example/activity/controller/ProviderController.java

@@ -7,9 +7,9 @@
 import com.example.activity.service.EmailService;
 import com.example.common.core.response.ResponseResult;
 import com.example.common.core.response.code.ErrorCode;
+import com.example.common.core.utils.RedisUtil;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.HashMap;
@@ -23,6 +23,8 @@ public class ProviderController implements ProviderApi {
 
  private final EmailService emailService;
 
+ private final RedisUtil redisUtil;
+
 
  @Override
  public ResponseResult sendEmail(String emailAddress) {
@@ -37,6 +39,7 @@ public ResponseResult provider(){
  hashmap.put("3", ResponseResult.failed().isSuccess());
  hashmap.put("4", ResponseResult.failed("message").isSuccess());
  hashmap.put("5", ResponseResult.failed(ErrorCode.FORBIDDEN).isSuccess());
+ redisUtil.set("1","2",30);
  return ResponseResult.success(hashmap);
  }
 

activity/src/test/java/com/example/activity/ActivityApplicationTests.java

@@ -10,6 +10,7 @@
  </parent>
 
  <artifactId>auth_client</artifactId>
+ <packaging>jar</packaging>
 
  <properties>
  <maven.compiler.source>17</maven.compiler.source>

auth/auth_client/pom.xml

@@ -10,6 +10,7 @@
  </parent>
 
  <artifactId>auth_server</artifactId>
+ <packaging>jar</packaging>
 
  <properties>
  <maven.compiler.source>17</maven.compiler.source>
@@ -20,15 +21,10 @@
  <dependencies>
  <dependency>
  <groupId>com.example</groupId>
- <artifactId>core</artifactId>
+ <artifactId>common-core</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  </dependency>
 
- <dependency>
- <groupId>com.example</groupId>
- <artifactId>redis</artifactId>
- <version>0.0.1-SNAPSHOT</version>
- </dependency>
 
 
  <dependency>

auth/auth_server/pom.xml

@@ -9,7 +9,9 @@
  <version>0.0.1-SNAPSHOT</version>
  </parent>
 
- <artifactId>core</artifactId>
+ <artifactId>common-core</artifactId>
+ <version>0.0.1-SNAPSHOT</version>
+ <packaging>jar</packaging>
 
  <properties>
  <maven.compiler.source>17</maven.compiler.source>
@@ -22,7 +24,18 @@
  <groupId>com.fasterxml.jackson.core</groupId>
  <artifactId>jackson-databind</artifactId>
  </dependency>
-
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-starter-data-redis</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>org.redisson</groupId>
+ <artifactId>redisson</artifactId>
+ </dependency>
+ <dependency>
+ <groupId>com.fasterxml.jackson.datatype</groupId>
+ <artifactId>jackson-datatype-jsr310</artifactId>
+ </dependency>
  <dependency>
  <groupId>com.alibaba.cloud</groupId>
  <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
@@ -37,7 +50,10 @@
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-bootstrap</artifactId>
  </dependency>
-
+ <dependency>
+ <groupId>org.springframework.boot</groupId>
+ <artifactId>spring-boot-autoconfigure</artifactId>
+ </dependency>
  <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>

common/core/pom.xml renamed to common/common-core/pom.xml

@@ -1,4 +1,4 @@
-package com.example.common.redis.config;
+package com.example.common.core.config;
 
 import com.fasterxml.jackson.annotation.JsonAutoDetect;
 import com.fasterxml.jackson.annotation.JsonTypeInfo;
@@ -7,10 +7,7 @@
 import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
 import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;
 import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
-import io.netty.buffer.ByteBuf;
-import io.netty.buffer.ByteBufAllocator;
-import io.netty.buffer.ByteBufInputStream;
-import io.netty.buffer.ByteBufOutputStream;
+import io.netty.buffer.*;
 import org.redisson.client.codec.BaseCodec;
 import org.redisson.client.protocol.Decoder;
 import org.redisson.client.protocol.Encoder;
@@ -19,6 +16,7 @@
 import java.io.InputStream;
 import java.io.OutputStream;
 
+
 public class CustomJsonJacksonCodec extends BaseCodec {
  public static final CustomJsonJacksonCodec INSTANCE = new CustomJsonJacksonCodec();
 
@@ -67,4 +65,4 @@ public static ObjectMapper getObjectMapper() {
  return objectMapper;
  }
 
-}
+}

common/redis/src/main/java/com/example/common/redis/config/CustomJsonJacksonCodec.java renamed to common/common-core/src/main/java/com/example/common/core/config/CustomJsonJacksonCodec.java

@@ -1,19 +1,26 @@
-package com.example.common.redis.config;
+package com.example.common.core.config;
 
+import com.example.common.core.utils.RedisKeyUtil;
+import com.example.common.core.utils.RedisUtil;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
 import org.springframework.data.redis.serializer.StringRedisSerializer;
+
 /**
  * Redis配置
  */
 @Configuration
-public class RedisAutoConfig {
+@AutoConfigureAfter({RedisSessionAutoConfiguration.class})
+@Import({RedisUtil.class, RedisKeyUtil.class})
+public class RedisAutoConfiguration {
 
  /**
  * 自定义RedisTemplate

common/redis/src/main/java/com/example/common/redis/config/RedisAutoConfig.java renamed to common/common-core/src/main/java/com/example/common/core/config/RedisAutoConfiguration.java

@@ -0,0 +1,96 @@
+package com.example.common.core.config;
+
+import com.example.common.core.utils.RedisKeyUtil;
+import org.redisson.Redisson;
+import org.redisson.api.RBloomFilter;
+import org.redisson.api.RedissonClient;
+import org.redisson.client.codec.Codec;
+import org.redisson.config.Config;
+import org.springframework.boot.autoconfigure.AutoConfigureBefore;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
+import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
+
+
+@ConditionalOnClass(Redisson.class)
+@AutoConfigureBefore({RedisAutoConfiguration.class})
+@EnableConfigurationProperties(RedisProperties.class)
+public class RedisSessionAutoConfiguration {
+
+ private static final String REDIS_PROTOCOL_PREFIX = "redis://";
+
+ private static final String REDISS_PROTOCOL_PREFIX = "rediss://";
+
+ @Bean
+ public RBloomFilter<String> bloomFilter(RedissonClient redisson) {
+ RBloomFilter<String> bloomFilter = redisson.getBloomFilter(RedisKeyUtil.getBloomFilterKey());
+ bloomFilter.tryInit(10000,0.01);
+ return bloomFilter;
+ }
+
+ /**
+ * redisson配置
+ * @param properties redis配置文件
+ * @return
+ */
+ @Bean(destroyMethod = "shutdown")
+ @ConditionalOnMissingBean(RedissonClient.class)
+ public RedissonClient redisClient(RedisProperties properties) {
+ Config config;
+ final Duration duration = properties.getTimeout();
+ int timeout = duration == null ? 0 : (int) duration.toMillis();
+ if (properties.getSentinel() != null) {
+ config = new Config();
+ config.useSentinelServers()
+ .setMasterName(properties.getSentinel().getMaster())
+ .addSentinelAddress(convertNodes(properties.isSsl(),properties.getSentinel().getNodes()))
+ .setDatabase(properties.getDatabase())
+ .setConnectTimeout(timeout)
+ .setPassword(properties.getPassword());
+ } else if (properties.getCluster() != null) {
+ config = new Config();
+ config.useClusterServers()
+ .addNodeAddress(convertNodes(properties.isSsl(),properties.getCluster().getNodes()))
+ .setPassword(properties.getPassword())
+ .setTimeout(timeout);
+ } else {
+ config = new Config();
+ config.useSingleServer()
+ .setAddress(convertAddress(properties.isSsl(),properties.getHost() ,properties.getPort()))
+ .setDatabase(properties.getDatabase())
+ .setPassword(properties.getPassword())
+ .setTimeout(timeout);
+ }
+ // 使用json序列化方式
+ Codec codec = CustomJsonJacksonCodec.INSTANCE;
+ config.setCodec(codec);
+ return Redisson.create(config);
+ }
+
+ private String getProtocolPrefix(boolean isSsl) {
+ return isSsl ? REDISS_PROTOCOL_PREFIX : REDIS_PROTOCOL_PREFIX;
+ }
+
+ private String convertAddress(boolean isSsl,String host,int port) {
+ return getProtocolPrefix(isSsl) + host + ":" + port;
+ }
+
+ private String[] convertNodes(boolean isSsl,List<String> nodeList) {
+ List<String> nodes = new ArrayList<>(nodeList.size());
+ for (String node : nodeList) {
+ if (node.startsWith(REDISS_PROTOCOL_PREFIX) || node.startsWith(REDIS_PROTOCOL_PREFIX)) {
+ nodes.add(node);
+ } else {
+ nodes.add(getProtocolPrefix(isSsl) + node);
+ }
+ }
+ return nodes.toArray(new String[0]);
+ }
+
+}