Redis 캐시 제거 전략 및 트랜잭션을 사용하여 낙관적 잠금을 구현하는 방법

캐시 제거 전략

제목 LRU 원칙

LRU(Least Recent Used, Least Recent Used) 알고리즘은 데이터의 과거 액세스 기록을 기반으로 데이터를 제거하는 것이 핵심 아이디어입니다. , 그러면 앞으로도 방문할 확률도 높아집니다.”

가장 일반적인 구현은 캐시된 데이터를 저장하기 위해 연결 목록을 사용하는 것입니다. 자세한 알고리즘은 다음과 같이 구현됩니다.

• 새 데이터가 연결 목록의 헤드에 삽입됩니다. 캐시에 도달할 때마다(즉, 캐시된 데이터에 액세스할 때마다) 데이터를 연결 목록의 선두로 이동합니다.

• 연결 목록이 가득 차면 연결 목록 끝에 있는 데이터를 삭제합니다.

• Java에서 LinkHashMap을 사용하면 해시 연결 목록 구현을 통해 LRU를 구현할 수 있습니다.

Title Redis 캐시 제거 전략

최대 캐시 설정

redis에서는 사용자가 최대 캐시를 설정할 수 있습니다. maxmemory를 사용하는 메모리 크기, 기본값은 0이며 최대 캐시는 지정되지 않습니다. 새로운 데이터가 추가되어 최대 메모리를 초과하면 redis가 충돌하므로 설정해야 합니다.

redis 메모리 데이터 세트의 크기가 특정 크기로 증가하면 데이터 제거 전략이 구현됩니다.

제거 전략

redis 제거 전략 구성: maxmemory-policy voltile-lru, 핫 구성 지원

redis는 6가지 데이터 제거 전략을 제공합니다.

휘발성-lru:

설정된 만료 시간에서 선택

• 휘발성-ttl을 제거하기 위해 데이터 세트(server.db[i].expires)에서 가장 최근에 사용된 데이터:
만료 시간이 설정된 데이터 세트(server.db[i].expires)에서 만료될 데이터 선택 및 제거

• 휘발성-random:
만료 시간이 설정된 데이터 세트(server.db[i].expires)에서 제거할 데이터를 무작위로 선택

• allkeys -lru:
From 데이터 세트(server.db[i].dict)에서 가장 최근에 사용된 데이터를 선택하여

• allkeys-random:
데이터 세트(server.db[i)에서 임의의 데이터 선택 ].dict)를 제거하여

• no-enviction(eviction):
데이터 추방 없음

• Redis 트랜잭션

Redis 트랜잭션 소개

Redis 트랜잭션은 MULTI, EXEC 5개 명령을 통해 완료됩니다. , DISCARD 및 WATCH 및 UNWATCH .

• Redis의 단일 명령은 원자적이므로 여기서는 트랜잭션 개체가 명령 세트인지 확인해야 합니다.

• Redis는 명령 세트를 직렬화하고 동일한 트랜잭션에서 명령 세트의 연속적이고 중단 없는 실행을 보장합니다.

• Redis는 롤백 작업을 지원하지 않습니다. 트랜잭션 명령

• MULTI

은 트랜잭션 블록의 시작을 표시하는 데 사용됩니다. Redis는 후속 명령을 하나씩 대기열에 넣은 다음 원자 EXEC 명령을 사용하여 이 명령 시퀀스를 실행합니다. ... 명령을 대기열에 넣은 다음 정상적인 연결 상태를 재개합니다.

구문: ​​

multi

WATCH[트랜잭션을 조건부로 실행해야 함]인 경우 이 명령을 사용하여 지정된 [모니터링할 키] 상태를 설정하세요.

구문: ​​

exec

참고: Redis의 낙관적 잠금을 구현하려면 이 명령을 사용하세요.

UNWATCH

트랜잭션에 대해 이전에 모니터링한 모든 키 지우기

구문: ​​

discard

명령 그림:

트랜잭션 데모:

watch key [key…]

Redis는 트랜잭션 롤백을 지원하지 않습니다(왜 아직인가요?)

대부분의 트랜잭션 실패는 구문 오류 또는 유형 오류로 인해 발생합니다. 이러한 오류는 모두 개발 단계에서 예측할 수 있습니다. Redis는 성능상의 이유로 트랜잭션 롤백을 무시합니다.

Redis Optimistic Lock

Optimistic Lock은 CAS(Compare And Swap) 아이디어(비교 및 교체)를 기반으로 하며 상호 배타적이지 않으며 잠금 대기를 유발하지 않으며 리소스를 소비하지 않습니다. 그러나 반복적인 재시도가 필요합니다. 또한 재시도 덕분에 평가판 메커니즘이 더 빠르게 응답할 수 있습니다. 따라서 Redis를 사용하여 낙관적 잠금을 구현할 수 있습니다. 구체적인 아이디어는 다음과 같습니다.

redis의 감시 기능을 사용하여 이 redisKey의 상태 값을 모니터링합니다.

redisKey의 값을 가져옵니다.

Redis 트랜잭션 만들기

값을 제공합니다. 이 키 +1

然后去执行这个事务，如果key的值被修改过则回滚，key不加1

public void watch() {
	try {
		String watchKeys = "watchKeys";
		//初始值 value=1
		jedis.set(watchKeys, 1);
		//监听key为watchKeys的值
		jedis.watch(watchkeys);
		//开启事务
		Transaction tx = jedis.multi();
		//watchKeys自增加一
		tx.incr(watchKeys);
		//执行事务，如果其他线程对watchKeys中的value进行修改，则该事务将不会执行
		//通过redis事务以及watch命令实现乐观锁
		List<Object> exec = tx.exec();
		if (exec == null) {
			System.out.println("事务未执行");
		} else {
			System.out.println("事务成功执行，watchKeys的value成功修改");
		}
	} catch (Exception e) {
		e.printStackTrace();
	} finally {
		jedis.close();
	}
}

Redis乐观锁实现秒杀

public class RedisLock {
    public static void main(String[] arg) {
        //库存key 
        String redisKey = "stock";
        ExecutorService executorService = Executors.newFixedThreadPool(20);
        try {
            Jedis jedis = new RedisProperties.Jedis("127.0.0.1", 6378);
            // 可以被秒杀的库存的初始值，库存总共20个
            jedis.set(redisKey, "0");
            jedis.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
        for (int i = 0; i < 1000; i++) {
            executorService.execute(() -> {
                Jedis jedis1 = new Jedis("127.0.0.1", 6378);
                try {
                    jedis1.watch(redisKey);
                    String redisValue = jedis1.get(redisKey);
                    int valInteger = Integer.valueOf(redisValue);
                    String userInfo = UUID.randomUUID().toString();
                    // 没有秒完
                    if (valInteger < 20) {
                        Transaction tx = jedis1.multi();
                        tx.incr(redisKey);
                        List list = tx.exec();
                        // 秒成功 失败返回空list而不是空
                        if (list != null && list.size() > 0) {
                            System.out.println("用户：" + userInfo + "，秒杀成 功！当前成功人数：" + (valInteger + 1));
                        }
                        // 版本变化，被别人抢了。
                        else {
                            System.out.println("用户：" + userInfo + "，秒杀失 败");
                        }
                    }
                    // 秒完了
                    else {
                        System.out.println("已经有20人秒杀成功，秒杀结束");
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    jedis1.close();
                }
            });
        }
        executorService.shutdown();
    }
}

위 내용은 Redis 캐시 제거 전략 및 트랜잭션을 사용하여 낙관적 잠금을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!