本篇內(nèi)容主要講解“JAVA怎么用redisUtils工具類來防止高并發(fā)獲取緩存出現(xiàn)并發(fā)問題”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“JAVA怎么用redisUtils工具類來防止高并發(fā)獲取緩存出現(xiàn)并發(fā)問題”吧!

創(chuàng)新互聯(lián)建站專注于寶坻企業(yè)網(wǎng)站建設(shè),響應(yīng)式網(wǎng)站設(shè)計(jì),商城網(wǎng)站制作。寶坻網(wǎng)站建設(shè)公司,為寶坻等地區(qū)提供建站服務(wù)。全流程按需制作，專業(yè)設(shè)計(jì)，全程項(xiàng)目跟蹤，創(chuàng)新互聯(lián)建站專業(yè)和態(tài)度為您提供的服務(wù)

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.BoundHashOperations;
import org.springframework.data.redis.core.BoundValueOperations;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;

import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.function.BiFunction;
import java.util.function.Function;

@Slf4j
public class RedisUtils{

    /**
     * @param redisTemplate redis操作模板工具
     * @param key           緩存主鍵
     * @param timeout       過期時間
     * @param timeUnit      過期時間單位
     * @return
     * @description 方法描述
     * @author kejie.huang
     * @date 2019/10/18 9:20
     */
    public static void expire(RedisTemplate redisTemplate, String key, long timeout, TimeUnit timeUnit) {
        boolean hasKey = redisTemplate.hasKey(key);
        // 如果key存在
        if (hasKey) {
            // 獲取過期時間是永久則設(shè)置
            Long timeOut = redisTemplate.getExpire(key);
            if (timeOut.intValue() == -1) {
                redisTemplate.expire(key, timeout, timeUnit);
            }
        }
    }

    public static Object getValue(RedisTemplate  redisTemplate, String key, Function mappingFunction){
        BoundValueOperations boundValueOperations = redisTemplate.boundValueOps(key);
        Object value = boundValueOperations.get();
        if(value == null){
            synchronized (key.intern()){
                value =  boundValueOperations.get();
                if(value == null){
                    value = mappingFunction.apply(key);
                    if(value != null){
                        boundValueOperations.set(value);
                    }
                }
            }
        }
        return value;
    }

    public static Object getHashValue(RedisTemplate redisTemplate, String key, String hashKey, BiFunction mappingFunction){
        BoundHashOperations boundHashOperations = redisTemplate.boundHashOps(key);
        Object value = boundHashOperations.get(hashKey);
        if(value == null){
            synchronized (key.concat(hashKey).intern()){
                value =  boundHashOperations.get(hashKey);
                if(value == null){
                    value = mappingFunction.apply(key, hashKey);
                    if(value != null){
                        boundHashOperations.put(hashKey, value);
                    }
                }
            }
        }
        return value;
    }

    public static Map getHashValue(RedisTemplate redisTemplate, String key, Function> mappingFunction){
        Map entries = redisTemplate.opsForHash().entries(key);
        if(entries == null){
            synchronized (key.intern()){
                if(!redisTemplate.hasKey(key)){
                    entries = mappingFunction.apply(key);
                    if(entries != null){
                        redisTemplate.opsForHash().putAll(key, entries);
                    }
                }
            }
        }
        return entries;
    }

    public static String getHashValue(StringRedisTemplate redisTemplate, String key, String hashKey, BiFunction mappingFunction){
        BoundHashOperations boundHashOperations = redisTemplate.boundHashOps(key);
        String value = boundHashOperations.get(hashKey);
        if(value == null){
            synchronized (key.concat(hashKey).intern()){
                value =  boundHashOperations.get(hashKey);
                if(value == null){
                    value = mappingFunction.apply(key, hashKey);
                    if(value != null){
                        boundHashOperations.put(hashKey, value);
                    }
                }
            }
        }
        return value;
    }
}

到此，相信大家對“JAVA怎么用redisUtils工具類來防止高并發(fā)獲取緩存出現(xiàn)并發(fā)問題”有了更深的了解，不妨來實(shí)際操作一番吧！這里是創(chuàng)新互聯(lián)網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！