Redis

本文基于Redis配置完集成的前提下操作 未配置可前往配置集成

第一步 安装包

安装集群配置包

1
2
pip install redis-py-cluster
# 若pip不好使就改为 pip3

第二步 使用

  1. 导包

    1
    from rediscluster import *

  2. 构建所有的节点

    1
    2
    3
    4
    5
    6
    7
    8
    9
    # 构建所有的节点，Redis会使⽤CRC16算法，将键和值写到某个节点上
            startup_nodes = [
                {'host': '192.111.141.129', 'port': '8000'},
                {'host': '192.111.141.129', 'port': '8001'},
                {'host': '192.111.141.129', 'port': '7002'},
                {'host': '192.111.141.129', 'port': '7003'},
                {'host': '192.111.141.129', 'port': '7004'},
                {'host': '192.111.141.129', 'port': '7005'},
            ]

  3. 构建RedisCluster对象

    1
    2
    # 构建RedisCluster对象
    src = RedisCluster(startup_nodes=startup_nodes, decode_responses=True)

  4. 测试设置与获取代码

    1
    2
    3
    4
    5
    6
    # 设置键为name、值为itheima的数据
    result = src.set('name', 'aaa')
    print(result)
    # 获取键为name
    name = src.get('name')
    print(name)

  5. 再添加异常捕获

1
2
3
4
5
6
7
if __name__ == '__main__':
    try:
        代码...
      
except Exception as e:
     print(e)

文件示例

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
from rediscluster import *


if __name__ == '__main__':
    try:
        # 构建所有的节点，Redis会使⽤CRC16算法，将键和值写到某个节点上
        startup_nodes = [
            {'host': '192.111.141.129', 'port': '8000'},
            {'host': '192.111.141.129', 'port': '8001'},
            {'host': '192.111.141.129', 'port': '7002'},
            {'host': '192.111.141.129', 'port': '7003'},
            {'host': '192.111.141.129', 'port': '7004'},
            {'host': '192.111.141.129', 'port': '7005'},
        ]
        # 构建RedisCluster对象
        src = RedisCluster(startup_nodes=startup_nodes, decode_responses=True)
        # 设置键为name、值为itheima的数据
        result = src.set('name', 'aaa')
        print(result)
        # 获取键为name
        name = src.get('name')
        print(name)
    except Exception as e:
        print(e)