今日の世界では、大規(guī)模でトラフィックの多いシステムでは、リクエストに応答する速度と効率が最も重要です。電子商取引 Web サイト、ソーシャル ネットワーク、銀行サービスなどのオンライン プラットフォームは、大量のデータとユーザーのリクエストに直面しています。この高い需要はサーバーやデータベースに大きな負(fù)荷をかけるだけでなく、ユーザー エクスペリエンスにも大きな影響を與える可能性があります。これに関連して、キャッシュ システムの実裝は、パフォーマンスを向上させ、リソースの負(fù)荷を軽減する効果的なソリューションとなります。

この記事では、AVL ツリーと Redis を組み合わせた高度なキャッシュ システムの実裝について説明します。このシステムには、パフォーマンスと柔軟性を強(qiáng)化するためのセキュリティ メカニズム、TTL (Time to Live) 管理、Redis との統(tǒng)合が含まれています。目標(biāo)は、両方のテクノロジーの弱點(diǎn)を軽減しながら、両方のテクノロジーの利點(diǎn)を活用することです。

重要な注意: この記事は人工知能の支援を受けて開(kāi)発されました。

---

AVL ツリーベースのキャッシュ システムと Redis を組み合わせる利點(diǎn)と欠點(diǎn)

利點(diǎn):

1. メモリ効率の向上:

   • インテリジェントな TTL 管理: AVL ツリーを使用してデータの有効期限を管理することにより、メモリ消費(fèi)を最適化し、古いデータの保持を防ぐことができます。これは、データが急速に変化し、正確な有効期限が必要なシナリオで特に役立ちます。

2. 強(qiáng)化されたセキュリティ:

   • トークン検証: トークンベースの検証メカニズムを追加すると、Redis のセキュリティが強(qiáng)化されます。この追加のセキュリティ層により、キャッシュへの不正アクセスが防止され、システム全體のセキュリティが強(qiáng)化されます。

3. 高度な TTL 管理:

   • カスタム有効期限ポリシー: AVL ツリーを使用すると、Redis がそのままではサポートしていない、より複雑でカスタマイズされた有効期限ポリシーを?qū)g裝できます。

4. 多様なデータ構(gòu)造:

   • バランスの取れたツリー構(gòu)造: バランスの取れたデータ構(gòu)造として、AVL ツリーは、Redis のデフォルトのデータ構(gòu)造と比較して、高速な検索と並べ替えを必要とする特定のユースケースで優(yōu)れたパフォーマンスを提供できます。

5. 柔軟性とカスタマイズの向上:

   • より優(yōu)れたカスタマイズ: 2 つのシステムを組み合わせることで、より広範(fàn)なカスタマイズが可能になり、より正確でアプリケーション固有のソリューションの開(kāi)発が可能になります。

欠點(diǎn):

1. アーキテクチャの複雑さの増加:

   • 2 つのキャッシュ システムの管理: Redis と AVL ツリーベースのキャッシュ システムを同時(shí)に使用すると、アーキテクチャが複雑になり、2 つのシステム間で調(diào)整された管理が必要になります。

2. 時(shí)間オーバーヘッドの増加:

   • 追加のレイテンシ: 追加のキャッシュ レイヤーを追加すると、遅延が発生する可能性があります。これらの潛在的な遅延をパフォーマンス上の利點(diǎn)が上回るようにすることが重要です。

3. データのメンテナンスと同期:

   • データの一貫性: Redis と AVL ツリー間の一貫性と同期を維持することは、データの不一致を防ぐために重要であり、複雑な同期メカニズムが必要になります。

4. 開(kāi)発コストとメンテナンスコストの増加:

   • 経費(fèi)の増加: 2 つのキャッシュ システムの開(kāi)発と維持には、より多くのリソースと多様な専門知識(shí)が必要となり、プロジェクト全體のコストが増加する可能性があります。

5. セキュリティの複雑さ:

   • セキュリティ ポリシーの調(diào)整: セキュリティ ポリシーが両方のシステムに正しく一貫して実裝されていることを確認(rèn)することは、困難な場(chǎng)合があります。

---

AVL ツリーと Redis を使用したキャッシュ システムの実裝

