举例实现springboot 项目 功能点:统计功能 需求:统计本周第一天 本月第一天 本年第一天起到今天为止的中奖趋势接口 并对接口进行redis缓存处理 过期时间10分钟
时间: 2023-12-16 16:03:26 浏览: 98
好的,我来为您解答。与上一个问题相比,这里我们将使用 Redis 作为缓存,实现统计本周第一天、本月第一天、本年第一天起到今天为止的中奖趋势接口,并对接口进行 Redis 缓存处理,过期时间为 10 分钟。
首先,我们需要在 pom.xml 文件中添加 Redis 相关的依赖和配置,可以参考以下代码:
```xml
<!-- Redis 相关依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- Redis 配置 -->
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.database=0
spring.redis.password=
spring.redis.timeout=10000
spring.redis.pool.max-active=8
spring.redis.pool.max-wait=-1
spring.redis.pool.max-idle=8
spring.redis.pool.min-idle=0
```
其中,`spring.redis.host`、`spring.redis.port`、`spring.redis.database`、`spring.redis.password` 等属性用于配置 Redis 的连接信息和密码,`spring.redis.timeout` 属性用于配置 Redis 的连接超时时间,`spring.redis.pool.max-active`、`spring.redis.pool.max-wait`、`spring.redis.pool.max-idle`、`spring.redis.pool.min-idle` 等属性用于配置 Redis 的连接池。
接着,我们需要在启动类上添加 `@EnableCaching` 注解启用缓存功能,可以参考以下代码:
```java
@SpringBootApplication
@EnableCaching
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
```
然后,我们需要在 `application.yml` 文件中配置 Redis 缓存管理器,可以参考以下代码:
```yaml
cache:
manager: redis # 指定缓存管理器为 Redis
redis:
cache-prefix: my-cache # 指定缓存前缀
key-prefix: my-key # 指定缓存键前缀
default-expiration: 600 # 指定默认过期时间为 10 分钟
```
接着,我们需要定义一个接口,可以参考以下代码:
```java
@RestController
public class TrendController {
@Autowired
private TrendService trendService;
@GetMapping("/trend")
@Cacheable(value = "trend", keyGenerator = "cacheKeyGenerator", cacheManager = "cacheManager", unless = "#result == null")
public List<Trend> getTrend() {
return trendService.getTrend();
}
}
```
其中,`@GetMapping` 注解指定了接口的访问路径为 `/trend`,`@Cacheable` 注解指定了接口的缓存处理,`Trend` 是一个自定义的数据实体类。
接着,我们需要实现 `TrendService` 接口,可以参考以下代码:
```java
@Service
public class TrendServiceImpl implements TrendService {
private final TrendRepository trendRepository;
@Autowired
public TrendServiceImpl(TrendRepository trendRepository) {
this.trendRepository = trendRepository;
}
@Override
public List<Trend> getTrend() {
LocalDate now = LocalDate.now();
LocalDate firstDayOfWeek = now.with(DayOfWeek.MONDAY);
LocalDate firstDayOfMonth = now.with(TemporalAdjusters.firstDayOfMonth());
LocalDate firstDayOfYear = now.with(TemporalAdjusters.firstDayOfYear());
return trendRepository.findByCreateTimeBetween(firstDayOfYear, now);
}
}
```
其中,`TrendRepository` 是一个自定义的数据访问接口,`LocalDate` 是 Java 8 提供的日期时间类,`getTrend()` 方法用于获取中奖趋势数据。
最后,我们需要实现 `TrendRepository` 接口,并配置 Redis 缓存,可以参考以下代码:
```java
@Repository
public interface TrendRepository extends JpaRepository<Trend, Long> {
@Cacheable(value = "trend", key = "'week:' + #p0.toString()", unless = "#result == null")
List<Trend> findByCreateTimeBetween(LocalDate start, LocalDate end);
@Cacheable(value = "trend", key = "'month:' + #p0.toString()", unless = "#result == null")
List<Trend> findByCreateTimeBetween(LocalDate start, LocalDate end);
@Cacheable(value = "trend", key = "'year:' + #p0.toString()", unless = "#result == null")
List<Trend> findByCreateTimeBetween(LocalDate start, LocalDate end);
}
```
其中,`@Cacheable` 注解用于配置 Redis 缓存,`value` 属性指定了缓存的名称为 `trend`,`key` 属性指定了缓存的键值,可以使用 SpEL 表达式指定一个或多个缓存键值,用逗号分隔;`unless` 属性指定了当方法返回值为 null 时,不缓存结果。这里我们为每个查询方法都添加了缓存配置,分别对应了本周、本月、本年的中奖趋势数据。
至此,一个统计本周第一天、本月第一天、本年第一天起到今天为止的中奖趋势接口就实现了,并且已经添加了 Redis 缓存处理,过期时间为 10 分钟。
阅读全文