发布信息
import redis
import time
class RedisPub():
def __init__(self):
pool = redis.ConnectionPool(host='127.0.0.0', port='6379', password='adc123') #连接redis
self._conn = redis.StrictRedis(connection_pool=pool)
self.pub_chan = 'chan_test'
def public(self):
msg = ('要发布的信息内容')
self._conn.publish(self.pub_chan, msg) #发布信息
if __name__ == '__main__':
R = RedisPub()
R.public()
python连接redis发布消息
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- 1.准备工作 要想实现python与redis的连接，首先需要引入redis，就这样来实现 2.开始啦 1.创建一...
- 摘要 消息的发布与订阅模式是分布式系统中系统间调用进行解耦的重要手段。通过消息中间件实现的系统间异步通信能够有效地...
- 今天使用Python连接Azure Redis的时候遇到了一系列问题。 首先，使用Python的redis包连接R...