以下では、このキャッシュ システムの専門的な実裝を紹介します。この実裝には、TTL 機(jī)能でデータを管理するための AVL ツリーと高速データ ストレージのための Redis が含まれています。

1. TTL を使用した AVL ツリー

まず、TTL 管理機(jī)能を備えた AVL ツリーを?qū)g裝します。

// src/utils/avltree.ts

export class AVLNode {
  key: string;
  value: any;
  ttl: number; // Expiration time in milliseconds
  height: number;
  left: AVLNode | null;
  right: AVLNode | null;

  constructor(key: string, value: any, ttl: number) {
    this.key = key;
    this.value = value;
    this.ttl = Date.now() + ttl;
    this.height = 1;
    this.left = null;
    this.right = null;
  }

  isExpired(): boolean {
    return Date.now() > this.ttl;
  }
}

export class AVLTree {
  private root: AVLNode | null;

  constructor() {
    this.root = null;
  }

  private getHeight(node: AVLNode | null): number {
    return node ? node.height : 0;
  }

  private updateHeight(node: AVLNode): void {
    node.height = 1 + Math.max(this.getHeight(node.left), this.getHeight(node.right));
  }

  private rotateRight(y: AVLNode): AVLNode {
    const x = y.left!;
    y.left = x.right;
    x.right = y;
    this.updateHeight(y);
    this.updateHeight(x);
    return x;
  }

  private rotateLeft(x: AVLNode): AVLNode {
    const y = x.right!;
    x.right = y.left;
    y.left = x;
    this.updateHeight(x);
    this.updateHeight(y);
    return y;
  }

  private getBalance(node: AVLNode): number {
    return node ? this.getHeight(node.left) - this.getHeight(node.right) : 0;
  }

  insert(key: string, value: any, ttl: number): void {
    this.root = this.insertNode(this.root, key, value, ttl);
  }

  private insertNode(node: AVLNode | null, key: string, value: any, ttl: number): AVLNode {
    if (!node) return new AVLNode(key, value, ttl);

    if (key < node.key) {
      node.left = this.insertNode(node.left, key, value, ttl);
    } else if (key > node.key) {
      node.right = this.insertNode(node.right, key, value, ttl);
    } else {
      node.value = value;
      node.ttl = Date.now() + ttl;
      return node;
    }

    this.updateHeight(node);
    const balance = this.getBalance(node);

    // Balancing the tree
    if (balance > 1 && key < node.left!.key) return this.rotateRight(node);
    if (balance < -1 && key > node.right!.key) return this.rotateLeft(node);
    if (balance > 1 && key > node.left!.key) {
      node.left = this.rotateLeft(node.left!);
      return this.rotateRight(node);
    }
    if (balance < -1 && key < node.right!.key) {
      node.right = this.rotateRight(node.right!);
      return this.rotateLeft(node);
    }

    return node;
  }

  search(key: string): any {
    let node = this.root;
    while (node) {
      if (node.isExpired()) {
        this.delete(key);
        return null;
      }
      if (key === node.key) return node.value;
      node = key < node.key ? node.left : node.right;
    }
    return null;
  }

  delete(key: string): void {
    this.root = this.deleteNode(this.root, key);
  }

  private deleteNode(node: AVLNode | null, key: string): AVLNode | null {
    if (!node) return null;

    if (key < node.key) {
      node.left = this.deleteNode(node.left, key);
    } else if (key > node.key) {
      node.right = this.deleteNode(node.right, key);
    } else {
      if (!node.left || !node.right) return node.left || node.right;
      let minLargerNode = node.right;
      while (minLargerNode.left) minLargerNode = minLargerNode.left;
      node.key = minLargerNode.key;
      node.value = minLargerNode.value;
      node.ttl = minLargerNode.ttl;
      node.right = this.deleteNode(node.right, minLargerNode.key);
    }

    this.updateHeight(node);
    const balance = this.getBalance(node);

    if (balance > 1 && this.getBalance(node.left!) >= 0) return this.rotateRight(node);
    if (balance < -1 && this.getBalance(node.right!) <= 0) return this.rotateLeft(node);
    if (balance > 1 && this.getBalance(node.left!) < 0) {
      node.left = this.rotateLeft(node.left!);
      return this.rotateRight(node);
    }
    if (balance < -1 && this.getBalance(node.right!) > 0) {
      node.right = this.rotateRight(node.right!);
      return this.rotateLeft(node);
    }

    return node;
  }
}

