Python操作redis的订阅发布功能

ycycoco

　　安装redis-server
　　yum -y install gcc gcc-c++    #安装编译工具
　　cd /opt
　　wget -c http://download.redis.io/releases/redis-3.0.5.tar.gz   #下载包
　　tar xf redis-3.0.5.tar.gz     #解压
　　cd redis-3.0.5
　　make MALLOC=libc  #编译
　　make PREFIX=/usr/local/redis install  #安装
　　echo 'PATH=/usr/local/redis/bin:$PATH' >> /etc/profile    #配置环境变量
　　source /etc/profile #或 . /etc/profile
　　mkdir /usr/local/redis/conf  #创建目录
　　cp /opt/redis-3.0.5/redis.conf /usr/local/redis/conf/   #拷贝配置文件
　　sed -i "46s#/var/run/redis.pid#/usr/local/redis/conf/redis.pid#" /usr/local/redis/conf/redis.conf
　　sed -i "192s#./#/usr/local/redis/conf/#" /usr/local/redis/conf/redis.conf
　　sed -i 509s/no/yes/ /usr/local/redis/conf/redis.conf
　　nohup redis-server /usr/local/redis/conf/redis.conf &> /dev/null &
　　echo vm.overcommit_memory = 1 >> /etc/sysctl.conf
　　sysctl -p
　　lsof -i:6379  #查看端口有没有起来
　　安装pip命令依赖包
　　wget http://pypi.python.org/packages/source/s/setuptools/setuptools-0.6c11.tar.gz --no-check-certificate
　　cd setuptools-0.6c11
　　python setup.py build
　　python setup.py install
　　安装pip命令
　　wget "https://pypi.python.org/packages/source/p/pip/pip-1.5.4.tar.gz#md5=834b2904f92d46aaa333267fb1c922bb" --no-check-certificate
　　tar xf pip-1.5.4.tar.gz
　　cd pip-1.5.4
　　python setup.py install
　　安装redis的Python api
　　pip install redis
　　测试
　　[root@test1 opt]# python
　　Python 2.6.6 (r266:84292, Nov 22 2013, 12:16:22)
　　[GCC 4.4.7 20120313 (Red Hat 4.4.7-4)] on linux2
　　Type "help", "copyright", "credits" or "license" for more information.
　　>>> import redis
　　>>> r = redis.Redis(host='10.211.55.4', port=6379)
　　>>> r.set('foo', 'Bar')
　　>>> print r.get('foo')
　　"Bar"
　　[root@test1 opt]# redis-cli
　　127.0.0.1:6379> get foo
　　"Bar"
　　redis订阅和发布功能演示
　　[root@test1 opt]# cat redishelper.py
　　#!/usr/bin/env python
　　#coding:utf-8
　　import redis
　　class RedisHelper:
　　def __init__(self):
　　self.__conn = redis.Redis(host='127.0.0.1')
　　self.chan_sub = 'fm87.7'  #订阅频道
　　self.chan_pub = 'fm87.7'  #接收频道
　　def get(self,key):
　　return self.__conn.get(key)
　　def set(self,key,value):
　　self.__conn.set(key,value)
　　def public(self,msg):   #在chan_pub这个频道发布消息
　　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') #发布了test这个消息
　　在一端执行脚本
　　python redishelper.py
　　另一端查看
　　>>> import redishelper
　　>>> r = redishelper.RedisHelper()
　　>>> r.subscribe()
　　
　　>>> recv = r.subscribe()
　　>>> recv.parse_response()
　　['message', 'fm87.7', 'test']
　　订布发阅演示2
　　#在一个终端打开这个
　　>>> import redis
　　>>> r = redis.Redis(host='127.0.0.1')
　　>>> chan = r.pubsub()       #打开频道
　　>>> chan.subscribe("fm100") #调到该频道
　　>>> chan.parse_response()   #测试监听频道
　　['subscribe', 'fm100', 1L]
　　>>> chan.parse_response()   #再次执行成阻塞状态等待消息的到来
　　>>> while True:          #写成死循环
　　...  chan.parse_response()
　　在另一个终端打开发布消息
　　>>> import redis
　　>>> p = redis.Redis(host='127.0.0.1')
　　>>> p.publish('fm100','Hellow World!!!')
　　1L
　　回到之前那终端发现已经出来消息
　　>>> while True:
　　...  chan.parse_response()
　　...
　　['message', 'fm100', 'Hellow World!!!']