Redis가 구현하는 분산 트랜잭션에 대한 자세한 설명

인터넷 거래가 지속적으로 성장함에 따라 분산 거래는 비즈니스 시스템의 필수적인 부분이 되었습니다. 분산 트랜잭션 구현 방법이 지속적으로 풍부해짐에 따라 널리 사용되는 인메모리 데이터베이스인 Redis는 점차 분산 트랜잭션 구현을 위한 첫 번째 선택이 되고 있습니다. 이 글에서는 Redis가 분산 트랜잭션을 구현하는 방법을 주로 소개합니다.

Redis의 트랜잭션 모델

Redis에서 지원하는 트랜잭션 모델은 일괄 작업입니다. 트랜잭션 내에서 Redis는 여러 명령을 실행할 수 있습니다. 동일한 트랜잭션에서 여러 명령이 모두 성공하거나 실패하여 트랜잭션의 무결성을 보장하므로 Redis는 트랜잭션성을 잘 지원할 수 있습니다.

Redis 트랜잭션의 기본 원칙은 여러 명령을 하나의 트랜잭션으로 패키징한 후 원자적으로 실행하는 것입니다. 그러나 Redis 트랜잭션의 실행 프로세스는 일반 트랜잭션이 다음 단계를 수행한다는 점에 유의해야 합니다. :

1. 트랜잭션 시작
2. 다중 명령 실행

그러나 Redis 트랜잭션의 실행 프로세스는 다음과 같습니다.

1. 다중 명령 실행

3. 4. 트랜잭션 제출

Redis가 트랜잭션을 실행할 때 여러 명령이 대기열에 들어가고 이러한 명령은 트랜잭션이 제출될 때까지 원자 방식으로 실행됩니다. 트랜잭션 실행 중에 오류가 발생하면 Redis는 오류 코드를 클라이언트에 반환하고 트랜잭션에서 실행되지 않은 명령을 실행하지 않습니다.

Redis 트랜잭션 인스턴스

다음 코드는 Redis 트랜잭션의 간단한 사용을 보여줍니다.

require 'redis'

# 连接Redis数据库
redis = Redis.new(host: 'localhost', port: 6379)

# 初始化一个Redis事务对象
redis.multi do
  redis.set('key1', 'value1')
  redis.set('key2', 'value2')
end

위 코드에서는 Redis 트랜잭션 개체를 사용하여 두 개의 명령을 실행합니다. 이 트랜잭션의 목적은 key1의 값을 설정하는 것입니다. value1 로 key2 의 값을 value2 로 설정합니다. Redis 트랜잭션을 시작하려면 multi 메서드를 사용하고, 키 값을 설정하려면 set 메서드를 사용하고, Redis 트랜잭션을 제출하려면 exec 메서드를 사용하세요. 마지막으로 Redis는 원자 실행을 위해 이러한 명령을 트랜잭션으로 자동으로 패키징합니다.

Redis 분산 트랜잭션 구현 방법

분산 시스템에서는 트랜잭션 작업 데이터가 여러 노드에 분산될 수 있으므로 분산 트랜잭션의 일관성을 보장하는 메커니즘이 필요합니다. Redis의 분산 트랜잭션에는 다음과 같은 구현 방법이 있습니다.

1. Redis의 WATCH 명령을 사용합니다.

WATCH 명령을 사용하여 Redis는 하나 이상의 주요 변수를 모니터링할 수 있습니다. 이전 명령 실행 중에 이러한 변수가 수정된 경우 트랜잭션 실행이 중지되므로 트랜잭션 처리 중 데이터 업데이트로 인해 발생하는 오류를 방지할 수 있습니다. 다음은 WATCH를 사용하는 예입니다.

require 'redis'

# 连接Redis数据库
redis = Redis.new(host: 'localhost', port: 6379)

# 监视key
redis.watch('key')

# 开始事务
redis.multi do
  redis.set('key1', 'value1')
end

# 提交事务
redis.exec

위 코드에서는 watch를 사용하여 키가 수정되었는지 여부를 모니터링합니다. 트랜잭션이 실행되기 시작하면 키가 수정된 것으로 확인되면 실행됩니다. 트랜잭션이 실행된 후 pass exec 메소드가 제출됩니다.

2. Redis 트랜잭션 잠금 사용

WATCH 명령을 사용하는 경우 여러 클라이언트의 동시 액세스를 고려해야 하며 이로 인해 성능 저하가 발생합니다. 따라서 Redis는 Redis의 SETNX 명령 또는 SET 명령을 사용하여 트랜잭션 잠금을 구현할 수 있는 분산 잠금 솔루션도 제공합니다. SETNX 명령어는 설정된 키가 존재하지 않는 경우에만 성공적으로 설정됩니다. 이렇게 하면 하나의 클라이언트에서만 키를 얻을 수 있습니다. SET 명령어를 통해 키의 만료 시간을 설정하여 고유성과 보안을 보장할 수 있습니다. 잠그다. 코드는 다음과 같습니다.

require 'redis'

# 连接Redis数据库
redis = Redis.new(host: 'localhost', port: 6379)

# 设置Redis锁
redis.set('lock_key', 'value', ex: 10, nx: true)

# 执行事务
redis.multi do
  redis.set('key1', 'value1')
end

# 释放Redis锁
redis.del('lock_key')

# 提交事务
redis.exec

위 코드에서는 set 명령어를 사용하여 잠금을 설정하고, 만료 시간을 10초로 설정하고, 동시에 잠금의 반복 획득을 방지하기 위해 nx 매개변수를 설정했습니다.

3. Redis의 Lua 스크립트를 사용하세요

위의 두 가지 방법 외에도 Redis의 Lua 스크립트를 사용하여 분산 트랜잭션 기능을 구현할 수도 있습니다. Lua 스크립트는 원자성 작업을 지원하며 동일한 작업에서 여러 명령을 실행할 수 있습니다. Lua 스크립트를 사용자 정의하면 여러 Redis 명령을 원자성 작업으로 패키징하여 분산 트랜잭션을 달성할 수 있습니다. 다음은 Lua 스크립트 사용 예입니다.

redis.call('WATCH', KEYS[1])

if redis.call('GET', KEYS[1]) == ARGV[1] then
    redis.call('MULTI')
    redis.call('SET', KEYS[1], ARGV[2])
    redis.call('SET', KEYS[2], ARGV[3])
    redis.call('EXEC')
end

redis.call('UNWATCH')

위 코드에서는 Lua 스크립트를 사용하여 분산 트랜잭션을 구현하고, WATCH 명령을 사용하여 트랜잭션이 시작되기 전에 키 상태를 모니터링합니다. 실행 후 UNWATCH 명령을 사용하여 키 모니터링을 취소합니다. Lua 스크립트를 통해 여러 Redis 명령을 원자성 작업으로 패키징하여 분산 트랜잭션을 달성할 수 있습니다.

요약

Redis의 트랜잭션 모델은 일괄 작업으로 트랜잭션의 무결성을 보장합니다. 분산 시스템에서는 트랜잭션 작업 데이터가 여러 노드에 분산될 수 있으므로 분산 트랜잭션의 일관성을 보장하는 메커니즘이 필요합니다. Redis는 WATCH 명령, 트랜잭션 잠금 및 Lua 스크립트의 세 가지 구현 방법을 제공합니다. 어떤 방법을 선택할지는 비즈니스 요구에 따라 선택해야 합니다.

위 내용은 Redis가 구현하는 분산 트랜잭션에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!