2. Redis 統(tǒng)合によるキャッシュ サービス (CacheService)

このセクションでは、キャッシュ管理に AVL ツリーと Redis の両方を利用するキャッシュ サービスを?qū)g裝します。さらに、トークン検証メカニズムも組み込まれています。

// src/cache/cache.service.ts

import { Injectable, UnauthorizedException, InternalServerErrorException } from '@nestjs/common';
import { AVLTree } from '../utils/avltree';
import { InjectRedis, Redis } from '@nestjs-modules/ioredis';

@Injectable()
export class CacheService {
  private avlTree: AVLTree;
  private authorizedTokens: Set<string> = new Set(['your_authorized_token']); // Authorized tokens

  constructor(@InjectRedis() private readonly redis: Redis) {
    this.avlTree = new AVLTree();
  }

  validateToken(token: string): void {
    if (!this.authorizedTokens.has(token)) {
      throw new UnauthorizedException('Invalid access token');
    }
  }

  async set(key: string, value: any, ttl: number, token: string): Promise<void> {
    this.validateToken(token);
    try {
      // Store in Redis
      await this.redis.set(key, JSON.stringify(value), 'PX', ttl);
      // Store in AVL Tree
      this.avlTree.insert(key, value, ttl);
    } catch (error) {
      throw new InternalServerErrorException('Failed to set cache');
    }
  }

  async get(key: string, token: string): Promise<any> {
    this.validateToken(token);
    try {
      // First, attempt to retrieve from Redis
      const redisValue = await this.redis.get(key);
      if (redisValue) {
        return JSON.parse(redisValue);
      }

      // If not found in Redis, retrieve from AVL Tree
      const avlValue = this.avlTree.search(key);
      if (avlValue) {
        // Re-store in Redis for faster access next time
        // Assuming the remaining TTL is maintained in AVL Tree
        // For simplicity, we set a new TTL
        const newTtl = 60000; // 60 seconds as an example
        await this.redis.set(key, JSON.stringify(avlValue), 'PX', newTtl);
        return avlValue;
      }

      return null;
    } catch (error) {
      throw new InternalServerErrorException('Failed to get cache');
    }
  }

  async delete(key: string, token: string): Promise<void> {
    this.validateToken(token);
    try {
      // Remove from Redis
      await this.redis.del(key);
      // Remove from AVL Tree
      this.avlTree.delete(key);
    } catch (error) {
      throw new InternalServerErrorException('Failed to delete cache');
    }
  }
}

3. APIコントローラー(CacheController)

コントローラーはキャッシュ サービスへの API リクエストを管理します。

// src/cache/cache.controller.ts

import { Controller, Get, Post, Delete, Body, Param, Query, HttpCode, HttpStatus } from '@nestjs/common';
import { CacheService } from './cache.service';

class SetCacheDto {
  key: string;
  value: any;
  ttl: number; // milliseconds
  token: string;
}

@Controller('cache')
export class CacheController {
  constructor(private readonly cacheService: CacheService) {}

  @Post('set')
  @HttpCode(HttpStatus.CREATED)
  async setCache(@Body() body: SetCacheDto) {
    await this.cacheService.set(body.key, body.value, body.ttl, body.token);
    return { message: 'Data cached successfully' };
  }

  @Get('get/:key')
  async getCache(@Param('key') key: string, @Query('token') token: string) {
    const value = await this.cacheService.get(key, token);
    return value ? { value } : { message: 'Key not found or expired' };
  }

  @Delete('delete/:key')
  @HttpCode(HttpStatus.NO_CONTENT)
  async deleteCache(@Param('key') key: string, @Query('token') token: string) {
    await this.cacheService.delete(key, token);
    return { message: 'Key deleted successfully' };
  }
}

4. キャッシュモジュール(CacheModule)

サービスとコントローラーを接続し、Redis を注入するキャッシュ モジュールを定義します。

// src/cache/cache.module.ts

import { Module } from '@nestjs/common';
import { CacheService } from './cache.service';
import { CacheController } from './cache.controller';
import { RedisModule } from '@nestjs-modules/ioredis';

