使用Supabase+Bun后端实现PostgreSQL实时监控：求助排查问题

问题描述 #

我正在开发基于Supabase的应用，当前尝试部署一个使用Bun、TypeScript和Supabase-js库的独立轻量后端，用于监听PostgreSQL数据库的实时变更。当指定的training表发生新增或更新时，需更新本地维护的对应数组，同时检查表中start_time是否过期以触发其他函数。但目前Supabase实时订阅监听器无法接收到任何变更。

补充上下文 #

• 使用createClient初始化Supabase客户端，传入SERVICE_ROLE_KEY，以便独立于主应用运行；
• 在WSL2终端测试，怀疑存在WebSocket连接或端口配置问题；
• 已为training表开启实时功能。

相关代码中，客户端初始化、初始数据获取均正常，但实时连接状态返回false，订阅回调未触发。

排查步骤与解决方案 #

1. 检查Supabase客户端实时配置 #

确保初始化客户端时显式启用实时功能，并且WebSocket端点配置正确：

import { createClient } from '@supabase/supabase-js';

const supabase = createClient(
  process.env.SUPABASE_URL!,
  process.env.SUPABASE_SERVICE_ROLE_KEY!,
  {
    realtime: {
      autoRefreshToken: true,
      persistSession: false, // 服务端场景无需持久化会话
      connectTimeout: 10000,
      channelOptions: {
        config: {
          broadcast: { ack: true },
          presence: { key: '' }
        }
      }
    }
  }
);

同时确认Supabase项目API设置中，Realtime权限未限制服务角色的访问。

2. 验证WSL2的WebSocket连通性 #

WSL2的NAT网络模式可能导致WebSocket连接受阻：

• 在WSL2终端执行wscat -c wss://<你的Supabase项目ID>.supabase.co/realtime/v1/websocket?apikey=<你的服务角色密钥>，直接测试WebSocket连接是否正常；
• 关闭WSL2内的代理环境变量（如http_proxy/https_proxy），避免代理拦截WebSocket请求；
• 若问题持续，可尝试切换到WSL1测试网络兼容性。

3. 确认实时表权限与RLS规则 #

即使开启了表的实时功能，行级安全（RLS）规则可能阻止服务角色接收变更：

• 进入Supabase控制台Database -> Realtime，确认training表的INSERT和UPDATE事件已勾选；
• 为服务角色添加training表的读取权限（实时订阅依赖读取权限）：

CREATE POLICY "允许服务角色读取training表" ON public.training
FOR SELECT USING (true)
TO service_role;

4. 调试实时连接状态 #

在代码中添加状态监听，定位具体错误原因：

supabase.realtime.on('status', (status) => {
  console.log('实时连接状态:', status);
});

supabase.realtime.on('error', (error) => {
  console.error('实时连接错误:', error);
});

5. 检查订阅代码正确性 #

确保订阅逻辑指定了正确的事件、表名，且回调绑定正常：

const channel = supabase.channel('training-change-channel')
  .on('postgres_changes', {
    event: 'INSERT,UPDATE', // 仅监听需要的事件
    schema: 'public',
    table: 'training'
  }, (payload) => {
    console.log('收到变更:', payload);
    // 处理本地数组更新与start_time过期检查逻辑
  })
  .subscribe((status) => {
    console.log('订阅状态:', status);
  });

注意：通道名称需唯一，避免重复订阅导致冲突。

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