redis原理

Client:

import tab,redis
s = redis.Redis(host='10.39.3.110')

chan = s.pubsub()
chan.subscribe('fm100')
chan.parse_response()

Servre:
import redis
p = redis.Redis(host='10.39.3.110')

p.publish('fm100','wo ai beijing tiananmen')

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

import redis

class RedisHelper:

    def __init__(self):
        self.__conn = redis.Redis(host='10.39.3.110')
        self.chan_sub = 'fm87.7'
        self.chan_pub = 'fm104.5'
        
    def get(self,key):
        return self.__conn.get(key)

    def set(self,key,value):
        self.__conn.set(key,value)

    def public(self,msg):
        self.__conn.publish(self.chan_pub, msg)
        return True

    def subscribe(self):
        pub = self.__conn.pubsub()
        pub.subscribe(self.chan_sub)
        pub.parse_response()
        return pub

if __name__ == '__main__':
    t = RedisHelper()
    t.public('test')