更新缓存失败重试

男娘i 2024-02-18 22:54 72阅读 0赞

用户进行写数据的时候，对于一些数据需要进行对缓存的更新，但是如果缓存更新失败怎么办?

这里是一个异步更新缓存的简易实例

package sunziwen;
    
    import java.util.concurrent.CompletableFuture;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    import java.util.function.Consumer;
    import java.util.function.Supplier;
    
    /**
     * 更新缓存
     *
     * @author sunziwen
     * 2018-08-14 15:34
     * @version 1.0
     **/
    public class Main {
        public static void main(String args[]) {
            ExecutorService executor = Executors.newFixedThreadPool(10);
            System.out.println("执行插入数据库动作");
            updateCache("键", "值");
            System.out.println("执行完毕返回请求");
        }
    
        /**
         * 异步更新缓存
         *
         * @param key
         * @param value
         */
        public static void updateCache(String key, String value) {
            int count = 0;
            ExecutorService executor = Executors.newFixedThreadPool(10);
            CompletableFuture<String> cupdResult = CompletableFuture.supplyAsync(new Supplier<String>() {
                public String get() {
                    System.out.println("更新缓存失败");
                    try {
                        TimeUnit.SECONDS.sleep(2);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    return "false";
                }
            }, executor);
    
            /**
             * 异步任务完成后的回调方法
             */
            cupdResult.thenAccept(new Consumer<String>() {
                @Override
                public void accept(String s) {
                    if (s.equalsIgnoreCase("false")) {
                        System.out.println("再次尝试更新");
                        updateCache(key, value);
                    }
                }
            });
        }
    }

重试更新次数到达一定次数后(16)，如果还是更新失败，就要放弃重试，进行缓存Key值清除，让访问者直接命中数据库后再次进行缓存操作。