PHP实现MySQL插入实时监听方案咨询：替代Ajax轮询适配万级用户

核心架构：WebSocket + 消息中间件 + Python服务 #

针对10000级用户的实时消息展示需求，推荐采用「Python bot -> 消息中间件 -> WebSocket服务 -> 前端网页」的架构，完全替代轮询方案，具体拆解如下：

1. 调整Python bot的消息发送逻辑 #

• 废弃直接插入MySQL后依赖轮询的模式，改为同时写入MySQL + 推送消息到轻量消息中间件（优先选Redis Pub/Sub，轻量化易部署；若需更可靠的消息持久化可选RabbitMQ）
  • 示例代码（Redis Pub/Sub）：

    import redis
    import pymysql
    
    # 初始化Redis连接
    redis_conn = redis.Redis(host='your-redis-host', port=6379, db=0)
    # 初始化MySQL连接
    mysql_conn = pymysql.connect(host='your-mysql-host', user='user', password='pwd', db='msg_db')
    
    def send_message(user_id, content):
        # 1. 写入MySQL做持久化
        with mysql_conn.cursor() as cursor:
            sql = "INSERT INTO messages (user_id, content) VALUES (%s, %s)"
            cursor.execute(sql, (user_id, content))
            mysql_conn.commit()
        # 2. 推送到Redis频道
        redis_conn.publish('real_time_msg_channel', f'{{"user_id":{user_id},"content":"{content}"}}')
    

• 优势：消息中间件的并发推送能力远高于MySQL，能轻松承载1万级用户的消息分发，彻底规避数据库请求次数限制

2. 搭建WebSocket服务订阅中间件消息 #

• 用Python的FastAPI + WebSockets或Django Channels搭建WebSocket服务，订阅中间件的消息频道，实现服务端主动推送
  • 示例（FastAPI WebSocket）：

    from fastapi import FastAPI, WebSocket
    import redis
    import asyncio
    
    app = FastAPI()
    redis_conn = redis.Redis(host='your-redis-host', port=6379, db=0)
    pubsub = redis_conn.pubsub()
    pubsub.subscribe('real_time_msg_channel')
    
    # 存储所有活跃的WebSocket连接
    active_conns = set()
    
    async def relay_redis_msg():
        while True:
            msg = pubsub.get_message(ignore_subscribe_messages=True)
            if msg:
                # 向所有在线客户端推送消息
                for conn in active_conns:
                    await conn.send_text(msg['data'].decode('utf-8'))
            await asyncio.sleep(0.1)
    
    @app.on_event("startup")
    async def startup():
        asyncio.create_task(relay_redis_msg())
    
    @app.websocket("/ws/msg")
    async def ws_endpoint(websocket: WebSocket):
        await websocket.accept()
        active_conns.add(websocket)
        try:
            # 保持连接存活，无需前端主动请求
            while True:
                await websocket.receive_text()
        except:
            active_conns.remove(websocket)
    

• 优势：WebSocket是长连接，前端建立连接后无需发起任何轮询请求，服务端有新消息时直接推送到客户端

3. 前端WebSocket对接与消息展示 #

• 前端使用原生WebSocket API建立连接，接收消息后直接渲染到页面，同时添加重连逻辑避免连接断开：

  const wsUrl = 'ws://your-server-domain/ws/msg';
  let ws;
  
  function initWebSocket() {
      ws = new WebSocket(wsUrl);
      ws.onmessage = (event) => {
          const msg = JSON.parse(event.data);
          // 将消息插入页面容器
          const msgItem = document.createElement('div');
          msgItem.textContent = `用户${msg.user_id}: ${msg.content}`;
          document.getElementById('msg-list').appendChild(msgItem);
      };
      // 断开后自动重连
      ws.onclose = () => setTimeout(initWebSocket, 3000);
  }
  
  initWebSocket();
  

4. 历史消息兜底方案 #

• 用户首次加载页面时，发起单次请求获取MySQL中的历史消息，之后仅通过WebSocket接收新消息，既保证历史数据展示，又不会产生频繁请求

为什么不推荐直接监听MySQL Binlog？ #

• 配置复杂度高：需要开启MySQL Binlog、配置权限，且数据库版本或配置变更可能导致监听失效
• 耦合性强：业务代码与数据库底层绑定，维护成本高
• 性能瓶颈：Binlog监听的消息处理能力弱于专业消息中间件，面对1万级用户时容易出现推送延迟

内容的提问来源于stack exchange，提问作者Lucas Silva Dev