#Python-redis#--Python基本操作redis

pip install redis

#!/usr/bin/python
# _*_ coding:utf-8 _*_

import redis


#连接
rs = redis.Redis(host='192.168.0.104', port=6379, db=0, password="robinn")
rs.set("addr", "sichuan chengdu")
print( rs.get("addr") )


#连接池
conn = redis.ConnectionPool(host="192.168.0.104", port=6379,db=0,password="robinn")
r = redis.Redis(connection_pool=conn)

#管道(原子操作)
pip = r.pipeline(transaction=True)
r.set("fonts", "weiruanyahei")
r.set("sizes", "12pt")
pip.execute()

fonts = r.get("fonts")
sizes = r.get("sizes")

print(fonts)
print(sizes)

#!/usr/bin/python
# _*_ coding:utf-8 _*_

import redis

class RedisHelp(object):
    def __init__(self):
        self.__conn = redis.Redis(host="192.168.0.104", port=6379, db=0, password="robinn")
        self.channel = "notice"

    def pub(self, msg):
        self.__conn.publish(self.channel,msg)
        return True

    def sub(self):
        pub_obj = self.__conn.pubsub()
        pub_obj.subscribe(self.channel)
        pub_obj.parse_response()
        return pub_obj

#!/usr/bin/python
# _*_ coding:utf-8 _*_

from RedisHelper import RedisHelp

rs = RedisHelp()
flag = rs.pub("hello")
print("publisher: hello | successful!"+ str(flag))

#!/usr/bin/python
# _*_ coding:utf-8 _*_

from RedisHelper import RedisHelp

r = RedisHelp()
redis_sub = r.sub()

while True:
    msg = redis_sub.parse_response()
    print(msg)