设为首页 收藏本站
查看: 1674|回复: 0

[经验分享] Python操作redis的订阅发布功能

[复制链接]
累计签到:1 天
连续签到:1 天
发表于 2016-9-5 16:23:27 | 显示全部楼层 |阅读模式
安装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/ ... tools-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

测试
[iyunv@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"

[iyunv@test1 opt]# redis-cli  
127.0.0.1:6379> get foo
"Bar"


redis订阅和发布功能演示
[iyunv@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!!!']



运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-268049-1-1.html 上篇帖子: Python_正则表达式 下篇帖子: Python:with语句和上下文管理器对象
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表