Redis之发布订阅

时间：2024-11-25 22:07:43

一 什么是发布订阅

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

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

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

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

Redis之发布订阅

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

Redis之发布订阅

二 发布订阅模式的作用

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个粉丝订阅了你，当你发布新文章，就可以推送消息给粉丝们

相关文章