django redis 发布订阅

Django 可以通过使用 Redis 的发布订阅模型来实现实时通信。下面是使用 Django 和 Redis 实现发布订阅的一般步骤：

1. 安装 Redis 相关库

可以使用 pip 安装 Redis 相关库，例如：redis、django-redis。

2. 配置 Redis

在 Django 的 settings.py 文件中，配置 Redis 的连接信息，例如：

CACHES = {
    'default': {
        'BACKEND': 'django_redis.cache.RedisCache',
        'LOCATION': 'redis://127.0.0.1:6379/0',
        'OPTIONS': {
            'CLIENT_CLASS': 'django_redis.client.DefaultClient',
        }
    }
}

3. 发布消息

在 Django 的视图函数中，可以使用 Django-Redis 库的 publish() 函数来发布消息，例如：

from django_redis import get_redis_connection

redis_conn = get_redis_connection()
redis_conn.publish('channel_name', 'message_content')

4. 订阅消息

在 Django 的视图函数中，可以使用 Django-Redis 库的 subscribe() 函数来订阅消息，例如：

from django_redis import get_redis_connection
from django.http import HttpResponse
import redis

def stream(request):
    r = redis.Redis()
    p = r.pubsub()
    p.subscribe('channel_name')
    for message in p.listen():
        if message['type'] == 'message':
            return HttpResponse(message['data'])

上面的代码中，我们使用 Redis 的 pubsub() 函数来订阅 'channel_name' 频道，然后通过 listen() 方法来接收消息。如果收到了消息，就将消息内容返回给客户端。

以上就是使用 Django 和 Redis 实现发布订阅的一般步骤，你可以根据自己的需求进行修改和扩展。