1
class Listener(object):
2
    """
3
    监听器，用于监听Redis订阅的data
4
    """
5
    def __init__(self):
6
        # self.r = redis.Redis(host='139.198.4.56', port='6379')
7
        # redis_client为redis连接设置
8
        self.redis_client = redis_client
9
        self.crawl_seeds = self.redis_client.pubsub()
10
        self.crawl_seeds.subscribe('content')
11
        logging.info("连接到Redis...")
12

13
    def listen(self):
14
        for item in self.crawl_seeds.listen():
15
            if item['type'] != 'message':
16
                continue
17
            meta = str(item['data'], encoding='utf-8')
18
            logging.info('收:%s ' % json.loads(meta).get('content', '').strip())