GraphQL订阅采用Redis实现失败，请求技术排查支持

我之前在替换GraphQL默认PubSub为graphql-redis-subscriptions时也碰到过类似的assert.js报错，大概率是这几个常见问题导致的，你可以一步步排查：

1. 先排查Redis客户端版本兼容性 #

这是最常见的诱因！graphql-redis-subscriptions对ioredis的版本有依赖限制，比如早期的2.x版本只兼容ioredis 4.x系列，如果你装了5.x+的ioredis就会触发断言错误。

• 先执行npm list ioredis查看当前项目里的ioredis版本
• 如果版本不匹配，安装兼容的版本，比如针对graphql-redis-subscriptions@2.x：

  npm install ioredis@4.28.0 --save
  

2. 检查RedisPubSub的配置是否正确 #

很多人会踩这个小坑：不要复用同一个Redis实例作为publisher和subscriber，必须分别创建实例，而且要确保连接参数正确。
举个正确的配置示例：

const { RedisPubSub } = require('graphql-redis-subscriptions');
const Redis = require('ioredis');

// Redis连接配置，根据你的实际环境调整
const redisOptions = {
  host: 'localhost', // 或者你的远程Redis地址
  port: 6379,
  enableReadyCheck: true, // 开启连接就绪检查
  retryDelayOnFailover: 100,
  // 如果Redis设置了密码，加上这行
  // password: 'your-redis-auth-password',
};

// 分别创建发布和订阅实例
const pubsub = new RedisPubSub({
  publisher: new Redis(redisOptions),
  subscriber: new Redis(redisOptions),
});

3. 排查消息序列化/反序列化问题 #

默认情况下，graphql-redis-subscriptions用JSON序列化消息，如果你的订阅消息里有不能被JSON序列化的内容（比如循环引用、函数、特殊对象），就会触发断言错误。
你可以自定义序列化/反序列化逻辑来处理：

const pubsub = new RedisPubSub({
  publisher: new Redis(redisOptions),
  subscriber: new Redis(redisOptions),
  // 自定义序列化
  serializer: (data) => {
    // 在这里处理特殊类型，比如把Date转成字符串
    const serialized = { ...data };
    if (serialized.timestamp) serialized.timestamp = serialized.timestamp.toISOString();
    return JSON.stringify(serialized);
  },
  // 自定义反序列化
  deserializer: (data) => {
    const parsed = JSON.parse(data);
    // 把字符串转回Date
    if (parsed.timestamp) parsed.timestamp = new Date(parsed.timestamp);
    return parsed;
  },
});

4. 打印完整错误堆栈定位问题 #

你给出的错误只显示到assert.js:42 throw ne...，看不到完整堆栈很难精准定位。可以在订阅处理逻辑里加try-catch打印完整错误：

// 假设你是在resolver里处理订阅
const subscriptionResolver = {
  Subscription: {
    messageReceived: {
      subscribe: () => pubsub.asyncIterator('MESSAGE_TOPIC'),
      resolve: (payload) => {
        try {
          return payload.message;
        } catch (err) {
          console.error('完整错误堆栈：', err.stack);
          throw err;
        }
      },
    },
  },
};

完整堆栈会告诉你到底是连接失败、消息格式问题还是其他原因。

5. 检查端口冲突问题 #

你的后端同时跑了MQTT代理和Redis，要确保两者的端口没有冲突（Redis默认6379，MQTT默认1883，WebSocket默认8883），如果有端口被占用，会导致Redis连接异常，进而触发断言错误。

按照上面的步骤排查，应该能解决这个问题。

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