hummingbird
/
spring-boot-demo
Not watched
2
0
Fork 0
Code
Releases 0 Wiki Activity
Issues 0 Pull Requests 0 Datasets Model Cloudbrain
Browse Source

✨ 缓存模块之 redis 缓存案例完成

3.x
Yangkai.Shen 2 years ago
parent
5751436a69
commit
bbb3f3a98e
17 changed files with 298 additions and 335 deletions
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +36
    -0
      demo-cache/demo-cache-api/pom.xml
  2. +12
    -21
      demo-cache/demo-cache-api/src/main/java/com/xkcoding/cache/api/UserService.java
  3. +21
    -0
      demo-cache/demo-cache-api/src/main/java/com/xkcoding/cache/autoconfigure/CacheMockServiceAutoConfiguration.java
  4. +5
    -3
      demo-cache/demo-cache-api/src/main/java/com/xkcoding/cache/entity/User.java
  5. +2
    -0
      demo-cache/demo-cache-api/src/main/resources/META-INF/spring.factories
  6. +0
    -25
      demo-cache/demo-cache-redis/.gitignore
  7. +95
    -150
      demo-cache/demo-cache-redis/README.md
  8. +7
    -0
      demo-cache/demo-cache-redis/docker-compose.env.yml
  9. +57
    -63
      demo-cache/demo-cache-redis/pom.xml
  10. +10
    -2
      demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/RedisCacheApplication.java
  11. +8
    -6
      demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/configuration/RedisCacheAutoConfiguration.java
  12. +0
    -36
      demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/service/UserService.java
  13. +13
    -0
      demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/RedisCacheApplicationTests.java
  14. +20
    -8
      demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/RedisTest.java
  15. +0
    -16
      demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/SpringBootDemoCacheRedisApplicationTests.java
  16. +7
    -5
      demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/service/UserServiceTest.java
  17. +5
    -0
      demo-cache/pom.xml

+ 36
- 0
demo-cache/demo-cache-api/pom.xml View File

@@ -0,0 +1,36 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>com.xkcoding</groupId>
<artifactId>demo-cache</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>

<modelVersion>4.0.0</modelVersion>

<artifactId>demo-cache-api</artifactId>

<properties>
<java.version>17</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>

<build>
<finalName>demo-cache-api</finalName>
</build>

</project>

demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/service/impl/UserServiceImpl.java → demo-cache/demo-cache-api/src/main/java/com/xkcoding/cache/api/UserService.java View File

@@ -1,40 +1,34 @@
package com.xkcoding.cache.redis.service.impl;
package com.xkcoding.cache.api;


import com.google.common.collect.Maps;
import com.xkcoding.cache.redis.entity.User;
import com.xkcoding.cache.redis.service.UserService;
import com.xkcoding.cache.entity.User;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.cache.annotation.CacheEvict; import org.springframework.cache.annotation.CacheEvict;
import org.springframework.cache.annotation.CachePut; import org.springframework.cache.annotation.CachePut;
import org.springframework.cache.annotation.Cacheable; import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;


import java.util.HashMap;
import java.util.Map; import java.util.Map;


