2018-04-19

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的交互实例

1. 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)