Python：Redis发布订阅模式

发布消息

# -*- coding: utf-8 -*-

import redis

redis_con = redis.Redis(host='127.0.0.1')

redis_con.publish(channel='test', message='hi-1')


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
 

订阅消息

# -*- coding: utf-8 -*-

import redis

redis_con = redis.Redis(host='127.0.0.1')

pubsub = redis_con.pubsub()
pubsub.subscribe('test')
for item in pubsub.listen(): print(item)


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
 

接收到的消息

# 阻塞监听，第一条是测试数据
{'type': 'subscribe', 'pattern': None, 'channel': b'test', 'data': 1}
{'type': 'message', 'pattern': None, 'channel': b'test', 'data': b'hi'}

  

 

  
1
  
2
  
3
 

文章来源: pengshiyu.blog.csdn.net，作者：彭世瑜，版权归原作者所有，如需转载，请联系作者。

原文链接：pengshiyu.blog.csdn.net/article/details/115235888