[Redis-Python]发布订阅通过Redis异步发送邮件

接收订阅

#!/usr/bin/env pyhton
# coding:utf-8
# @Time     : 2020-02-16 21:36
# @Author   : LeoShi
# @Site     : 
# @File     : redis_demo.py
# @Software : MacOS Python 3.7

import redis

# 创建链接
# 返回 b'peigy2020'
# redis_connect = redis.Redis(host='172.16.1.111', port=6379, password='password')
# decode_responses=True 返回字符串
redis_connect = redis.Redis(host='172.16.1.111', port=6379, password='password', decode_responses=True)

# 接收订阅
catch = redis_connect.pubsub()
# 接收频道
catch.subscribe('email')
while 1:
    for item in catch.listen():
        if item['type'] == 'message':
            data = item['data']
            print(data)
            # 发送邮件

发布订阅

#!/usr/bin/env pyhton
# coding:utf-8
# @Time     : 2020-02-16 22:19
# @Author   : LeoShi
# @Site     : 
# @File     : redis_pulish.py
# @Software : MacOS Python 3.7

import redis

# 建立连接
redis_connect = redis.Redis(host='172.16.1.111', port=6379, password='password', decode_responses=True)

# 发布订阅
for i in range(3):
    redis_connect.publish('email','This is message{}'.format(i))

接收信息结果

This is message0
This is message1
This is message2