Redis：建構高可擴展性系統的利器，需要具體程式碼範例
Redis是一個開源的記憶體資料結構儲存系統，也可以用作訊息佇列和緩存資料庫等。它是一個強大的工具，能夠幫助我們建立高可擴展性系統。本文將為大家介紹Redis的幾個常用特性及其實作程式碼。
Redis的哨兵模式能夠幫助我們實現高可用性。當主節點宕機時，哨兵可以自動選出一個新的主節點。以下是一個簡單的哨兵模式實作範例：
設定檔：
sentinel monitor mymaster 127.0.0.1 6379 2 sentinel down-after-milliseconds mymaster 5000 sentinel failover-timeout mymaster 60000
程式碼：
# 使用redis-py实现哨兵模式
import redis
sentinel = redis.RedisSentinel(
[('127.0.0.1', 26379)],
socket_timeout=0.1,
)
redis_master = sentinel.master_for('mymaster', socket_timeout=0.1)
redis_slave = sentinel.slave_for('mymaster', socket_timeout=0.1)
redis_master.set('key', 'value')
print(redis_slave.get('key'))在分散式系統中，為了避免並發問題，我們需要使用分散式鎖定控制共享資源的存取。 Redis可以透過SETNX和GETSET指令實現分散式鎖定。以下是一個簡單的Redis分散式鎖定實作範例：
程式碼：
import redis
class RedisLock(object):
def __init__(self, name, acquire_timeout=10, expire_time=60):
self.redis = redis.Redis()
self.name = 'redis_lock_key_{}'.format(name)
self.acquire_timeout = acquire_timeout
self.expire_time = expire_time
def acquire_lock(self):
start_time = time.time()
while True:
end_time = time.time()
if self.redis.setnx(self.name, 1):
self.redis.expire(self.name, self.expire_time)
return True
elif end_time - start_time > self.acquire_timeout:
return False
time.sleep(0.1)
def release_lock(self):
self.redis.delete(self.name)
redis_lock = RedisLock('test')
if redis_lock.acquire_lock():
try:
# 操作共享资源
pass
finally:
redis_lock.release_lock()import redis
import threading
def subscribe_channel(redis, channel):
pub_sub = redis.pubsub()
pub_sub.subscribe(channel)
for message in pub_sub.listen():
print(message)
redis_sub = redis.StrictRedis(decode_responses=True)
redis_pub = redis.StrictRedis(decode_responses=True)
redis_thread = threading.Thread(target=subscribe_channel, args=(redis_sub, 'test_channel'))
redis_thread.start()
redis_pub.publish('test_channel', 'Hello, Redis!')import redis
redis_client = redis.Redis()
add_script = redis_client.register_script("""
local current_value = redis.call('get', KEYS[1])
current_value = tonumber(current_value) or 0
current_value = current_value + tonumber(ARGV[1])
redis.call('set', KEYS[1], current_value)
return current_value
""")
add_script(keys=['test_lua_key'], args=[1])以上是Redis：建構高可擴展性系統的利器的詳細內容。更多資訊請關注PHP中文網其他相關文章！
