一 什么是发布订阅

 发布订阅模式又叫观察者模式，它定义对象间的一种一对多的依赖关系，当一个对象的状态发生改变时，所有依赖它的对象都将得到通知

Redis 发布订阅(pub/sub)是一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。

Redis 客户端可以订阅任意数量的频道。

下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系：

当有新消息通过 PUBLISH 命令发送给频道 channel1 时， 这个消息就会被发送给订阅它的三个客户端：

二 发布订阅模式的作用

    1、用于异步编程，取代传递回调函数的方案

    2、让两个对象松耦合地联系在一起，一个对象不再显式地调用另一个对象的接口

三 python+Redis实现发布订阅

发布者：

# -*- coding:utf-8 -*-
# Author : liuqingzheng
# Data : 2018/11/23 19:17

import redis
conn=redis.Redis(host='127.0.0.1',port=6379)
# 频道，发布内容
conn.publish('98k','hello world')

订阅者：

# -*- coding:utf-8 -*-
# Author : liuqingzheng
# Data : 2018/11/23 19:20
import redis
conn=redis.Redis(host='127.0.0.1',port=6379)
# 拿到发布者对象
pub=conn.pubsub()
# 订阅频道
pub.subscribe('98k')
# 可以订阅多个频道
# pub.subscribe('998')
# 循环等待
while True:
    # 接收到消息，解析响应
    msg=pub.parse_response()
    print(msg)

 

四 发布订阅应用场景

1 构建实时消息系统，比如普通的即时聊天，群聊等功能

2 在我们的分布式架构中，常常会遇到读写分离的场景，在写入的过程中，就可以使用redis发布订阅，使得写入值及时发布到各个读的程序中，就保证数据的完整一致性

3 在一个博客网站中，有100个粉丝订阅了你，当你发布新文章，就可以推送消息给粉丝们