/** /**
* <p> * <p>
* UserService
* 模拟用户服务
* </p> * </p>
* *
* @author yangkai.shen * @author yangkai.shen
* @date Created in 2018-11-15 16:45
* @date Created in 2022-09-07 14:08
*/ */
@Service
@Slf4j @Slf4j
public class UserServiceImpl implements UserService {
@Service
public class UserService {
/** /**
* 模拟数据库 * 模拟数据库
*/ */
private static final Map<Long, User> DATABASES = Maps.newConcurrentMap();

/**
* 初始化数据
*/
static {
DATABASES.put(1L, new User(1L, "user1"));
DATABASES.put(2L, new User(2L, "user2"));
DATABASES.put(3L, new User(3L, "user3"));
}
private static final Map<Long, User> DATABASES = new HashMap<>() {{
put(1L, new User(1L, "user1"));
put(2L, new User(2L, "user2"));
put(3L, new User(3L, "user3"));
}};


/** /**
* 保存或修改用户 * 保存或修改用户
@@ -43,7 +37,6 @@ public class UserServiceImpl implements UserService {
* @return 操作结果 * @return 操作结果
*/ */
@CachePut(value = "user", key = "#user.id") @CachePut(value = "user", key = "#user.id")
@Override
public User saveOrUpdate(User user) { public User saveOrUpdate(User user) {
DATABASES.put(user.getId(), user); DATABASES.put(user.getId(), user);
log.info("保存用户【user】= {}", user); log.info("保存用户【user】= {}", user);
@@ -57,7 +50,6 @@ public class UserServiceImpl implements UserService {
* @return 返回结果 * @return 返回结果
*/ */
@Cacheable(value = "user", key = "#id") @Cacheable(value = "user", key = "#id")
@Override
public User get(Long id) { public User get(Long id) {
// 我们假设从数据库读取 // 我们假设从数据库读取
log.info("查询用户【id】= {}", id); log.info("查询用户【id】= {}", id);
@@ -70,7 +62,6 @@ public class UserServiceImpl implements UserService {
* @param id key值 * @param id key值
*/ */
@CacheEvict(value = "user", key = "#id") @CacheEvict(value = "user", key = "#id")
@Override
public void delete(Long id) { public void delete(Long id) {
DATABASES.remove(id); DATABASES.remove(id);
log.info("删除用户【id】= {}", id); log.info("删除用户【id】= {}", id);

+ 21
- 0
demo-cache/demo-cache-api/src/main/java/com/xkcoding/cache/autoconfigure/CacheMockServiceAutoConfiguration.java View File

@@ -0,0 +1,21 @@
package com.xkcoding.cache.autoconfigure;

import com.xkcoding.cache.api.UserService;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
* <p>
* 缓存 mock 自动装配
* </p>
*
* @author yangkai.shen
* @date 2022-09-07 14:31
*/
@Configuration(proxyBeanMethods = false)
public class CacheMockServiceAutoConfiguration {
@Bean
public UserService userService() {
return new UserService();
}
}

demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/entity/User.java → demo-cache/demo-cache-api/src/main/java/com/xkcoding/cache/entity/User.java View File

@@ -1,23 +1,25 @@
package com.xkcoding.cache.redis.entity;
package com.xkcoding.cache.entity;


import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.NoArgsConstructor; import lombok.NoArgsConstructor;


import java.io.Serial;
import java.io.Serializable; import java.io.Serializable;


/** /**
* <p> * <p>
* 用户实体
* 用户对象
* </p> * </p>
* *
* @author yangkai.shen * @author yangkai.shen
* @date Created in 2018-11-15 16:39
* @date Created in 2022-09-07 13:54
*/ */
@Data @Data
@AllArgsConstructor @AllArgsConstructor
@NoArgsConstructor @NoArgsConstructor
public class User implements Serializable { public class User implements Serializable {
@Serial
private static final long serialVersionUID = 2892248514883451461L; private static final long serialVersionUID = 2892248514883451461L;
/** /**
* 主键id * 主键id

+ 2
- 0
demo-cache/demo-cache-api/src/main/resources/META-INF/spring.factories View File

@@ -0,0 +1,2 @@
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.xkcoding.cache.autoconfigure.CacheMockServiceAutoConfiguration

+ 0
- 25
demo-cache/demo-cache-redis/.gitignore View File

@@ -1,25 +0,0 @@
/target/
!.mvn/wrapper/maven-wrapper.jar

### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache

### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr

### NetBeans ###
/nbproject/private/
/build/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/

+ 95
- 150
demo-cache/demo-cache-redis/README.md View File

@@ -1,94 +1,56 @@
# spring-boot-demo-cache-redis
## spring-boot-demo-cache-redis


> 此 demo 主要演示了 Spring Boot 如何整合 redis，操作redis中的数据，并使用redis缓存数据。连接池使用 Lettuce。 > 此 demo 主要演示了 Spring Boot 如何整合 redis，操作redis中的数据，并使用redis缓存数据。连接池使用 Lettuce。


## pom.xml
### 1.开发步骤


```xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
#### 1.1.添加依赖


<artifactId>spring-boot-demo-cache-redis</artifactId>
```xml
<dependencies>
<dependency>
<groupId>com.xkcoding</groupId>
<artifactId>common-tools</artifactId>
</dependency>

<dependency>
<groupId>com.xkcoding</groupId>
<artifactId>demo-cache-api</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
<packaging>jar</packaging>

<name>spring-boot-demo-cache-redis</name>
<description>Demo project for Spring Boot</description>

<parent>
<groupId>com.xkcoding</groupId>
<artifactId>spring-boot-demo</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<!-- 对象池，使用redis时必须引入 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>

<!-- 引入 jackson 对象json转换 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-json</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
</dependency>

<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
</dependency>

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>

<build>
<finalName>spring-boot-demo-cache-redis</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

<!-- 对象池，如果存在该依赖会自动注入 -->
<!-- https://docs.spring.io/spring-boot/docs/3.0.0-M4/reference/htmlsingle/#data.nosql.redis.connecting -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>
``` ```


## application.yml
#### 1.2.配置文件


```yaml ```yaml
spring: spring:
@@ -116,21 +78,13 @@ logging:
com.xkcoding: debug com.xkcoding: debug
``` ```


## RedisConfig.java
#### 1.3.自动装配Redis缓存管理


```java ```java
/**
* <p>
* redis配置
* </p>
*
* @author yangkai.shen
* @date Created in 2018-11-15 16:41
*/
@EnableCaching
@Configuration @Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class) @AutoConfigureAfter(RedisAutoConfiguration.class)
@EnableCaching
public class RedisConfig {
public class RedisCacheAutoConfiguration {


/** /**
* 默认情况下的模板只能支持RedisTemplate<String, String>，也就是只能存入字符串，因此支持序列化 * 默认情况下的模板只能支持RedisTemplate<String, String>，也就是只能存入字符串，因此支持序列化
@@ -151,40 +105,31 @@ public class RedisConfig {
public CacheManager cacheManager(RedisConnectionFactory factory) { public CacheManager cacheManager(RedisConnectionFactory factory) {
// 配置序列化 // 配置序列化
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig(); RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();
RedisCacheConfiguration redisCacheConfiguration = config.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer())).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
RedisCacheConfiguration redisCacheConfiguration =
config.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));


return RedisCacheManager.builder(factory).cacheDefaults(redisCacheConfiguration).build(); return RedisCacheManager.builder(factory).cacheDefaults(redisCacheConfiguration).build();
} }
} }
``` ```


## UserServiceImpl.java
#### 1.4.缓存通过注解实现

> 为了减少重复代码，该部分我将其抽取实现在 demo-cache-api 模块中


```java ```java
/**
* <p>
* UserService
* </p>
*
* @author yangkai.shen
* @date Created in 2018-11-15 16:45
*/
@Service
@Slf4j @Slf4j
public class UserServiceImpl implements UserService {
@Service
public class UserService {
/** /**
* 模拟数据库 * 模拟数据库
*/ */
private static final Map<Long, User> DATABASES = Maps.newConcurrentMap();

/**
* 初始化数据
*/
static {
DATABASES.put(1L, new User(1L, "user1"));
DATABASES.put(2L, new User(2L, "user2"));
DATABASES.put(3L, new User(3L, "user3"));
}
private static final Map<Long, User> DATABASES = new HashMap<>() {{
put(1L, new User(1L, "user1"));
put(2L, new User(2L, "user2"));
put(3L, new User(3L, "user3"));
}};


/** /**
* 保存或修改用户 * 保存或修改用户
@@ -193,7 +138,6 @@ public class UserServiceImpl implements UserService {
* @return 操作结果 * @return 操作结果
*/ */
@CachePut(value = "user", key = "#user.id") @CachePut(value = "user", key = "#user.id")
@Override
public User saveOrUpdate(User user) { public User saveOrUpdate(User user) {
DATABASES.put(user.getId(), user); DATABASES.put(user.getId(), user);
log.info("保存用户【user】= {}", user); log.info("保存用户【user】= {}", user);
@@ -207,7 +151,6 @@ public class UserServiceImpl implements UserService {
* @return 返回结果 * @return 返回结果
*/ */
@Cacheable(value = "user", key = "#id") @Cacheable(value = "user", key = "#id")
@Override
public User get(Long id) { public User get(Long id) {
// 我们假设从数据库读取 // 我们假设从数据库读取
log.info("查询用户【id】= {}", id); log.info("查询用户【id】= {}", id);
@@ -220,7 +163,6 @@ public class UserServiceImpl implements UserService {
* @param id key值 * @param id key值
*/ */
@CacheEvict(value = "user", key = "#id") @CacheEvict(value = "user", key = "#id")
@Override
public void delete(Long id) { public void delete(Long id) {
DATABASES.remove(id); DATABASES.remove(id);
log.info("删除用户【id】= {}", id); log.info("删除用户【id】= {}", id);
@@ -228,9 +170,20 @@ public class UserServiceImpl implements UserService {
} }
``` ```


## RedisTest.java
### 2.测试

#### 2.1.环境搭建


> 主要测试使用 `RedisTemplate` 操作 `Redis` 中的数据：
主要是 redis 环境的搭建，这里我提供了 docker-compose 文件，方便同学们一键启动测试环境

```bash
$ cd demo-cache/demo-cache-redis
$ docker compose -f docker-compose.env.yml up
```

#### 2.2.测试 Redis 基础功能

> 主要测试使用 `RedisTemplate` 操作 `Redis` 中的数据，查看是否正常序列化：
> >
> - opsForValue：对应 String（字符串） > - opsForValue：对应 String（字符串）
> - opsForZSet：对应 ZSet（有序集合） > - opsForZSet：对应 ZSet（有序集合）
@@ -240,16 +193,9 @@ public class UserServiceImpl implements UserService {
> - opsForGeo：** 对应 GEO（地理位置） > - opsForGeo：** 对应 GEO（地理位置）


```java ```java
/**
* <p>
* Redis测试
* </p>
*
* @author yangkai.shen
* @date Created in 2018-11-15 17:17
*/
@Slf4j @Slf4j
public class RedisTest extends SpringBootDemoCacheRedisApplicationTests {
@SpringBootTest
public class RedisTest {


@Autowired @Autowired
private StringRedisTemplate stringRedisTemplate; private StringRedisTemplate stringRedisTemplate;
@@ -261,13 +207,19 @@ public class RedisTest extends SpringBootDemoCacheRedisApplicationTests {
* 测试 Redis 操作 * 测试 Redis 操作
*/ */
@Test @Test
public void get() {
public void get() throws InterruptedException {
// 测试线程安全，程序结束查看redis中count的值是否为1000 // 测试线程安全，程序结束查看redis中count的值是否为1000
ExecutorService executorService = Executors.newFixedThreadPool(1000); ExecutorService executorService = Executors.newFixedThreadPool(1000);
IntStream.range(0, 1000).forEach(i -> executorService.execute(() -> stringRedisTemplate.opsForValue().increment("count", 1)));
CountDownLatch wait = new CountDownLatch(1000);
IntStream.range(0, 1000).forEach(i -> executorService.execute(() -> {
stringRedisTemplate.opsForValue().increment("count", 1);
wait.countDown();
}));
wait.await();
log.debug("【count】= {}", stringRedisTemplate.opsForValue().getAndExpire("count", Duration.ofSeconds(10)));


stringRedisTemplate.opsForValue().set("k1", "v1"); stringRedisTemplate.opsForValue().set("k1", "v1");
String k1 = stringRedisTemplate.opsForValue().get("k1");
String k1 = stringRedisTemplate.opsForValue().getAndExpire("k1", Duration.ofSeconds(10));
log.debug("【k1】= {}", k1); log.debug("【k1】= {}", k1);


// 以下演示整合，具体Redis命令可以参考官方文档 // 以下演示整合，具体Redis命令可以参考官方文档
@@ -275,27 +227,19 @@ public class RedisTest extends SpringBootDemoCacheRedisApplicationTests {
redisCacheTemplate.opsForValue().set(key, new User(1L, "user1")); redisCacheTemplate.opsForValue().set(key, new User(1L, "user1"));
// 对应 String（字符串） // 对应 String（字符串）
User user = (User) redisCacheTemplate.opsForValue().get(key); User user = (User) redisCacheTemplate.opsForValue().get(key);
String userSerialized = stringRedisTemplate.opsForValue().getAndExpire(key, Duration.ofSeconds(10));
log.debug("【user】= {}", user); log.debug("【user】= {}", user);
log.debug("【userSerialized】= {}", userSerialized);
} }
} }

``` ```


## UserServiceTest.java

> 主要测试使用Redis缓存是否起效
#### 2.3.测试Redis缓存是否生效


```java ```java
/**
* <p>
* Redis - 缓存测试
* </p>
*
* @author yangkai.shen
* @date Created in 2018-11-15 16:53
*/
@Slf4j @Slf4j
public class UserServiceTest extends SpringBootDemoCacheRedisApplicationTests {
@SpringBootTest
public class UserServiceTest {
@Autowired @Autowired
private UserService userService; private UserService userService;


@@ -340,8 +284,9 @@ public class UserServiceTest extends SpringBootDemoCacheRedisApplicationTests {
} }
``` ```


## 参考
### 3.参考


- spring-data-redis 官方文档：https://docs.spring.io/spring-data/redis/docs/2.0.1.RELEASE/reference/html/
- redis 文档：https://redis.io/documentation
- redis 中文文档：http://www.redis.cn/commands.html
- [Spring Boot 官方文档之连接 Redis](https://docs.spring.io/spring-boot/docs/3.0.0-M4/reference/htmlsingle/#data.nosql.redis)
- [Spring Boot 官方文档之 Redis 缓存](https://docs.spring.io/spring-boot/docs/3.0.0-M4/reference/htmlsingle/#io.caching.provider.redis)
- [spring-data-redis 官方文档](https://docs.spring.io/spring-data/redis/docs/3.0.0-M5/reference/html/)
- [Redis 官方文档](https://redis.io/docs/)

+ 7
- 0
demo-cache/demo-cache-redis/docker-compose.env.yml View File

@@ -0,0 +1,7 @@
version: "3.8"

services:
redis:
image: redis:7.0.4-alpine
ports:
- "6379:6379"

+ 57
- 63
demo-cache/demo-cache-redis/pom.xml View File

@@ -1,81 +1,75 @@
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<artifactId>demo-cache-redis</artifactId>
<parent>
<groupId>com.xkcoding</groupId>
<artifactId>demo-cache</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
<packaging>jar</packaging>
</parent>


<name>demo-cache-redis</name>
<description>Demo project for Spring Boot</description>
<modelVersion>4.0.0</modelVersion>


<parent>
<groupId>com.xkcoding</groupId>
<artifactId>spring-boot-demo</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<artifactId>demo-cache-redis</artifactId>
<version>1.0.0-SNAPSHOT</version>
<packaging>jar</packaging>


<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
</properties>
<name>demo-cache-redis</name>
<description>Demo project for Spring Boot</description>


<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<properties>
<java.version>17</java.version>
</properties>


<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<dependencies>
<dependency>
<groupId>com.xkcoding</groupId>
<artifactId>common-tools</artifactId>
</dependency>


<!-- 对象池，使用redis时必须引入 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
<dependency>
<groupId>com.xkcoding</groupId>
<artifactId>demo-cache-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>


<!-- 引入 jackson 对象json转换 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-json</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>


<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>


<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
</dependency>
<!-- 对象池，如果存在该依赖会自动注入 -->
<!-- https://docs.spring.io/spring-boot/docs/3.0.0-M4/reference/htmlsingle/#data.nosql.redis.connecting -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>


<dependency>
<groupId>cn.hutool</groupId>
<artifactId>hutool-all</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>


<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
</dependencies>


<build>
<finalName>demo-cache-redis</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<build>
<finalName>demo-cache-redis</finalName>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>


</project> </project>

demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/SpringBootDemoCacheRedisApplication.java → demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/RedisCacheApplication.java View File

@@ -3,10 +3,18 @@ package com.xkcoding.cache.redis;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;


/**
* <p>
* 启动器
* </p>
*
* @author yangkai.shen
* @date Created in 2022-09-06 23:09
*/
@SpringBootApplication @SpringBootApplication
public class SpringBootDemoCacheRedisApplication {
public class RedisCacheApplication {


public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(SpringBootDemoCacheRedisApplication.class, args);
SpringApplication.run(RedisCacheApplication.class, args);
} }
} }

demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/config/RedisConfig.java → demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/configuration/RedisCacheAutoConfiguration.java View File

@@ -1,4 +1,4 @@
package com.xkcoding.cache.redis.config;
package com.xkcoding.cache.redis.configuration;


import org.springframework.boot.autoconfigure.AutoConfigureAfter; import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration; import org.springframework.boot.autoconfigure.data.redis.RedisAutoConfiguration;
@@ -19,16 +19,16 @@ import java.io.Serializable;


/** /**
* <p> * <p>
* redis配置
* redis 缓存自动装配，同时设置 redis 序列化
* </p> * </p>
* *
* @author yangkai.shen * @author yangkai.shen
* @date Created in 2018-11-15 16:41
* @date Created in 2022-09-07 14:03
*/ */
@EnableCaching
@Configuration @Configuration
@AutoConfigureAfter(RedisAutoConfiguration.class) @AutoConfigureAfter(RedisAutoConfiguration.class)
@EnableCaching
public class RedisConfig {
public class RedisCacheAutoConfiguration {


/** /**
* 默认情况下的模板只能支持RedisTemplate<String, String>，也就是只能存入字符串，因此支持序列化 * 默认情况下的模板只能支持RedisTemplate<String, String>，也就是只能存入字符串，因此支持序列化
@@ -49,7 +49,9 @@ public class RedisConfig {
public CacheManager cacheManager(RedisConnectionFactory factory) { public CacheManager cacheManager(RedisConnectionFactory factory) {
// 配置序列化 // 配置序列化
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig(); RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig();
RedisCacheConfiguration redisCacheConfiguration = config.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer())).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));
RedisCacheConfiguration redisCacheConfiguration =
config.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer()))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));


return RedisCacheManager.builder(factory).cacheDefaults(redisCacheConfiguration).build(); return RedisCacheManager.builder(factory).cacheDefaults(redisCacheConfiguration).build();
} }

+ 0
- 36
demo-cache/demo-cache-redis/src/main/java/com/xkcoding/cache/redis/service/UserService.java View File

@@ -1,36 +0,0 @@
package com.xkcoding.cache.redis.service;

import com.xkcoding.cache.redis.entity.User;

/**
* <p>
* UserService
* </p>
*
* @author yangkai.shen
* @date Created in 2018-11-15 16:45
*/
public interface UserService {
/**
* 保存或修改用户
*
* @param user 用户对象
* @return 操作结果
*/
User saveOrUpdate(User user);

/**
* 获取用户
*
* @param id key值
* @return 返回结果
*/
User get(Long id);

/**
* 删除
*
* @param id key值
*/
void delete(Long id);
}

+ 13
- 0
demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/RedisCacheApplicationTests.java View File

@@ -0,0 +1,13 @@
package com.xkcoding.cache.redis;

import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class RedisCacheApplicationTests {

@Test
void contextLoads() {
}

}

+ 20
- 8
demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/RedisTest.java View File

@@ -1,27 +1,31 @@
package com.xkcoding.cache.redis; package com.xkcoding.cache.redis;


import com.xkcoding.cache.redis.entity.User;
import com.xkcoding.cache.entity.User;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;


import java.io.Serializable; import java.io.Serializable;
import java.time.Duration;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.stream.IntStream; import java.util.stream.IntStream;


/** /**
* <p> * <p>
* Redis测试
* redis 基础用法
* </p> * </p>
* *
* @author yangkai.shen * @author yangkai.shen
* @date Created in 2018-11-15 17:17
* @date Created in 2022-09-07 13:48
*/ */
@Slf4j @Slf4j
public class RedisTest extends SpringBootDemoCacheRedisApplicationTests {
@SpringBootTest
public class RedisTest {


@Autowired @Autowired
private StringRedisTemplate stringRedisTemplate; private StringRedisTemplate stringRedisTemplate;
@@ -33,13 +37,19 @@ public class RedisTest extends SpringBootDemoCacheRedisApplicationTests {
* 测试 Redis 操作 * 测试 Redis 操作
*/ */
@Test @Test
public void get() {
public void get() throws InterruptedException {
// 测试线程安全，程序结束查看redis中count的值是否为1000 // 测试线程安全，程序结束查看redis中count的值是否为1000
ExecutorService executorService = Executors.newFixedThreadPool(1000); ExecutorService executorService = Executors.newFixedThreadPool(1000);
IntStream.range(0, 1000).forEach(i -> executorService.execute(() -> stringRedisTemplate.opsForValue().increment("count", 1)));
CountDownLatch wait = new CountDownLatch(1000);
IntStream.range(0, 1000).forEach(i -> executorService.execute(() -> {
stringRedisTemplate.opsForValue().increment("count", 1);
wait.countDown();
}));
wait.await();
log.debug("【count】= {}", stringRedisTemplate.opsForValue().getAndExpire("count", Duration.ofSeconds(10)));


stringRedisTemplate.opsForValue().set("k1", "v1"); stringRedisTemplate.opsForValue().set("k1", "v1");
String k1 = stringRedisTemplate.opsForValue().get("k1");
String k1 = stringRedisTemplate.opsForValue().getAndExpire("k1", Duration.ofSeconds(10));
log.debug("【k1】= {}", k1); log.debug("【k1】= {}", k1);


// 以下演示整合，具体Redis命令可以参考官方文档 // 以下演示整合，具体Redis命令可以参考官方文档
@@ -47,6 +57,8 @@ public class RedisTest extends SpringBootDemoCacheRedisApplicationTests {
redisCacheTemplate.opsForValue().set(key, new User(1L, "user1")); redisCacheTemplate.opsForValue().set(key, new User(1L, "user1"));
// 对应 String（字符串） // 对应 String（字符串）
User user = (User) redisCacheTemplate.opsForValue().get(key); User user = (User) redisCacheTemplate.opsForValue().get(key);
String userSerialized = stringRedisTemplate.opsForValue().getAndExpire(key, Duration.ofSeconds(10));
log.debug("【user】= {}", user); log.debug("【user】= {}", user);
log.debug("【userSerialized】= {}", userSerialized);
} }
} }

+ 0
- 16
demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/SpringBootDemoCacheRedisApplicationTests.java View File

@@ -1,16 +0,0 @@
package com.xkcoding.cache.redis;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringBootDemoCacheRedisApplicationTests {

@Test
public void contextLoads() {
}

}

+ 7
- 5
demo-cache/demo-cache-redis/src/test/java/com/xkcoding/cache/redis/service/UserServiceTest.java View File

@@ -1,10 +1,11 @@
package com.xkcoding.cache.redis.service; package com.xkcoding.cache.redis.service;


import com.xkcoding.cache.redis.SpringBootDemoCacheRedisApplicationTests;
import com.xkcoding.cache.redis.entity.User;
import com.xkcoding.cache.api.UserService;
import com.xkcoding.cache.entity.User;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;


/** /**
* <p> * <p>
@@ -12,10 +13,11 @@ import org.springframework.beans.factory.annotation.Autowired;
* </p> * </p>
* *
* @author yangkai.shen * @author yangkai.shen
* @date Created in 2018-11-15 16:53
* @date Created in 2022-09-07 14:37
*/ */
@Slf4j @Slf4j
public class UserServiceTest extends SpringBootDemoCacheRedisApplicationTests {
@SpringBootTest
public class UserServiceTest {
@Autowired @Autowired
private UserService userService; private UserService userService;




+ 5
- 0
demo-cache/pom.xml View File

@@ -18,4 +18,9 @@
<java.version>17</java.version> <java.version>17</java.version>
</properties> </properties>


<modules>
<module>demo-cache-api</module>
<module>demo-cache-redis</module>
</modules>

</project> </project>

Write Preview
Loading…
Cancel
Save