python与redis交互
redis数据类型：
redis一共有5类数据类型：string, hash, list , set ,zset
- string
string是redis最基本的类型，你可以理解成与Memcached一模一样的类型，一个key对应一个value。
string类型是二进制安全的。意思是redis的string可以包含任何数据。比如jpg图片或者序列化的对象 。
string类型是Redis最基本的数据类型，一个键最大能存储512MB。
- hash
Redis hash 是一个键值(key=>value)对集合。
Redis hash是一个string类型的field和value的映射表，hash特别适合用于存储对象。
- list
Redis 列表是简单的字符串列表，按照插入顺序排序。你可以添加一个元素到列表的头部（左边）或者尾部（右边）,列表最多可存储 232 - 1 元素 (4294967295, 每个列表可存储40多亿)。
- set
Redis的Set是string类型的无序集合。
集合是通过哈希表实现的，所以添加，删除，查找的复杂度都是O(1)。
- zset
Redis zset 和 set 一样也是string类型元素的集合,且不允许重复的成员。
不同的是每个元素都会关联一个double类型的分数。redis正是通过分数来为集合中的成员进行从小到大的排序。
zset的成员是唯一的,但分数(score)却可以重复
redis数据操作方法：
string类型：
set p ; get p ; del p
mset w 1 e 3 批量创建
mget w e q 批量获取
incr o ; get o ; 递增
incrby o 5 增加5不是增加5
decrby o 3 减少3
incrbyfloat o 2.5 增de加浮点数
append u 2 追加（类似字符串这种直接追加数字）
getrange m 0 -1 从头取到尾
getrange 0 7;;; getrange m -2 -1;;;;;
list:双向链表
lpush lt coco haha lalala 推送数据进入列表，左插入
lrange lt 0 -1 获得列表的数
lpush lt coco haha lalala 右插入
每种类型的数据获取方法是不一样的
lpop lt 删除一个数据
llen lt 查看lt的长度
set:集合 --- 集合是无序的
sadd p 1 2 3 创建集合
scard p 查询集合的长度
smenbers 查询集合的元素
spop p 2 随机删除2个元素
zadd g 10 m1 增加成员
zscore g m1 获取成员分数
zrange g 0 -1 获取排序后的集合,从小到大
zrevrange g 0 -1 从大到小
python下redis与mysql的交互实例
- pip install redis 安装本地的redis
2.连接mysql
3.连接redis
import redis
redis.Redis()
4.获取姓名密码参数
python xxx.py argv1 argv2
import sys
sys.argv[1]
5.访问redis,判断输入的姓名和密码和redis中保存的用户名和密码是否匹配
6，和redis不匹配，则查询Mysql,select 操作
7，mysql 查询结果的话，则更新到redis中，反之则没有该用户
# _*_ coding:utf-8 _*_
import sys
import pymysql
import redis
# 访问mysql数据库
def con_mysql(sql):
db = pymysql.connect(host='127.0.0.1',
user='root',
passwd='peimin123!',
port=3306,
db = 'test4',
charset='utf8')
cursor = db.cursor()
cursor.execute(sql)
data = cursor.fetchall()
db.close()
return data
def con_redis(name, passwd):
r = redis.Redis(host='47.106.96.225', port = 6379,
password='peimin123!')
r_name = r.hget('user', 'name')
r_passwd = r.hget('user', 'passwd')
r_name = r_name.decode('utf8')
print(r_name)
r_pass = r_passwd.decode('utf8')
print(r_pass)
if name == r_name and passwd == r_pass:
return True, '登录成功'
else:
return False,'登录失败'
if __name__ == '__main__':
# 获取传入的姓名和密码参数
name = sys.argv[1]
passwd = sys.argv[2]
# 传入redis中，进行校验
result = con_redis(name, passwd)
if not result[0]:
# 查询mysql数据库
sql = '''select * from stu where name='%s' and
password='%s';''' % (name, passwd)
data = con_mysql(sql)
print(data)
if data:
r = redis.Redis(host='47.106.96.225', port = 6379,
password='peimin123!')
r.hset('user', 'name', name)
r.hset('user', 'passwd', passwd)
print('刷新redis， 登录成功')
else:
print('用户名和密码错误')
else:
print('redis中数据正确，登录成功')
redis的发布和订阅
步骤：pub,sub 通过redischell连接起来
Redis 发布订阅(pub/sub)是一种消息通信方式：发布者(pub)发送消息，订阅者(sub)接收消息。
Redis 客户端可以订阅任意数量的频道。
redischell
import redis
class RedisBase(object):
def __init__(self):
self.__conn = redis.Redis(host='47.106.96.225',
port=6379,
password='peimin123!')
self.pub = 'test'
self.sub = 'test'
# 发布
def publish_msg(self, msg):
self.__conn.publish(self.pub, msg)
# 订阅
def subscribe_msg(self):
# 打开收音机
pub = self.__conn.pubsub()
# 订阅接收
pub.subscribe(self.pub)
# 等待消息
pub.parse_response()
# 开始接收
return pub
pub
from redischell import RedisBase
obj = RedisBase()
msg = 'hello, world!'
obj.publish_msg(msg)
sub
from redischell import RedisBase
obj = RedisBase()
redis_sub = obj.subscribe_msg()
while True:
#二次调用parse_response() 开始接收
msg = redis_sub.parse_response()
print('msg:%s' % msg)
