python redis demo

以下是一个简单的 Python Redis 示例，包括连接 Redis 数据库、设置 Redis 键值对、获取 Redis 值等基本操作：

import redis

# 连接 Redis 数据库
r = redis.Redis(host='localhost', port=6379, db=0)

# 设置 Redis 键值对
r.set('name', 'Tom')

# 获取 Redis 值
name = r.get('name')
print(name)

在这个示例中，我们首先使用 `redis.Redis()` 方法连接 Redis 数据库，这里指定了 Redis 服务器的主机地址、端口号和数据库编号。接着我们使用 `r.set()` 方法设置了一个 Redis 键值对，键名为 'name'，键值为 'Tom'。最后，我们使用 `r.get()` 方法获取了 Redis 中 'name' 键对应的值，并将其输出到控制台上。

需要注意的是，以上示例需要先安装 Redis 数据库和 Python Redis 客户端。可以使用以下命令安装 Python Redis：

pip install redis

相关问题

python安装redis

要在Python中安装Redis，你可以按照以下步骤进行操作：

第一步：先从Redis的官方网站（https://redis.io/download）下载Redis的安装包，选择适合你操作系统的版本。

第二步：打开命令提示符(cmd)，进入到Python安装目录的Scripts文件夹中。使用pip命令来安装刚刚下载好的whl文件，例如：pip install D:\python\redis-2.10.5-py2.py3-none-any.whl。这个命令将会安装Redis的Python库。

第三步：在你的Python代码中导入redis库，你可以使用以下代码来建立一个Redis连接，确保你已经启动了Redis服务器：

import redis
# 建立线程池，避免重复连接
pool = redis.ConnectionPool(host='localhost', port=6379, decode_responses=True)
r = redis.Redis(connection_pool=pool)

第四步：你可以使用以下示例代码来测试连接和使用Redis：

def my_demo():
    r.set("news1", "http://www.1.com")
    r.set("news2", "http://www.2.com")
    print(r.get("news1"))
    print(r.get("news2"))

if __name__ == '__main__':
    my_demo()

这样，你就可以在Python中使用Redis了。请确保你已经安装了Redis服务器，并在代码中正确配置了主机和端口。

redis 分布式锁demo

Redis 分布式锁是一种在分布式环境下使用 Redis 实现的锁定机制，可以避免多个客户端同时修改共享资源而导致数据不一致的情况。下面是一个简单的 Redis 分布式锁的代码示例：

import redis
import time

# 连接 Redis 数据库
r = redis.StrictRedis(host='localhost', port=6379, db=0)

# 加锁函数
def acquire_lock(lockname, acquire_timeout=10, lock_timeout=10):
    identifier = str(time.time())
    end = time.time() + acquire_timeout
    while time.time() < end:
        if r.setnx(lockname, identifier):
            r.expire(lockname, lock_timeout)
            return identifier
    return False

# 释放锁函数
def release_lock(lockname, identifier):
    pipe = r.pipeline(True)
    while True:
        try:
            pipe.watch(lockname)
            if pipe.get(lockname) == identifier:
                pipe.multi()
                pipe.delete(lockname)
                pipe.execute()
                return True
            pipe.unwatch()
            break
        except redis.exceptions.WatchError:
            pass
    return False

# 使用分布式锁
def demo():
    lockname = "mylock"
    identifier = acquire_lock(lockname)
    if not identifier:
        print("无法获取锁")
        return
    print("成功获取锁")
    
    # 在此进行需要加锁的操作
    
    release_lock(lockname, identifier)
    print("释放锁成功")

demo()

以上代码示例中，首先连接 Redis 数据库，然后定义了获取锁和释放锁的两个函数。在使用分布式锁的示例中，先调用 `acquire_lock` 获取锁，成功获取锁之后进行需要加锁的操作，完成操作后调用 `release_lock` 释放锁。这样可以保证在多个客户端同时请求锁时，只有一个客户端能够成功获取锁，从而避免了数据的并发修改问题。