当前位置：首页 > Java

qps如何计算java

2026-03-18 00:49:33Java

QPS（Queries Per Second）计算方法

QPS是衡量系统吞吐量的重要指标，表示每秒处理的请求数。在Java中计算QPS通常有以下几种方法：

基于时间窗口的计数器

使用原子计数器记录请求数，配合定时器计算固定时间间隔内的QPS：

qps如何计算java

AtomicLong counter = new AtomicLong(0);
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

// 每秒钟输出一次QPS
scheduler.scheduleAtFixedRate(() -> {
    long currentCount = counter.getAndSet(0);
    System.out.println("Current QPS: " + currentCount);
}, 1, 1, TimeUnit.SECONDS);

// 在请求处理逻辑中递增计数器
void handleRequest() {
    counter.incrementAndGet();
    // 处理请求逻辑...
}

滑动窗口算法

更精确的计算方式，可以避免时间窗口边界导致的统计误差：

qps如何计算java

class SlidingWindow {
    private final long[] timestamps;
    private final AtomicInteger index = new AtomicInteger(0);

    public SlidingWindow(int windowSize) {
        this.timestamps = new long[windowSize];
    }

    public void recordRequest() {
        timestamps[index.getAndIncrement() % timestamps.length] = System.currentTimeMillis();
    }

    public double calculateQPS() {
        long now = System.currentTimeMillis();
        long oldest = now - 1000; // 1秒时间窗口
        int count = 0;

        for (long ts : timestamps) {
            if (ts > oldest) {
                count++;
            }
        }
        return count;
    }
}

使用性能监控工具

对于生产环境，推荐使用专业监控工具：

Prometheus + Grafana：通过Counter指标自动计算QPS

Micrometer：提供现成的QPS计量器


MeterRegistry registry = new SimpleMeterRegistry();
Counter requests = Counter.builder("api.requests")
  .register(registry);

// 每次请求时调用 requests.increment();


#### JMH基准测试
在开发阶段进行压力测试时，可以使用JMH工具精确测量QPS：
```java
@BenchmarkMode(Mode.Throughput)
@OutputTimeUnit(TimeUnit.SECONDS)
public class QpsBenchmark {
    @Benchmark
    public void testRequest(Blackhole bh) {
        // 模拟请求处理逻辑
        bh.consume(doRequest());
    }
}