java 统计qps

在Java中，统计QPS（每秒查询率）可以通过以下步骤实现：

1. 创建一个计数器，并初始化为0，用于记录每秒的查询次数。
2. 使用Java的多线程机制，创建一个定时任务，每秒钟执行一次。可以使用ScheduledExecutorService或者Timer类来实现。
3. 在定时任务中，获取当前时间戳，并将计数器的值保存起来，表示上一秒的查询次数。
4. 将计数器重置为0，准备开始记录下一秒的查询次数。
5. 将上一步获取到的查询次数除以1秒的时间差（以毫秒为单位），得到每秒的查询次数。
6. 将计算得到的QPS值进行输出或者保存，用于后续的分析和监控。

下面是示例代码：

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

public class QPSStatistic {
    private static int counter = 0;

    public static void main(String[] args) {
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
        executorService.scheduleAtFixedRate(() -> {
            long currentTime = System.currentTimeMillis();
            int qps = counter;
            System.out.println("QPS: " + qps);
            counter = 0;
        }, 0, 1, TimeUnit.SECONDS);

        // 模拟查询操作
        for (int i = 0; i < 1000; i++) {
            new Thread(() -> {
                // ... 执行查询操作
                // 每次查询完成后，将计数器加1
                counter++;
            }).start();
        }
    }
}

上述代码中，通过创建一个ScheduledExecutorService来定时执行QPS统计任务。在每一秒钟的任务中，获取当前时间戳，并保存计数器的值作为上一秒的查询次数。然后将计数器清零，准备记录下一秒的查询次数。通过将上一秒的查询次数除以1秒的时间差，即可得到每秒的查询次数。最后，将得到的QPS值输出或保存起来，以供后续分析和监控。