@Module({
  imports: [
    RedisModule.forRoot({
      config: {
        host: 'localhost',
        port: 6379,
        // Other Redis configurations
      },
    }),
  ],
  providers: [CacheService],
  controllers: [CacheController],
})
export class CacheModule {}

5. Redis の構(gòu)成

NestJS プロジェクトで Redis を使用するには、@nestjs-modules/ioredis パッケージを利用します。まず、パッケージをインストールします:

npm install @nestjs-modules/ioredis ioredis

次に、上記のように CacheModule で Redis を構(gòu)成します。より高度な構(gòu)成が必要な場(chǎng)合は、別の構(gòu)成ファイルを使用できます。

6. トークン検証メカニズム

トークンの管理と検証には、さまざまな戦略を採(cǎi)用できます。この単純な実裝では、トークンは固定セットで維持されます。大規(guī)模なプロジェクトの場(chǎng)合は、JWT (JSON Web Token) またはその他の高度なセキュリティ方法を使用することをお?jiǎng)幛幛筏蓼埂?/p>

7. エラー処理と入力検証

この実裝では、入力検証とエラー管理に DTO (データ転送オブジェクト) クラスが使用されます。さらに、キャッシュ サービスは、予期しない問(wèn)題を防ぐために一般的なエラー処理を利用します。

8. メインアプリケーションモジュール（AppModule）

最後に、キャッシュ モジュールをメイン アプリケーション モジュールに追加します。

// src/utils/avltree.ts

export class AVLNode {
  key: string;
  value: any;
  ttl: number; // Expiration time in milliseconds
  height: number;
  left: AVLNode | null;
  right: AVLNode | null;

  constructor(key: string, value: any, ttl: number) {
    this.key = key;
    this.value = value;
    this.ttl = Date.now() + ttl;
    this.height = 1;
    this.left = null;
    this.right = null;
  }

  isExpired(): boolean {
    return Date.now() > this.ttl;
  }
}

export class AVLTree {
  private root: AVLNode | null;

  constructor() {
    this.root = null;
  }

  private getHeight(node: AVLNode | null): number {
    return node ? node.height : 0;
  }

  private updateHeight(node: AVLNode): void {
    node.height = 1 + Math.max(this.getHeight(node.left), this.getHeight(node.right));
  }

  private rotateRight(y: AVLNode): AVLNode {
    const x = y.left!;
    y.left = x.right;
    x.right = y;
    this.updateHeight(y);
    this.updateHeight(x);
    return x;
  }

  private rotateLeft(x: AVLNode): AVLNode {
    const y = x.right!;
    x.right = y.left;
    y.left = x;
    this.updateHeight(x);
    this.updateHeight(y);
    return y;
  }

  private getBalance(node: AVLNode): number {
    return node ? this.getHeight(node.left) - this.getHeight(node.right) : 0;
  }

  insert(key: string, value: any, ttl: number): void {
    this.root = this.insertNode(this.root, key, value, ttl);
  }

  private insertNode(node: AVLNode | null, key: string, value: any, ttl: number): AVLNode {
    if (!node) return new AVLNode(key, value, ttl);

    if (key < node.key) {
      node.left = this.insertNode(node.left, key, value, ttl);
    } else if (key > node.key) {
      node.right = this.insertNode(node.right, key, value, ttl);
    } else {
      node.value = value;
      node.ttl = Date.now() + ttl;
      return node;
    }

    this.updateHeight(node);
    const balance = this.getBalance(node);

    // Balancing the tree
    if (balance > 1 && key < node.left!.key) return this.rotateRight(node);
    if (balance < -1 && key > node.right!.key) return this.rotateLeft(node);
    if (balance > 1 && key > node.left!.key) {
      node.left = this.rotateLeft(node.left!);
      return this.rotateRight(node);
    }
    if (balance < -1 && key < node.right!.key) {
      node.right = this.rotateRight(node.right!);
      return this.rotateLeft(node);
    }

    return node;
  }

  search(key: string): any {
    let node = this.root;
    while (node) {
      if (node.isExpired()) {
        this.delete(key);
        return null;
      }
      if (key === node.key) return node.value;
      node = key < node.key ? node.left : node.right;
    }
    return null;
  }

