Redis的高效性和操作便捷性使其非常适合用于实时的计数器场景，所以我们可以通过RedisINCR命令来实现每日页面浏览量（PV）的统计。每当有用户访问页面时，可以将统计日期作为Redis键的一部分并且将对应的页面的浏览量+1，这样就可以实现每日的浏览量的统计。当然为了防止Redis中数据的持续累积，可以设置过期时间或定期清理过期数据。

下面我们就来介绍一下使用Spring Boot和Redis实现每日页面浏览量的统计。

准备工作

首先，需要在pom.xml中引入Spring Data Redis的依赖，如下所示。

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

在application.yml配置文件中，配置Redis的连接信息，如下所示。

spring:
  redis:
    host: localhost
    port: 6379

配置RedisTemplate

在Spring Boot中已经为我们提供了自动配置的RedisTemplate，不过我们也可以根据业务需求自定义模板，如下所示。

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.StringRedisSerializer;

@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(connectionFactory);

        // 使用String的序列化器来序列化键
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new StringRedisSerializer());

        return redisTemplate;
    }
}

编写PV统计服务

在这里，定义一个服务类来实现页面浏览量统计，通过RedisTemplate来方便的操作Redis，如下所示。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.time.LocalDate;
import java.time.format.DateTimeFormatter;

@Service
public class PageViewService {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    // 日期格式化
    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMdd");

    /**
     * 记录页面访问量
     *
     * @param pageId 页面ID
     */
    public void recordPageView(String pageId) {
        // 获取当天日期，格式为yyyyMMdd
        String currentDate = LocalDate.now().format(DATE_FORMATTER);

        // Redis中的键格式：pv:yyyyMMdd:{pageId}
        String redisKey = String.format("pv:%s:%s", currentDate, pageId);

        // 自增1
        redisTemplate.opsForValue().increment(redisKey, 1);
    }

    /**
     * 获取指定页面在某日的访问量
     *
     * @param pageId 页面ID
     * @param date 日期，格式为yyyyMMdd
     * @return 浏览量
     */
    public Long getPageView(String pageId, String date) {
        String redisKey = String.format("pv:%s:%s", date, pageId);
        String value = (String) redisTemplate.opsForValue().get(redisKey);
        return value != null ? Long.valueOf(value) : 0L;
    }
}

编写一个简单的Controller来测试PV统计功能

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class PageViewController {

    @Autowired
    private PageViewService pageViewService;

    /**
     * 记录页面访问
     */
    @GetMapping("/visit")
    public String visit(@RequestParam String pageId) {
        pageViewService.recordPageView(pageId);
        return "Page visit recorded";
    }

    /**
     * 获取页面在某日的访问量
     */
    @GetMapping("/pageview")
    public String getPageView(@RequestParam String pageId, @RequestParam String date) {
        Long pageViews = pageViewService.getPageView(pageId, date);
        return String.format("Page %s had %d views on %s", pageId, pageViews, date);
    }
}

定时任务清理过期数据

根据需要，可以通过定时任务定期清理Redis中过期的PV数据。例如我们只需要保留最近7天的浏览数据，可以通过Spring的定时任务来实现对过期数据的清理。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDate;
import java.time.format.DateTimeFormatter;
import java.util.Set;

@Component
public class PageViewCleaner {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    private static final DateTimeFormatter DATE_FORMATTER = DateTimeFormatter.ofPattern("yyyyMMdd");

    /**
     * 每天凌晨执行一次，清理过期的PV数据
     */
    @Scheduled(cron = "0 0 0 * * ?")
    public void cleanExpiredData() {
        // 获取7天前的日期
        String expiredDate = LocalDate.now().minusDays(7).format(DATE_FORMATTER);

        // 找到所有以pv:开头的键
        Set<String> keys = redisTemplate.keys("pv:*");

        if (keys != null && !keys.isEmpty()) {
            for (String key : keys) {
                // 解析日期，删除过期的数据
                if (key.contains(expiredDate)) {
                    redisTemplate.delete(key);
                }
            }
        }
    }
}

总结

通过Redis的高效读写和Spring Boot的简便配置，我们能够快速实现对每日页面浏览量的统计功能。使用Redis的自增操作确保了并发情况下的正确性，并且通过键的设计，可以轻松实现按日期的统计。如果需要清理数据，可以通过定时任务来管理Redis中的过期数据。