Python操作redis的订阅发布功能

发布时间：2019-08-27 08:02:02编辑：auto阅读（1689）

安装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()

<redis.client.PubSub object at 0x7f1789422950>

>>> 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!!!']

关键字：