Redis 提供了基本的数据类型操作,以及发布/订阅模式,以下是一些基本操作的示例代码:
import redis
# 连接到 Redis
client = redis.StrictRedis(host='localhost', port=6379, db=0)
# 设置字符串
client.set('my_key', 'my_value')
# 获取字符串
value = client.get('my_key')
print(value) # 输出: my_value
# 列表操作
client.rpush('my_list', 'item1')
client.rpush('my_list', 'item2')
list_items = client.lrange('my_list', 0, -1)
print(list_items) # 输出: [b'item1', b'item2']
# 集合操作
client.sadd('my_set', 'item1')
client.sadd('my_set', 'item2')
set_members = client.smembers('my_set')
print(set_members) # 输出: {b'item1', b'item2'}
# 发布/订阅
# 发布者
client.publish('my_channel', 'hello world')
# 订阅者 (需要另外启动一个进程或者线程执行)
pubsub = client.pubsub()
pubsub.subscribe('my_channel')
for message in pubsub.listen():
print(message)
在上述代码中,我们展示了如何使用 Python 的 redis
库来操作 Redis 的基本数据类型,如字符串、列表、集合,以及如何使用发布/订阅模式进行消息通信。需要注意的是,订阅者的代码需要在一个独立的进程或线程中运行,因为 pubsub.listen()
是一个阻塞的操作,会持续监听订阅的频道。