一 Python操作Redis之普通连接
#先安装 pip3 install redis import redis r = redis.Redis(host=‘127.0.0.1‘, port=6379) r.set(‘foo‘, ‘Bar‘) print(r.get(‘foo‘))
二 Python操作Redis之连接池
#使用connection pool来管理对一个redis server的所有连接，避免每次建立、释放连接的开#销。默认，每个Redis实例都会维护一个自己的连接池。可以直接建立一个连接池，然后作为#参数Redis，这样就可以实现多个Redis实例共享一个连接池 import redis pool = redis.ConnectionPool(host=‘127.0.0.1‘, port=6379) r = redis.Redis(connection_pool=pool) r.set(‘foo‘, ‘Bar‘) print(r.get(‘foo‘))
三 Django中使用redis
方式1:(所有框架通用)
建立redis_pool.py
import redis POOL = redis.ConnectionPool(host=‘127.0.0.1‘, port=6379,password=‘1234‘,max_connections=1000)
视图函数使用
import redis from django.shortcuts import render,HttpResponse from utils.redis_pool import POOL def index(request): conn = redis.Redis(connection_pool=POOL) conn.hset(‘kkk‘,‘age‘,18) return HttpResponse(‘设置成功‘) def order(request): conn = redis.Redis(connection_pool=POOL) conn.hget(‘kkk‘,‘age‘) return HttpResponse(‘获取成功‘)
方式2:（django自己封装的）
安装django-redis模块
pip3 install django-redis
setting里配置：
# redis配置 CACHES = { "default": { "BACKEND": "django_redis.cache.RedisCache", "LOCATION": "redis://127.0.0.1:6379", "OPTIONS": { "CLIENT_CLASS": "django_redis.client.DefaultClient", "CONNECTION_POOL_KWARGS": {"max_connections": 100} # "PASSWORD": "123", } } }
注意:设置了redis配置，此时建立的缓存会存在redis里面
视图函数
from django_redis import get_redis_connection conn = get_redis_connection(‘default‘) print(conn.hgetall(‘xxx‘))
四 redis开启事务
redis-py默认在执行每次请求都会创建（连接池申请连接）和断开（归还连接池）一次连接操作，如果想要在一次请求中指定多个命令，则可以使用pipline实现一次请求指定多个命令，并且默认情况下一次pipline 是原子性操作
import redis pool = redis.ConnectionPool(host=‘10.211.55.4‘, port=6379) r = redis.Redis(connection_pool=pool) # pipe = r.pipeline(transaction=False) pipe = r.pipeline(transaction=True) pipe.multi() pipe.set(‘name‘, ‘alex‘) pipe.set(‘role‘, ‘sb‘) pipe.execute()
