Cara menggunakan skrip Redis+Lua untuk melaksanakan fungsi anti-leret antara muka kaunter

[Proses pelaksanaan]

1. Analisis masalah

Jika arahan yang ditetapkan ditetapkan, tetapi apabila menetapkan masa tamat tempoh kerana kegelisahan rangkaian Jika tetapan tidak berjaya kerana sebab lain, pembilang mati (serupa dengan kebuntuan) akan muncul; untuk membuat Perintah yang ditetapkan dan perintah tamat tempoh berfungsi bersama untuk memastikan bahawa Redis dilaksanakan tanpa gangguan, yang menjamin operasi atom pada tahap yang besar

Mengapa dikatakan bahawa operasi atom dijamin pada tahap yang besar tetapi tidak; sepenuhnya? Kerana masalah mungkin berlaku apabila Redis dilaksanakan secara dalaman, tetapi kebarangkalian adalah sangat kecil, walaupun untuk peristiwa kebarangkalian kecil, terdapat penyelesaian yang sepadan, seperti menyelesaikan kebuntuan idea yang patut dirujuk: Mencegah kebuntuan akan menyimpan nilai kunci sebagai masa Cap, walaupun masa tamat tempoh tidak ditetapkan, apabila menilai sama ada untuk mengunci, anda boleh menambahnya untuk melihat sama ada nilai melebihi masa yang ditetapkan dari sekarang Jika melebihi masa, padamkannya dan tetapkan semula kunci.

3. Transformasi kod

1. Pelaksanaan kunci Redis+Lua

package han.zhang.utils;
 
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DigestUtils;
import org.springframework.data.redis.core.script.RedisScript;
import java.util.Collections;
import java.util.UUID;
public class RedisLock {
    private static final LogUtils logger = LogUtils.getLogger(RedisLock.class);
    private final StringRedisTemplate stringRedisTemplate;
    private final String lockKey;
    private final String lockValue;
    private boolean locked = false;
    /**
     * 使用脚本在redis服务器执行这个逻辑可以在一定程度上保证此操作的原子性
     * （即不会发生客户端在执行setNX和expire命令之间，发生崩溃或失去与服务器的连接导致expire没有得到执行，发生永久死锁）
     * <p>
     * 除非脚本在redis服务器执行时redis服务器发生崩溃，不过此种情况锁也会失效
     */
    private static final RedisScript<Boolean> SETNX_AND_EXPIRE_SCRIPT;
    static {
        StringBuilder sb = new StringBuilder();
        sb.append("if (redis.call(&#39;setnx&#39;, KEYS[1], ARGV[1]) == 1) then\n");
        sb.append("\tredis.call(&#39;expire&#39;, KEYS[1], tonumber(ARGV[2]))\n");
        sb.append("\treturn true\n");
        sb.append("else\n");
        sb.append("\treturn false\n");
        sb.append("end");
        SETNX_AND_EXPIRE_SCRIPT = new RedisScriptImpl<>(sb.toString(), Boolean.class);
    }
    private static final RedisScript<Boolean> DEL_IF_GET_EQUALS;
        sb.append("if (redis.call(&#39;get&#39;, KEYS[1]) == ARGV[1]) then\n");
        sb.append("\tredis.call(&#39;del&#39;, KEYS[1])\n");
        DEL_IF_GET_EQUALS = new RedisScriptImpl<>(sb.toString(), Boolean.class);
    public RedisLock(StringRedisTemplate stringRedisTemplate, String lockKey) {
        this.stringRedisTemplate = stringRedisTemplate;
        this.lockKey = lockKey;
        this.lockValue = UUID.randomUUID().toString() + "." + System.currentTimeMillis();
    private boolean doTryLock(int lockSeconds) {
        if (locked) {
            throw new IllegalStateException("already locked!");
        }
        locked = stringRedisTemplate.execute(SETNX_AND_EXPIRE_SCRIPT, Collections.singletonList(lockKey), lockValue,
                String.valueOf(lockSeconds));
        return locked;
     * 尝试获得锁，成功返回true，如果失败立即返回false
     *
     * @param lockSeconds 加锁的时间(秒)，超过这个时间后锁会自动释放
    public boolean tryLock(int lockSeconds) {
        try {
            return doTryLock(lockSeconds);
        } catch (Exception e) {
            logger.error("tryLock Error", e);
            return false;
     * 轮询的方式去获得锁，成功返回true，超过轮询次数或异常返回false
     * @param lockSeconds       加锁的时间(秒)，超过这个时间后锁会自动释放
     * @param tryIntervalMillis 轮询的时间间隔(毫秒)
     * @param maxTryCount       最大的轮询次数
    public boolean tryLock(final int lockSeconds, final long tryIntervalMillis, final int maxTryCount) {
        int tryCount = 0;
        while (true) {
            if (++tryCount >= maxTryCount) {
                // 获取锁超时
                return false;
            }
            try {
                if (doTryLock(lockSeconds)) {
                    return true;
                }
            } catch (Exception e) {
                logger.error("tryLock Error", e);
                Thread.sleep(tryIntervalMillis);
            } catch (InterruptedException e) {
                logger.error("tryLock interrupted", e);
     * 解锁操作
    public void unlock() {
        if (!locked) {
            throw new IllegalStateException("not locked yet!");
        locked = false;
        // 忽略结果
        stringRedisTemplate.execute(DEL_IF_GET_EQUALS, Collections.singletonList(lockKey), lockValue);
    private static class RedisScriptImpl<T> implements RedisScript<T> {
        private final String script;
        private final String sha1;
        private final Class<T> resultType;
        public RedisScriptImpl(String script, Class<T> resultType) {
            this.script = script;
            this.sha1 = DigestUtils.sha1DigestAsHex(script);
            this.resultType = resultType;
        @Override
        public String getSha1() {
            return sha1;
        public Class<T> getResultType() {
            return resultType;
        public String getScriptAsString() {
            return script;
}

2 ) Kelas Alat                                                                                                                                                                      

Atas ialah kandungan terperinci Cara menggunakan skrip Redis+Lua untuk melaksanakan fungsi anti-leret antara muka kaunter. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!