python 操做redis

from redis import Redis


cache = Redis(host='192.168.0.101',port=6379,password='wuheng')

#1.操做字符串
# cache.set('username','zhiliao')

# cache.delete('username')

# cache.set('password','wuheng')

# cache.delete('username')#刪除key

#列表的操做
# cache.lpush('languages','java')#從左到右的插入列表，
# cache.lpush('languages','python')
# cache.lpush('languages','php')
#
# print(cache.lrange('languages',0,-1))#獲取列表中全部元素

#集合的操做
# cache.sadd('team','11')
# cache.sadd('team','123')

# print(cache.smembers('team'))#獲取集合中全部元素

#哈希的操做
# cache.hset('website','baidu','www.baidu.com')
# cache.hset('website','mokw','www.mokewang.com')
# print(cache.hgetall('website'))#獲取全部字典中的值
# {b'baidu': b'www.baidu.com', b'mokw': b'www.mokewang.com'}

#事物的操做
#定義一個管道和一個實例
# pip = cache.pipeline()
# pip.set('username','zhiliao')
# pip.set('username','123456')
# pip.execute()#執行這個事物，事物要摸執行，否則所有不執行

#發佈與訂閱
#異步發送郵件的功能
ps = cache.pubsub()#建立一個訂閱的對象
ps.subscribe('email')#,訂閱email頻道
while True:
    # ps.listen()#監聽 返回值是一個生成器
    for item in ps.listen():
        print(item)#這個時候就能夠處理一些操做
        if item['type'] == 'message' and item['channel'] == b'email':
            data = item['data']
            print(data.decode('utf-8'))

from redis import Redis


cache = Redis(host='192.168.0.101',port=6379,password='wuheng')

#發佈三個郵件消息

for x in range(3):
    cache.publish('email','xxx@qq.com')