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,并进行基础命令和键值对操作。


数据运维技术 » Redis 查询与应用之旅(redis 查询和使用)