Amadeus's Studio.

redis订阅python代码

Redis
字数统计: 109阅读时长: 1 min
2019/02/28 Share 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
class Listener(object):
    """
    监听器，用于监听Redis订阅的data
    """
    def __init__(self):
        # self.r = redis.Redis(host='139.198.4.56', port='6379')
        # redis_client为redis连接设置
        self.redis_client = redis_client
        self.crawl_seeds = self.redis_client.pubsub()
        self.crawl_seeds.subscribe('content')
        logging.info("连接到Redis...")
    
    def listen(self):
        for item in self.crawl_seeds.listen():
            if item['type'] != 'message':
                continue
            meta = str(item['data'], encoding='utf-8')
            logging.info('收:%s ' % json.loads(meta).get('content', '').strip())

用日志打印接受结果

Redis不是专门做消息队列的，建议使用RabbitMQ、Kafka

原文作者：Amadeus

原文链接：http://gilgameshzzz.github.io/2019/02/28/redis订阅python代码/

发表日期：February 28th 2019, 12:00:00 am

更新日期：April 16th 2020, 10:31:17 am

版权声明：本文采用知识共享署名-非商业性使用 4.0 国际许可协议进行许可

CATALOG
Total : 25
2020
2019
Docker MongoDB Java Netty MyBatisPlus 布隆过滤器 Redis python 并发 java lambda 问题 hash 算法 二叉树 MySQL Golang 位移 web安全 OOP