Node.js中怎么使用Redis？原来这么简单！（node re

REDIS_HOST：Redis 域名

内容来自zvvq

REDIS_PORT：Redis 端口号 zvvq.cn

REDIS_DB： Redis 数据库

内容来自samhan

REDIS_PASSPORT：Redis 设置的密码

zvvq.cn

npm install cache-manager --save zvvq

npm install cache-manager-redis-store --save

内容来自zvvq

npm install @types/cache-manager -D

import { ConfigModule, ConfigService } from &39;@nestjs/config&39;; 内容来自zvvq，别采集哟

import { RedisCacheService } from &39;./redis-cache.service&39;;

本文来自zvvq

import { CacheModule, Module, Global } from &39;@nestjs/common&39;;

import as redisStore from &39;cache-manager-redis-store&39;;

copyright zvvq

@Module({ copyright zvvq

imports: [ 内容来自samhan666

CacheModule.registerAsync({ 本文来自zvvq

isGlobal: true,

copyright zvvq

imports: [ConfigModule], 内容来自samhan

inject: [ConfigService],

zvvq好，好zvvq

useFactory: async (configService: ConfigService) => {

return {

store: redisStore, 内容来自zvvq，别采集哟

host: configService.get(&39;REDIS_HOST&39;),

copyright zvvq

port: configService.get(&39;REDIS_PORT&39;), 内容来自zvvq

db: 0, //目标库,

内容来自samhan666

auth_pass:  configService.get(&39;REDIS_PASSPORT&39;) // 密码,没有可以不写 copyright zvvq

};

},

}),

zvvq

], 内容来自zvvq，别采集哟

providers: [RedisCacheService],

zvvq.cn

exports: [RedisCacheService],

})

export class RedisCacheModule {}

import { Injectable, Inject, CACHE_MANAGER } from &39;@nestjs/common&39;; 内容来自samhan

import { Cache } from &39;cache-manager&39;; 内容来自samhan666

@Injectable() zvvq

export class RedisCacheService {

本文来自zvvq

constructor(

@Inject(CACHE_MANAGER) zvvq.cn

private cacheManager: Cache, zvvq.cn

) {}

cacheSet(key: string, value: string, ttl: number) {

zvvq

this.cacheManager.set(key, value, { ttl }, (err) => {

zvvq

if (err) throw err; 内容来自samhan

}); 内容来自zvvq

} 本文来自zvvq

async cacheGet(key: string): Promise<any> {

return this.cacheManager.get(key); zvvq

} zvvq.cn

} 内容来自samhan

// auth.service.ts 内容来自zvvq，别采集哟

async login(user: Partial<User>) { zvvq好，好zvvq

const token = this.createToken({ 内容来自zvvq

id: user.id, 内容来自zvvq

username: user.username,

role: user.role,

});

copyright zvvq

+   await this.redisCacheService.cacheSet(

zvvq.cn

+     `${user.id}&${user.username}&${user.role}`,

+     token,

内容来自zvvq

+     1800, zvvq好，好zvvq

+   ); 内容来自zvvq

return { token };

内容来自samhan

}

// jwt.strategy.ts

本文来自zvvq

+ import { RedisCacheService } from &39;./../core/db/redis-cache.service&39;; zvvq

export class JwtStrategy extends PassportStrategy(Strategy) { 内容来自zvvq，别采集哟

constructor(

内容来自samhan

@InjectRepository(User) 内容来自zvvq

private readonly userRepository: Repository<User>,

private readonly authService: AuthService, zvvq

private readonly configService: ConfigService, 本文来自zvvq

+   private readonly redisCacheService: RedisCacheService,

) {

内容来自zvvq

super({

zvvq好，好zvvq

jwtFromRequest: ExtractJwt.fromAuthHeaderAsBearerToken(),

内容来自samhan

secretOrKey: configService.get(&39;SECRET&39;),

zvvq.cn

+     passReqToCallback: true,

} as StrategyOptions); 内容来自zvvq，别采集哟

} 内容来自zvvq，别采集哟

async validate(req, user: User) {

内容来自samhan666

+   const token = ExtractJwt.fromAuthHeaderAsBearerToken()(req);

本文来自zvvq

+   const cacheToken = await this.redisCacheService.cacheGet(

+     `${user.id}&${user.username}&${user.role}`, zvvq好，好zvvq

+   ); 内容来自zvvq

+   if (!cacheToken) { 内容来自zvvq

+     throw new UnauthorizedException(&39;token 已过期&39;);

本文来自zvvq

+   } zvvq好，好zvvq

const existUser = await this.authService.getUser(user); copyright zvvq

if (!existUser) {

throw new UnauthorizedException(&39;token不正确&39;);

zvvq

} zvvq

return existUser; copyright zvvq

}

}

zvvq

// jwt.strategy.ts

内容来自samhan666

async validate(req, user: User) { zvvq

const token = ExtractJwt.fromAuthHeaderAsBearerToken()(req);

const cacheToken = await this.redisCacheService.cacheGet( zvvq.cn

`${user.id}&${user.username}&${user.role}`, zvvq

);

zvvq

if (!cacheToken) {

内容来自samhan666

throw new UnauthorizedException(&39;token 已过期&39;); 本文来自zvvq

} copyright zvvq

+   if (token != cacheToken) {

zvvq

+     throw new UnauthorizedException(&39;token不正确&39;);

内容来自zvvq，别采集哟

+   } 内容来自zvvq

const existUser = await this.authService.getUser(user); copyright zvvq

if (!existUser) {

zvvq

throw new UnauthorizedException(&39;token不正确&39;);

内容来自zvvq，别采集哟

}

return existUser;

} copyright zvvq

// auth.module.ts 内容来自samhan

const jwtModule = JwtModule.registerAsync({

zvvq好，好zvvq

inject: [ConfigService],

useFactory: async (configService: ConfigService) => { 内容来自zvvq

return { zvvq好，好zvvq

secret: configService.get(&39;SECRET&39;, &39;test123456&39;), 内容来自samhan

-     signOptions: { expiresIn: &39;4h&39; },  // 取消有效期设置

内容来自samhan666

};

本文来自zvvq

},

zvvq.cn

});

本文来自zvvq

// jwt.strategy.ts 本文来自zvvq

async validate(req, user: User) {

const token = ExtractJwt.fromAuthHeaderAsBearerToken()(req);

zvvq

const cacheToken = await this.redisCacheService.cacheGet( zvvq

`${user.id}&${user.username}&${user.role}`, 内容来自zvvq，别采集哟

);

if (!cacheToken) {

throw new UnauthorizedException(&39;token 已过期&39;); zvvq好，好zvvq

}

if (token != cacheToken) { zvvq

throw new UnauthorizedException(&39;token不正确&39;);

内容来自samhan666

} copyright zvvq

const existUser = await this.authService.getUser(user); zvvq

if (!existUser) {

throw new UnauthorizedException(&39;token不正确&39;); 内容来自samhan

} 内容来自samhan666

+   this.redisCacheService.cacheSet(

+     `${user.id}&${user.username}&${user.role}`, 内容来自samhan666

+     token, zvvq好，好zvvq

+     1800,

zvvq好，好zvvq

+   );

内容来自samhan666

return existUser; zvvq好，好zvvq

}