Redis 是一个开源的内存中数据结构存储系统，可以用作数据库、缓存和消息中间件。以下是一些 Redis 的常见使用场景：
- 缓存系统：Redis 是一个非常出色的缓存工具，可以把热点数据保存在内存中，加快应用程序的访问速度。
import redis
r = redis.Redis(host='localhost', port=6379, db=0)
r.set('key', 'value')
print(r.get('key'))
- 分布式会话存储：Web应用可以使用 Redis 保存用户会话，从而在整个应用中对用户状态进行管理。
# Flask 使用 Redis 作为会话存储
from flask import Flask, session
from redis import Redis
app = Flask(__name__)
app.config['SESSION_TYPE'] = 'redis'
app.config['SESSION_REDIS'] = Redis(host='localhost', port=6379, db=0)
@app.route('/')
def index():
session['key'] = 'value'
return 'Session stored in Redis'
- 队列系统：Redis 提供了列表和发布/订阅功能，可以作为消息队列使用。
import redis
r = redis.Redis(host='localhost', port=6379, db=0)
r.lpush('queue', 'item')
print(r.brpop('queue', timeout=5))
- 排行榜/计数器：Redis 的 Sorted Set 和 Hash 数据类型可以用来创建各种排行榜和计数器。
import redis
r = redis.Redis(host='localhost', port=6379, db=0)
r.zadd('leaderboard', {'player1': 200, 'player2': 150})
print(r.zrange('leaderboard', 0, -1, withscores=True))
- 分布式锁：Redlock 是一种使用 Redis 实现分布式锁的算法。
import redis
def acquire_lock(lock_name, acquire_timeout=5, lock_timeout=5):
identifier = str(uuid.uuid4())
end = time.time() + acquire_timeout
lock_name = 'lock:' + lock_name
while time.time() < end:
if r.set(lock_name, identifier, ex=lock_timeout, nx=True):
return identifier
time.sleep(0.001)
return False
def release_lock(lock_name, identifier):
lock_name = 'lock:' + lock_name
with r.pipeline() as pipe:
while True:
try:
pipe.watch(lock_name)
if pipe.get(lock_name) == identifier:
pipe.multi()
pipe.delete(lock_name)
pipe.execute()
return True
pipe.unwatch()
break
except redis.exceptions.WatchError:
pass
return False
- 点击流/用户行为跟踪：Redis 提供的 Bitwise 操作和 Data Structure 可以用于大规模的事件跟踪。
import redis
r = redis.Redis(host='localhost', port=6379, db=0)
r.setbit('user:100:events', 10, 1)
r.setbit('user:100:events', 15, 1)
print(r.bitcount('user:100:events'))
- 分布式数据共享：多个系统或服务可以通过 Redis 共享和交换数据。
import redis
r = redis.Red