  delete(key: string): void {
    this.root = this.deleteNode(this.root, key);
  }

  private deleteNode(node: AVLNode | null, key: string): AVLNode | null {
    if (!node) return null;

    if (key < node.key) {
      node.left = this.deleteNode(node.left, key);
    } else if (key > node.key) {
      node.right = this.deleteNode(node.right, key);
    } else {
      if (!node.left || !node.right) return node.left || node.right;
      let minLargerNode = node.right;
      while (minLargerNode.left) minLargerNode = minLargerNode.left;
      node.key = minLargerNode.key;
      node.value = minLargerNode.value;
      node.ttl = minLargerNode.ttl;
      node.right = this.deleteNode(node.right, minLargerNode.key);
    }

    this.updateHeight(node);
    const balance = this.getBalance(node);

    if (balance > 1 && this.getBalance(node.left!) >= 0) return this.rotateRight(node);
    if (balance < -1 && this.getBalance(node.right!) <= 0) return this.rotateLeft(node);
    if (balance > 1 && this.getBalance(node.left!) < 0) {
      node.left = this.rotateLeft(node.left!);
      return this.rotateRight(node);
    }
    if (balance < -1 && this.getBalance(node.right!) > 0) {
      node.right = this.rotateRight(node.right!);
      return this.rotateLeft(node);
    }

    return node;
  }
}

9. メインアプリケーションファイル (main.ts)

NestJS をブートストラップするメイン アプリケーション ファイル。

// src/cache/cache.service.ts

import { Injectable, UnauthorizedException, InternalServerErrorException } from '@nestjs/common';
import { AVLTree } from '../utils/avltree';
import { InjectRedis, Redis } from '@nestjs-modules/ioredis';

@Injectable()
export class CacheService {
  private avlTree: AVLTree;
  private authorizedTokens: Set<string> = new Set(['your_authorized_token']); // Authorized tokens

  constructor(@InjectRedis() private readonly redis: Redis) {
    this.avlTree = new AVLTree();
  }

  validateToken(token: string): void {
    if (!this.authorizedTokens.has(token)) {
      throw new UnauthorizedException('Invalid access token');
    }
  }

  async set(key: string, value: any, ttl: number, token: string): Promise<void> {
    this.validateToken(token);
    try {
      // Store in Redis
      await this.redis.set(key, JSON.stringify(value), 'PX', ttl);
      // Store in AVL Tree
      this.avlTree.insert(key, value, ttl);
    } catch (error) {
      throw new InternalServerErrorException('Failed to set cache');
    }
  }

  async get(key: string, token: string): Promise<any> {
    this.validateToken(token);
    try {
      // First, attempt to retrieve from Redis
      const redisValue = await this.redis.get(key);
      if (redisValue) {
        return JSON.parse(redisValue);
      }

      // If not found in Redis, retrieve from AVL Tree
      const avlValue = this.avlTree.search(key);
      if (avlValue) {
        // Re-store in Redis for faster access next time
        // Assuming the remaining TTL is maintained in AVL Tree
        // For simplicity, we set a new TTL
        const newTtl = 60000; // 60 seconds as an example
        await this.redis.set(key, JSON.stringify(avlValue), 'PX', newTtl);
        return avlValue;
      }

      return null;
    } catch (error) {
      throw new InternalServerErrorException('Failed to get cache');
    }
  }

  async delete(key: string, token: string): Promise<void> {
    this.validateToken(token);
    try {
      // Remove from Redis
      await this.redis.del(key);
      // Remove from AVL Tree
      this.avlTree.delete(key);
    } catch (error) {
      throw new InternalServerErrorException('Failed to delete cache');
    }
  }
}

10. アプリケーションのテストと実行

すべてのコンポーネントを?qū)g裝したら、アプリケーションを?qū)g行して機(jī)能を確認(rèn)できます。

// src/cache/cache.controller.ts

import { Controller, Get, Post, Delete, Body, Param, Query, HttpCode, HttpStatus } from '@nestjs/common';
import { CacheService } from './cache.service';

class SetCacheDto {
  key: string;
  value: any;
  ttl: number; // milliseconds
  token: string;
}

@Controller('cache')
export class CacheController {
  constructor(private readonly cacheService: CacheService) {}

