Connect-redis，快速会话设置失败：UnhandledPromiseRejectionWarning：错误：客户端已关闭

Question

import { MikroORM } from '@mikro-orm/core';
import { ApolloServer } from 'apollo-server-express';
import express from 'express';
import { buildSchema } from 'type-graphql';
import { __prod__ } from './constants';
import mikroOrmConfig from './mikro-orm.config';
import { HelloResolver } from './resolvers/hello';
import { PostResolver } from './resolvers/post';
import { UserResolver } from './resolvers/user';

const main = async () => {
  const orm = await MikroORM.init(mikroOrmConfig);
  await orm.getMigrator().up();

  const app = express();

  const redis = require('redis');
  const connectRedis = require('connect-redis');
  const session = require('express-session');
  const RedisStore = connectRedis(session);

  const redisClient = redis.createClient({
    port: 6379,
    host: 'localhost',
  });

  app.use(
    session({
      name: 'qid',
      saveUninitialized: false,
      secret: 'sdfdsf24342fdsdfdsf23f2fdwf',
      resave: false,
      store: new RedisStore({
        client: redisClient,
        disableTouch: true,
      }),
      cookie: {
        maxAge: 86400 * 10, // 10 days
        httpOnly: true,
        secure: __prod__,
        sameSite: 'lax',
      },
    })
  );

  const appoloServer = new ApolloServer({
    schema: await buildSchema({
      resolvers: [HelloResolver, PostResolver, UserResolver],
      validate: false,
    }),

    // context is an object accessible by all the resolvers
    context: ({ req, res }) => ({ em: orm.em, req, res }),
  });

  appoloServer.applyMiddleware({ app });

  app.listen(4000, () => {
    console.log('Server is started on 4000');
  });
};

main().catch(err => {
  console.error(err);
});

$纱线开发 结果：服务器在 4000 上启动 2秒后： UnhandledPromiseRejectionWarning：错误：客户端已关闭 在 Commander._RedisClient_sendCommand (/home/hleb/Projects/wreddit-server/node_modules/@node-redis/client/dist/lib/client/index.js:387:31)

我做错了什么？ 谢谢。

Answer 1

import { createClient } from 'redis';

const redisClient = createClient({
    url: yoururl,
});

(async () => {
    redisClient.on('error', (err) => console.log('Redis Client Error', err));
    await redisClient.connect();
})();

export default redisClient;

我不知道为什么 我运行 redisClint.connet() 问题就解决了。