一 什么是发布订阅

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

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')

个人应用:

#!/usr/bin/env python
# -*- coding:utf-8 -*-

import redis

conn = redis.Redis(host="127.0.0.1", port=6379)
# 频道，发布内容
conn.publish("98k", "hello2 world")
conn.publish("98k", "hello3 world")
conn.publish("98k", "hello5 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)

个人应用:

#!/usr/bin/env python
# -*- coding:utf-8 -*-

import redis

conn = redis.Redis(host="127.0.0.1", port=6379)
# 拿到发布者对象
pub = conn.pubsub()
# 订阅频道
pub.subscribe("98k")
# 可以订阅多个频道
# pub.subscribe('998')
# 循环等待
while True:
    parse_msg = pub.parse_response()
    if isinstance(parse_msg[2], bytes):
        # 接收到消息，解析响应
        msg = parse_msg[2].decode('utf-8')
    else:
        msg = str(parse_msg[2])
    print(msg)

四 发布订阅应用场景

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

? 个人构思的功能实现:

根据不同用户 在消息前 加上标识, 前端位置切割对应位置实现展示

对应用户 通过接收订阅信息来获取数据,  对应发送数据传到后台 后, 后台操作redis连接对象conn来发布数据等待其他订阅者获取

个人理解: 对应这种思路挺有意思, 但是还是websocket更方便和安全!!!

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

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

redis发布订阅

原文：https://www.cnblogs.com/suren-apan/p/11964453.html