Koa会话从上下文访问存储客户端连接

Question

我使用的是以koa为框架的nodejs，加上koa-session和koa-redis。

import Koa from 'koa';
...
import session from 'koa-session';
import redisStore from 'koa-redis';
const app = new Koa();
app.keys = ["cookieKeys"];
app.use(session({
maxAge: 5184000000,
store: redisStore({url: 'redis://localhost:6379'})
}, app));
...
const server = app.listen(1339, () => {
console.log(`Server listening on port: 1339`);
});
export default server;

现在可以在redis上设置ctx.session.key = "value";并获取ctx.sessios.key;，因为连接已经建立。

我如何访问其他模块中的koa会话存储中使用的相同redis客户端？现在我正在创建一个新的连接：

import { Context, Next, Middleware } from 'koa';
import redis from 'koa-redis';
export default async (ctx: Context, next: Next): Promise<Middleware> => {
try {
return await next();
} catch (err) {
if (err.status !== 401) {
throw err;
}
const redisClient = await redis({url: 'redis://localhost:6379'}).client;
const tokenAccess = ctx.cookies.get('tokenAccess', {signed: true});
const tokenRefresh = ctx.session.tokenRefresh;
...
const isRefreshTokenRevoked = Number.isInteger(await redisClient.zrank('blacklist', tokenRefresh));
await redisClient.quit();
if (isRefreshTokenRevoked) {
throw err;
}
...
}
}

我在上下文ctx.session._sessCtx.store.client中找到了此属性。将此属性用于此目的正确吗？

Answer 1

我想我的问题跳了几步。我用db.js文件重写了代码，并将redis连接作为一个单例：

import { redisURI } from './config';
import Redis from 'koa-redis';
export const redisStore = Redis({url: redisURI});

所以现在我可以导入这个连接并在index.js和其他文件上使用：

import Koa from 'koa';
...
import session from 'koa-session';
import { redisStore } from './db';
//import redisStore from 'koa-redis';
const app = new Koa();
app.keys = ["cookieKeys"];
app.use(session({
maxAge: 5184000000,
store: redisStore
//store: redisStore({url: 'redis://localhost:6379'})
}, app));
...
const server = app.listen(1339, () => {
console.log(`Server listening on port: 1339`);
});
export default server;

在另一个模块上导入：

import { Context, Next, Middleware } from 'koa';
import { redisStore } from './db';
export default async (ctx: Context, next: Next): Promise<Middleware> => {
try {
return await next();
} catch (err) {
if (err.status !== 401) {
throw err;
}
//const redisClient = await redis({url: 'redis://localhost:6379'}).client;
const tokenAccess = ctx.cookies.get('tokenAccess', {signed: true});
const tokenRefresh = ctx.session.tokenRefresh;
...
const isRefreshTokenRevoked = Number.isInteger(await redisStore.client.zrank('blacklist', tokenRefresh));
//const isRefreshTokenRevoked = Number.isInteger(await redisClient.zrank('blacklist', tokenRefresh));
//await redisClient.quit();
if (isRefreshTokenRevoked) {
throw err;
}
...
}
}