// 典型問題代碼示例
public void updateProduct(Product product) {
    // 操作1：更新數(shù)據(jù)庫
    db.update(product); 
    // 操作2：刪除緩存
    redis.del(product.getId());
}

public void updateWithDelayDelete(Product product) {
    // 第一階段刪除
    redis.delete(product.getId()); 
    
    // 數(shù)據(jù)庫更新
    db.update(product);
    
    // 異步延時(shí)刪除
    scheduledExecutor.schedule(() -> {
        redis.delete(product.getId());
    }, 500, TimeUnit.MILLISECONDS);
}

 // 讀操作：使用讀鎖保證一致性
    public Integer getProductStock(Long productId) {
        String cacheKey = "product:stock:" + productId;
        RReadWriteLock lock = redissonClient.getReadWriteLock("product_lock:" + productId);
        
        try {
            // 1. 獲取讀鎖（共享鎖）
            lock.readLock().lock();
            
            // 2. 先查緩存
            Integer stock = (Integer) redisTemplate.opsForValue().get(cacheKey);
            if (stock != null) {
                return stock;
            }
            
            // 3. 緩存未命中，查數(shù)據(jù)庫
            try {
                stock = jdbcTemplate.queryForObject(
                    "SELECT stock FROM product WHERE id = ?", 
                    Integer.class, 
                    productId
                );
            } catch (EmptyResultDataAccessException e) {
                return 0; // 處理數(shù)據(jù)不存在的情況
            }
            
            // 4. 寫入緩存（設(shè)置過期時(shí)間防雪崩）
            redisTemplate.opsForValue().set(cacheKey, stock, 30, TimeUnit.MINUTES);
            return stock;
            
        } finally {
            // 5. 釋放讀鎖
            lock.readLock().unlock();
        }
    }

    // 寫操作：使用寫鎖保證強(qiáng)一致性
    public void updateProductStock(Long productId, int newStock) {
        String cacheKey = "product:stock:" + productId;
        RReadWriteLock lock = redissonClient.getReadWriteLock("product_lock:" + productId);
        
        try {
            // 1. 獲取寫鎖（排他鎖）
            lock.writeLock().lock();
            
            // 2. 更新數(shù)據(jù)庫
            jdbcTemplate.update(
                "UPDATE product SET stock = ? WHERE id = ?", 
                newStock, 
                productId
            );
            
            // 3. 刪除緩存（直接刪除，下次讀時(shí)重建）
            redisTemplate.delete(cacheKey);
            
        } finally {
            // 4. 釋放寫鎖
            lock.writeLock().unlock();
        }
    }

// RocketMQ生產(chǎn)者
public void sendCacheUpdateMessage(String key) {
    Message message = new Message("CACHE_TOPIC", key.getBytes());
    rocketMQTemplate.send(message);
}

// RocketMQ消費(fèi)者
@RocketMQMessageListener(topic = "CACHE_TOPIC")
public void processMessage(String key) {
    redis.delete(key);
    // 可選：重新加載最新數(shù)據(jù)
    Product product = db.get(key);
    redis.set(key, product);
}

# Canal服務(wù)端配置示例
canal:
  instance:
    master:
      address: 127.0.0.1:3306
    dbUsername: canal
    dbPassword: canal
    filter: .*\\..*