如何实现Django网站在所有访问浏览器间保持状态同步？

核心问题定位 #

你当前的问题本质有两点：一是新用户首次登录时未获取到最新数据库状态（模板渲染用了旧数据），二是高频AJAX轮询在视图增多后会导致性能瓶颈。以下是针对性的长效解决方案：

1. 修复首次渲染的数据源问题 #

确保用户首次登录时，视图从数据库拉取最新数据，而非缓存的旧模板或数据：

• 移除不必要的页面级缓存：如果视图使用了@cache_page装饰器，同一凭证的用户可能会拿到缓存的旧响应。对于动态数据视图，直接去掉@cache_page，或改用基于用户ID+数据版本的缓存策略，比如：

  from django.core.cache import cache
  
  def dynamic_view(request):
      user_key = f"user_{request.user.id}"
      data_version = cache.get(f"{user_key}_data_version", 0)
      cached_data = cache.get(f"{user_key}_data_{data_version}")
      if not cached_data:
          # 从数据库拉取最新数据
          cached_data = MyModel.objects.filter(user=request.user).all()
          cache.set(f"{user_key}_data_{data_version}", cached_data, timeout=300)
      return render(request, 'template.html', {'data': cached_data})
  

• 避免视图外的全局数据缓存：不要在模块级别提前查询数据库并缓存结果，确保每次请求进入视图时都执行实时查询。

2. 替换轮询为WebSocket推送（长效最优方案） #

用WebSocket替代高频AJAX轮询，当数据库状态变化时主动推送给所有在线客户端，包括新登录的用户：

• 使用Django Channels实现WebSocket通信：
  1. 配置Channels，连接到Redis或PostgreSQL作为通道层。
  2. 在模型中添加post_save信号，当数据更新时向通道发送通知：

     from django.db.models.signals import post_save
     from django.dispatch import receiver
     from channels.layers import get_channel_layer
     from asgiref.sync import async_to_sync
     
     @receiver(post_save, sender=MyModel)
     def send_data_update(sender, instance, created, **kwargs):
         channel_layer = get_channel_layer()
         # 向所有订阅了"data_updates"组的客户端发送消息
         async_to_sync(channel_layer.group_send)(
             "data_updates",
             {
                 "type": "data_update_message",
                 "data": {"id": instance.id, "status": instance.status}
             }
         )
     

  3. 客户端JS监听WebSocket，收到消息后仅更新对应的DOM元素，无需刷新整个视图：

     const ws = new WebSocket('ws://' + window.location.host + '/ws/data-updates/');
     ws.onmessage = function(e) {
         const data = JSON.parse(e.data);
         // 更新页面上的对应元素
         document.getElementById(`post-${data.id}`).textContent = data.status;
     };
     

• 新用户登录时，先拉取一次当前最新状态，再订阅WebSocket，确保首次加载就是最新数据，之后实时同步。

3. 优化AJAX轮询（过渡方案） #

如果暂时无法接入WebSocket，可以优化现有轮询逻辑降低性能损耗：

• 合并多视图请求：创建一个统一的API端点（比如/api/all-updates/），一次性返回所有需要更新的数据，减少HTTP请求次数：

  from django.http import JsonResponse
  
  def all_updates_api(request):
      data = {
          'view1_data': View1Model.objects.filter(user=request.user).values(),
          'view2_data': View2Model.objects.filter(user=request.user).values()
      }
      return JsonResponse(data)
  

• 改用长轮询：客户端发送请求后，服务器保持连接直到有数据更新或超时，避免每秒空请求：

  import time
  from django.http import JsonResponse
  
  def long_poll_update(request):
      last_update = request.GET.get('last_update', 0)
      timeout = time.time() + 30  # 30秒超时
      while time.time() < timeout:
          current_version = cache.get('data_version', 0)
          if current_version > int(last_update):
              # 有更新，返回数据
              data = MyModel.objects.filter(user=request.user).values()
              return JsonResponse({'data': data, 'version': current_version})
          time.sleep(1)
      # 超时返回空，客户端重新发起请求
      return JsonResponse({'data': [], 'version': last_update})
  

• 基于版本号的增量更新：在数据库中维护一个全局或用户级的数据版本号，每次更新数据时递增版本号，客户端仅在版本变化时拉取具体数据，减少传输量。

4. 利用PostgreSQL的LISTEN/NOTIFY增强同步 #

结合你已有的PostgreSQL中间件，使用数据库的通知机制触发状态同步：

• 在PostgreSQL中创建触发器，当目标表数据更新时发送NOTIFY：

  CREATE OR REPLACE FUNCTION notify_data_update()
  RETURNS TRIGGER AS $$
  BEGIN
      PERFORM pg_notify('data_update', row_to_json(NEW)::text);
      RETURN NEW;
  END;
  $$ LANGUAGE plpgsql;
  
  CREATE TRIGGER trigger_data_update
  AFTER INSERT OR UPDATE ON myapp_mymodel
  FOR EACH ROW EXECUTE FUNCTION notify_data_update();
  

• 在Django中监听这个通知，收到后更新缓存或推送给客户端：

  import psycopg2
  from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT
  
  def listen_db_updates():
      conn = psycopg2.connect("dbname=your_db user=your_user password=your_pass")
      conn.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT)
      cur = conn.cursor()
      cur.execute("LISTEN data_update;")
      while True:
          conn.poll()
          while conn.notifies:
              notify = conn.notifies.pop()
              # 处理通知，比如更新缓存或通过Channels推送
              update_cache_with_new_data(notify.payload)
  

内容的提问来源于stack exchange，提问作者Satyam Srivastava