Redis 查询与应用之旅(redis 查询和使用)
Redis是一个常见的高性能Key-Value内存数据库,它的特点是数据读取速度快,可用于缓存和数据存储等领域。以下将介绍Redis的查询与应用之旅,包括连接Redis,基础命令、键值对操作、事务、发布/订阅等功能,并附带相关代码示例。
连接Redis
我们需要连接Redis数据库。以下是在Python中使用redis-py进行连接的代码:
import redis
r = redis.Redis(host="localhost", port=6379, db=0)
其中,host表示Redis所在的IP地址,port表示端口号,db为数据库编号,可以选取0~15个之间的数字。
基础命令
下面是一些Redis的基础命令:
设置键值对(set/get):
r.set("name", "Alice")
print(r.get("name"))
输出:
b’Alice’
获取key数量(dbsize):
print(r.dbsize())
输出:
1
删除key(delete):
r.delete("name")
键值对操作
除了设置键值对,Redis还支持其他类型的数据,例如列表、哈希表、集合和有序集合。以下是一些常见的操作:
列表:
r.rpush("mylist", "a")
r.rpush("mylist", "b")r.lpush("mylist", "c")
print(r.lrange("mylist", 0, -1))
输出:
[b’c’, b’a’, b’b’]
哈希表:
r.hset("myhash", "field1", "value1")
r.hset("myhash", "field2", "value2")print(r.hgetall("myhash"))
输出:
{b'field1': b'value1', b'field2': b'value2'}
集合:
r.sadd("myset", "a")
r.sadd("myset", "b")r.sadd("myset", "c")
print(r.smembers("myset"))
输出:
{b'a', b'b', b'c'}
有序集合:
r.zadd("myzset", {"a": 1, "b": 2, "c": 3})
print(r.zrange("myzset", 0, -1, withscores=True))
输出:
[(b'a', 1.0), (b'b', 2.0), (b'c', 3.0)]
事务
Redis支持事务的概念,可以将多个操作打包成一个事务进行提交或回滚。以下是一个事务的示例:
with r.pipeline() as pipe:
while True: try:
pipe.watch("mykey") value = pipe.get("mykey")
value = int(value) + 1 pipe.multi()
pipe.set("mykey", value) pipe.execute()
break except redis.exceptions.WatchError:
continue
当多个客户端同时修改同一个key时,watch可以协助实现乐观锁。
发布/订阅
Redis还提供了发布/订阅功能,可以实现消息的广播。以下是发布/订阅的代码示例:
import threading
def publisher(): for i in range(10):
r.publish("channel", i) time.sleep(1)
def subscriber(): pubsub = r.pubsub()
pubsub.subscribe("channel") for item in pubsub.listen():
print(item["data"])
t1 = threading.Thread(target=publisher)t2 = threading.Thread(target=subscriber)
t1.start()t2.start()
在发布者中,每隔1秒向频道“channel”发布一条消息。在订阅者中,使用pubsub()函数订阅该频道,并使用listen()函数获取消息。在输出过程中,item[“data”]表示收到的消息。
总结
Redis是一个高性能的Key-Value内存数据库,支持多种数据结构和事务,还提供了发布/订阅功能。使用redis-py可以方便地连接Redis,并进行基础命令和键值对操作。