处理Redis与MySQL数据不一致的Java定期巡检方案

<dependencies>
    <!-- MySQL连接驱动 -->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.23</version>
    </dependency>

    <!-- Jedis：Java连接Redis的客户端库 -->
    <dependency>
        <groupId>redis.clients</groupId>
        <artifactId>jedis</artifactId>
        <version>3.7.0</version>
    </dependency>
</dependencies>

import redis.clients.jedis.Jedis;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Timer;
import java.util.TimerTask;

public class InventoryConsistencyChecker {

    // Redis连接信息
    private static final String REDIS_HOST = "localhost";
    private static final int REDIS_PORT = 6379;
    private static final int REDIS_DB = 0;

    // MySQL连接信息
    private static final String MYSQL_URL = "jdbc:mysql://localhost:3306/ecommerce";
    private static final String MYSQL_USER = "user";
    private static final String MYSQL_PASSWORD = "password";

    public static void main(String[] args) {
        // 创建定时任务
        Timer timer = new Timer();
        timer.schedule(new InventoryCheckerTask(), 0, 30 * 60 * 1000); // 每30分钟执行一次
    }

    static class InventoryCheckerTask extends TimerTask {
        @Override
        public void run() {
            System.out.println("Starting inventory consistency check...");

            try {
                // 连接Redis
                Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT);
                jedis.select(REDIS_DB);

                // 连接MySQL
                Connection mysqlConnection = DriverManager.getConnection(MYSQL_URL, MYSQL_USER, MYSQL_PASSWORD);

                // 查询所有商品ID
                PreparedStatement preparedStatement = mysqlConnection.prepareStatement("SELECT id FROM products");
                ResultSet resultSet = preparedStatement.executeQuery();

                while (resultSet.next()) {
                    int productId = resultSet.getInt("id");

                    // 从Redis获取缓存库存
                    int redisStock = Integer.parseInt(jedis.get("product:" + productId + ":stock"));

                    // 从MySQL获取实际库存
                    PreparedStatement stockStatement = mysqlConnection.prepareStatement("SELECT stock FROM products WHERE id = ?");
                    stockStatement.setInt(1, productId);
                    ResultSet stockResultSet = stockStatement.executeQuery();
                    int mysqlStock = 0;
                    if (stockResultSet.next()) {
                        mysqlStock = stockResultSet.getInt("stock");
                    }

                    // 检测库存一致性
                    if (redisStock != mysqlStock) {
                        System.out.println("Inventory inconsistency detected for product " + productId +
                                ". Redis: " + redisStock + ", MySQL: " + mysqlStock);

                        // 在这里可以记录日志或者触发修复机制
                        // log.error("Inventory inconsistency detected for product " + productId);

                        // 例如，触发修复机制
                        // repairInventory(productId, redisStock, mysqlStock);
                    }
                }

                // 关闭连接
                jedis.close();
                mysqlConnection.close();

            } catch (SQLException e) {
                System.err.println("Error during inventory consistency check: " + e.getMessage());
            }
        }
    }
}

javac InventoryConsistencyChecker.java
java InventoryConsistencyChecker