左手Mongodb右手Redis redis操作

set key value 设置key的值

get key 取得key的值

decr key 值会减一

incr key 值会加一

decrby key value ，会让key的值减少value.

incrby key value 会让key的值增加value.

del key 删除key的值

python操作redis的第三方库是“redis”

使用命令 pip install redis

import redis
client = redis.Redis()

后面都要的操作都要使用client对象进行。

for key in client.Keys():
    print(key)

client.keys()返回的是一个列表，列表内的bytes型key.

1.创建字符串

client.set(key,value)

2.获取字符串的值

client.get("hello")

前面的b代表是bytes类型

通过key,decode()解码，字符串就可以正常显示。

提示：

无论是Python的字符串还是数字，进入redis就会编程bytes型的数据，因此特别注意格式转化。

在redis-cli中，set命令有一个nx参数，在python中也可以使用：

client.set("key","value",nx=True)

如果key存在了，则不会覆盖原有的数据。

redis的数据都保存在内存中，查询起来非常快。可以满足对查询速度要求很快但查询逻辑简单的查询。

对于数据超百万级的，需要使用redis的hash.存储相同的数据，hash消耗的内存只有字符串的四分之一。

对于不知道有多少key的情况，不能冒然使用keys *，甚至导致redis失去响应。

列表的创建，查询和修改

1.列表list是redis中的另一种数据结构。

列表就像一根平放的水管，既可以从左边塞数据，也可以向右边塞数据，可以从左边取数据也可以从右边取数据。

redis-cli种插入数据，使用push.

左边插入，lpush value1....value2...

右边插入，rpush value1...value2

用lpush插入数据的流程如图所示

用rpush和lpush插入数据的写法完全相同。

查看列表的长度，使用llen,命令格式是llen key

根据索引查看数据

使用lrange来根据索引查看数据

索引从最左边开始，从0开始到长度-1.

索引查看数据的命令格式为：

lrange 0 开始索引结束索引

lrange example_list 6 6

lrange key start stop

弹出数据，使用pop,分为lpop，rpop

lpop，左弹出 lpop key

rpop 右弹出 rpop key

弹出的数据会被从列表中删除。

修改数据lset

lset key index 新的值
lset example_list 3 me

python如何插入数据

把多条数据使用一个列表保存，然后在这个列表“左侧加※”后作为参数加入到lpush或者rpush

读取数据

首先查看列表长度llen(key)

需要解码，使用decode()

从左右弹出数据使用lpop,rpop,

被弹出来的数据也是bytes类型，所以仍需要解码

列表的应用：

在工程中，redis列表一般用来作为一个队列，存放一批可以使用相同逻辑处理的数据

在一个互联网公司，需要在除夕给10万个用户发送祝福短信，假设一台服务器1秒钟可以发送一个短信，现有10台服务器，需要2.7小时完成任务。

为了保证不漏掉客服，也不能重读发送。

不停的从redis获取手机号调用发送接口。

模拟程序：

import json

import redis

client = redis.Redis(host="localhost", port=6379)


def send_sms(phone_number):
    print("发送对象手机", phone_number)
    print("啦啦啦啦啦")


while True:
    phone_info_bytes = client.lpop("phone_queue")
    if not phone_info_bytes:
        print("短信发送完毕")
        break
    phone_info = json.loads(phone_info_bytes)
    retry_times = phone_info.get("retry_times", 0)
    phone_number = phone_info["phone_number"]
    result = send_sms(phone_number)
    if result:
        print(f"手机号：{phone_number} 短信发送成功！")
        continue
    if retry_times >= 3:
        print(f"重试超过三次，放弃手机号{phone_number}")
        continue
    next_phone_info = {"phone_number": phone_number, "retry_times": retry_times + 1}
client.rpush("phone_queue", json.dumps(next_phone_info))