ioredis 上に構築された多用途で使いやすいキャッシュ マネージャーを使用して、Node.js アプリのパフォーマンスを向上させます。キャッシュを簡素化し、効率を最適化し、運用を合理化します。
私は、使いやすさとパフォーマンスに重点を置き、自分のニーズに合わせて ioredis 上に構築されたクラスを開発しました。 TypeScript のサポートが含まれており、簡単な使用法と効率的な操作を目指しています。動的データベースの使用やより詳細なエラー処理の可能性により、さらに改善および最適化することができます。これを皆さんと共有したいと思います。改善のためのフィードバックや提案をいただければ幸いです。
import Redis, { type RedisOptions } from 'ioredis';
interface CacheConfig {
defaultTTL?: number;
}
export class cacheManager {
private static instance: cacheManager;
private static redisClient: Redis;
private currentKey: string | null;
private defaultTTL: number;
private static readonly DEFAULT_TTL = 3600;
private constructor(config?: CacheConfig) {
const redisConfig: RedisOptions = {
db: 2,
retryStrategy: (times: number) => {
const delay = Math.min(times * 50, 2000);
return delay;
},
lazyConnect: true,
maxRetriesPerRequest: 3,
enableReadyCheck: true,
autoResubscribe: true,
autoResendUnfulfilledCommands: true,
reconnectOnError: (err: Error) => {
const targetError = 'READONLY';
return err.message.includes(targetError);
},
};
if (!cacheManager.redisClient) {
cacheManager.redisClient = new Redis(redisConfig);
cacheManager.redisClient.on('error', (error: Error) => {
console.error('Redis Client Error:', error);
});
cacheManager.redisClient.on('connect', () => {
console.debug('Redis Client Connected');
});
cacheManager.redisClient.on('ready', () => {
console.debug('Redis Client Ready');
});
}
this.currentKey = null;
this.defaultTTL = config?.defaultTTL ?? cacheManager.DEFAULT_TTL;
}
public static getInstance(config?: CacheConfig): cacheManager {
if (!cacheManager.instance) {
cacheManager.instance = new cacheManager(config);
}
return cacheManager.instance;
}
public key(key: string): cacheManager {
this.validateKey(key);
this.currentKey = key;
return this;
}
private validateKey(key: string): void {
if (key.length > 100) throw new Error('Key too long');
if (!/^[\w:-]+$/.test(key)) throw new Error('Invalid key format');
}
public async getValue<T>(): Promise<T | null> {
try {
if (!this.currentKey) {
throw new Error('Key is required');
}
const value = await cacheManager.redisClient.get(this.currentKey);
return value ? JSON.parse(value) : null;
} catch (error) {
console.error('getValue Error:', error);
return null;
}
}
public async getMultiple<T>(keys: string[]): Promise<Record<string, T | null>> {
try {
const pipeline = cacheManager.redisClient.pipeline();
for (const key of keys) {
pipeline.get(key);
}
type PipelineResult = [Error | null, string | null][] | null;
const results = (await pipeline.exec()) as PipelineResult;
const output: Record<string, T | null> = {};
if (!results) {
return output;
}
keys.forEach((key, index) => {
const result = results[index];
if (result) {
const [err, value] = result;
if (!err && value) {
try {
output[key] = JSON.parse(value);
} catch {
output[key] = null;
}
} else {
output[key] = null;
}
} else {
output[key] = null;
}
});
return output;
} catch (error) {
console.error('getMultiple Error:', error);
return {};
}
}
public async setValue<T>(value: T, ttl: number = this.defaultTTL): Promise<boolean> {
try {
if (!this.currentKey) {
throw new Error('Key is required');
}
const stringValue = JSON.stringify(value);
if (ttl) {
await cacheManager.redisClient.setex(this.currentKey, ttl, stringValue);
} else {
await cacheManager.redisClient.set(this.currentKey, stringValue);
}
return true;
} catch (error) {
console.error('setValue Error:', error);
return false;
}
}
public async setBulkValue<T>(keyValuePairs: Record<string, T>, ttl: number = this.defaultTTL, batchSize = 1000): Promise<boolean> {
try {
const entries = Object.entries(keyValuePairs);
for (let i = 0; i < entries.length; i += batchSize) {
const batch = entries.slice(i, i + batchSize);
const pipeline = cacheManager.redisClient.pipeline();
for (const [key, value] of batch) {
const stringValue = JSON.stringify(value);
if (ttl) {
pipeline.setex(key, ttl, stringValue);
} else {
pipeline.set(key, stringValue);
}
}
await pipeline.exec();
}
return true;
} catch (error) {
console.error('setBulkValue Error:', error);
return false;
}
}
public async getOrSetValue<T>(fallbackFn: () => Promise<T>, ttl: number = this.defaultTTL): Promise<T | null> {
try {
if (!this.currentKey) {
throw new Error('Key is required');
}
const cachedValue = await this.getValue<T>();
if (cachedValue !== null) {
return cachedValue;
}
const value = await fallbackFn();
await this.setValue(value, ttl);
return value;
} catch (error) {
console.error('getOrSetValue Error:', error);
return null;
}
}
public async delete(): Promise<boolean> {
try {
if (!this.currentKey) {
throw new Error('Key is required');
}
await cacheManager.redisClient.del(this.currentKey);
return true;
} catch (error) {
console.error('delete Error:', error);
return false;
}
}
public async exists(): Promise<boolean> {
try {
if (!this.currentKey) {
throw new Error('Key is required');
}
return (await cacheManager.redisClient.exists(this.currentKey)) === 1;
} catch (error) {
console.error('exists Error:', error);
return false;
}
}
public async getTTL(): Promise<number> {
try {
if (!this.currentKey) {
throw new Error('Key is required');
}
return await cacheManager.redisClient.ttl(this.currentKey);
} catch (error) {
console.error('getTTL Error:', error);
return -1;
}
}
public static async disconnect(): Promise<void> {
if (cacheManager.redisClient) {
await cacheManager.redisClient.quit();
}
}
}
以上がTypeScript と ioredis を使用して Node.js で高性能キャッシュ マネージャーを構築するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
