论坛 › Redis › Python redis 发布和订阅

renshanshan 发表于 2018-11-4 13:38:49

Python redis 发布和订阅

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

　　
__author__ = 'gaogd'
　　

　　
import redis
　　

　　
class RedisHelper:
　　
    def __init__(self):
　　
      self.__conn = redis.Redis(host='192.168.10.12', port=6379, password='xxxx2014')
　　
      self.chan_sub = 'fm250'
　　
      self.chan_pub = 'fm250'
　　

　　
    def public(self, msg):      ##发送消息到fm250这个频道
　　
      self.__conn.publish(self.chan_pub, msg)
　　
      return True
　　

　　
    def subscribe(self):      ##订阅 (接受fm250这个频道的消息)
　　
      pub=self.__conn.pubsub()
　　
      pub.subscribe(self.chan_sub)
　　
      pub.parse_response()
　　
      return pub

查看完整版本: Python redis 发布和订阅