当前位置：首页 > Java

java如何统计pv

2026-03-25 03:02:00Java

统计PV（页面浏览量）的方法

在Java中统计PV可以通过多种方式实现，具体取决于应用场景（如Web应用、日志分析等）。以下是几种常见的方法：

使用Servlet过滤器统计Web应用PV

在Java Web应用中，可以通过Filter拦截请求并记录PV：

import javax.servlet.*;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicLong;

@WebFilter("/*")
public class PageViewFilter implements Filter {
    private AtomicLong pageViewCounter = new AtomicLong(0);

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) 
            throws IOException, ServletException {
        if (request instanceof HttpServletRequest) {
            pageViewCounter.incrementAndGet();
        }
        chain.doFilter(request, response);
    }

    @Override
    public void init(FilterConfig filterConfig) {
        // 初始化逻辑（可选）
    }

    @Override
    public void destroy() {
        // 销毁逻辑（可选）
    }
}

使用Spring Boot AOP统计PV

如果使用Spring Boot，可以通过AOP（面向切面编程）实现：

import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.springframework.stereotype.Component;
import java.util.concurrent.atomic.AtomicLong;

@Aspect
@Component
public class PageViewAspect {
    private AtomicLong pageViewCounter = new AtomicLong(0);

    @Before("execution(* com.example.controller.*.*(..))")
    public void countPageView() {
        pageViewCounter.incrementAndGet();
    }
}

使用数据库记录PV

对于需要持久化的场景，可以将PV数据存储到数据库（如MySQL）：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class PageViewDao {
    private static final String DB_URL = "jdbc:mysql://localhost:3306/your_db";
    private static final String DB_USER = "username";
    private static final String DB_PASSWORD = "password";

    public void incrementPageView(String pageUrl) {
        String sql = "INSERT INTO page_views (page_url, view_count) VALUES (?, 1) " +
                     "ON DUPLICATE KEY UPDATE view_count = view_count + 1";
        try (Connection conn = DriverManager.getConnection(DB_URL, DB_USER, DB_PASSWORD);
             PreparedStatement stmt = conn.prepareStatement(sql)) {
            stmt.setString(1, pageUrl);
            stmt.executeUpdate();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

使用Redis实现高性能PV统计

对于高并发场景，Redis的原子操作更适合实时统计：

java如何统计pv

import redis.clients.jedis.Jedis;

public class RedisPageViewCounter {
    private Jedis jedis;

    public RedisPageViewCounter() {
        this.jedis = new Jedis("localhost");
    }

    public void incrementPageView(String pageKey) {
        jedis.incr(pageKey);
    }

    public long getPageViewCount(String pageKey) {
        return Long.parseLong(jedis.get(pageKey));
    }
}