  @Post('set')
  @HttpCode(HttpStatus.CREATED)
  async setCache(@Body() body: SetCacheDto) {
    await this.cacheService.set(body.key, body.value, body.ttl, body.token);
    return { message: 'Data cached successfully' };
  }

  @Get('get/:key')
  async getCache(@Param('key') key: string, @Query('token') token: string) {
    const value = await this.cacheService.get(key, token);
    return value ? { value } : { message: 'Key not found or expired' };
  }

  @Delete('delete/:key')
  @HttpCode(HttpStatus.NO_CONTENT)
  async deleteCache(@Param('key') key: string, @Query('token') token: string) {
    await this.cacheService.delete(key, token);
    return { message: 'Key deleted successfully' };
  }
}

11. サンプルリクエスト

キャッシュを設(shè)定:

// src/cache/cache.module.ts

import { Module } from '@nestjs/common';
import { CacheService } from './cache.service';
import { CacheController } from './cache.controller';
import { RedisModule } from '@nestjs-modules/ioredis';

@Module({
  imports: [
    RedisModule.forRoot({
      config: {
        host: 'localhost',
        port: 6379,
        // Other Redis configurations
      },
    }),
  ],
  providers: [CacheService],
  controllers: [CacheController],
})
export class CacheModule {}

キャッシュの取得:

npm install @nestjs-modules/ioredis ioredis

キャッシュの削除:

// src/app.module.ts

import { Module } from '@nestjs/common';
import { CacheModule } from './cache/cache.module';

@Module({
  imports: [CacheModule],
  controllers: [],
  providers: [],
})
export class AppModule {}

---

Redis と AVL ツリーベースのキャッシュ システムを組み合わせるための適切な使用例

1. 銀行および金融システム:

   • 機(jī)密性の高いセッションとトランザクションの管理: 機(jī)密性の高い財(cái)務(wù)データには、高度なセキュリティと正確な TTL 管理が不可欠です。トークンのセキュリティとインテリジェントな TTL 管理を組み合わせると、この分野では非常に有益です。

2. トラフィックの多い電子商取引プラットフォーム:

   • 商品データの保存とショッピング カートの管理: Amazon のような大規(guī)模オンライン ストアでのユーザー エクスペリエンスを向上させるには、メモリの最適化とデータ アクセス速度の向上が不可欠です。

3. メッセージングおよびソーシャル ネットワーキング アプリケーション:

   • リアルタイムのユーザー ステータスの保存: ユーザーのオンライン/オフライン ステータスとメッセージを表示するには、高速アクセスと正確なデータ管理が必要です。

4. 天気予報(bào)と為替アプリケーション:

   • リクエストの負(fù)荷を軽減するための API キャッシュ: 複雑な計(jì)算の結(jié)果とライブデータを正確な有効期限管理とともに保存し、最新かつ迅速な情報(bào)をユーザーに提供します。

5. コンテンツ管理システムとメディア プラットフォーム:

   • トラフィックの多いページとコンテンツのキャッシュ: 閲覧頻度の高いコンテンツへのアクセスを最適化し、サーバーの負(fù)荷を軽減して、よりスムーズなユーザー エクスペリエンスを提供します。

6. 分析アプリケーションとリアルタイム ダッシュボード:

   • 即時(shí)の分析結(jié)果の保存: 複數(shù)のキャッシュを使用して高速で最新の分析データを提供し、パフォーマンスと結(jié)果の精度を向上させます。

---

結(jié)論

この記事では、NestJS フレームワーク內(nèi)で AVL ツリーと Redis を使用した高度なキャッシュ システムを?qū)g裝しました。このシステムは、高度な TTL 管理、トークンベースのセキュリティ、Redis 統(tǒng)合を提供し、需要の高いアプリケーションに堅(jiān)牢かつ柔軟なソリューションを提供します。これら 2 つのテクノロジーを組み合わせることで、両方の長(zhǎng)所が活用され、Redis の弱點(diǎn)に対処し、全體的なキャッシュ パフォーマンスが向上します。

以上がNestJS の高度なキャッシュによる速度とパフォーマンスの向上: AVL ツリーと Redis の使用方法の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國(guó)語(yǔ) Web サイトの他の関連記事を參照してください。