Node.js アプリケーションで Redis クライアントライブラリを使って Memorystore に接続する方法

2024-05-21

Node.js で本番環境で Memorystore を使用する

Memorystore を本番環境で使用する利点

パフォーマンスの向上: Memorystore はインメモリデータストアであるため、データベースに比べてデータアクセス速度が非常に速くなります。
スケーラビリティ: Memorystore は、ワークロードの要求に合わせて自動的にスケーリングできます。
可用性: Memorystore は高可用性インフラストラクチャ上で実行されるため、データ損失のリスクが低くなります。
使いやすさ: Memorystore は Redis と互換性があるため、既存の Node.js アプリケーションを簡単に移行できます。

Memorystore インスタンスを作成する: Google Cloud Platform Console または gcloud コマンドラインツールを使用して、Memorystore インスタンスを作成します。
Node.js アプリケーションで Redis クライアントライブラリをインストールする: npm または yarn を使用して、Node.js アプリケーションで Redis クライアントライブラリ (node_redis など) をインストールします。
アプリケーションを Memorystore インスタンスに接続する: Redis クライアントライブラリを使用して、Node.js アプリケーションを Memorystore インスタンスに接続します。
データを Memorystore に保存および取得する: Redis コマンドを使用して、データを Memorystore に保存および取得します。

本番環境で Memorystore を使用する際の注意事項

データの永続性: Memorystore はインメモリデータストアであるため、データはインスタンスがシャットダウンされると失われます。重要なデータは、永続的なストレージソリューションにもバックアップする必要があります。
セキュリティ: Memorystore インスタンスは、ファイアウォールルールを使用して保護する必要があります。
監視: Memorystore インスタンスのパフォーマンスと使用状況を監視する必要があります。

この情報は参考目的のみであり、本番環境での Memorystore の使用に関する公式ガイダンスとして解釈されるべきではありません。 Memorystore を本番環境で使用する前に、Google Cloud Platform のドキュメントを参照し、関連するベストプラクティスに従ってください。

Node.js で Memorystore を使用するサンプルコード

const redis = require('node_redis');

const client = redis.createClient({
  url: 'rediss://<your-memorystore-instance-id>@<your-memorystore-instance-region>.redis.cache.gcp.cloud.google.com:<your-memorystore-instance-port>',
});

client.on('error', (err) => {
  console.error('Error connecting to Memorystore:', err);
});

client.on('connect', () => {
  console.log('Connected to Memorystore!');

  // データを Memorystore に保存
  client.set('key', 'value', (err, reply) => {
    if (err) {
      console.error('Error setting data:', err);
      return;
    }

    console.log('Data saved successfully:', reply);
  });

  // Memorystore からデータを取得
  client.get('key', (err, reply) => {
    if (err) {
      console.error('Error getting data:', err);
      return;
    }

    console.log('Data retrieved successfully:', reply);
  });
});

説明

このコードは、以下のことを行います。

node_redis モジュールをインポートします。
redis.createClient() 関数を使用して、Memorystore インスタンスへの接続を作成します。
client.on('error') イベントリスナーを登録して、接続エラーを処理します。
client.set() メソッドを使用して、データをキー "key" で Memorystore に保存します。

このコードは、Memorystore の基本的な操作のみを示しています。詳細については、Memorystore のドキュメントを参照してください。

補足

上記のコードを実行するには、Memorystore インスタンスの ID、リージョン、ポート番号を置き換える必要があります。
データを保存する前に、Memorystore インスタンスに接続されていることを確認してください。
エラー処理を適切に実装する必要があります。

Node.js で Memorystore を使用するその他の方法

Pub/Sub を使用してメッセージをやり取りする

Memorystore は、Pub/Sub と統合されており、アプリケーション間でメッセージをやり取りするための高スループットでスケーラブルなソリューションを提供します。

以下の例は、Memorystore を使ってサブスクライバーにメッセージを公開する方法を示しています。

const redis = require('node_redis');
const PubSub = require('@google-cloud/pubsub');

const redisClient = redis.createClient({
  url: 'rediss://<your-memorystore-instance-id>@<your-memorystore-instance-region>.redis.cache.gcp.cloud.google.com:<your-memorystore-instance-port>',
});

const pubsubClient = new PubSub();

const topicName = 'my-topic';

pubsubClient.topic(topicName).publish('Hello, world!');

redisClient.on('message', (channel, message) => {
  console.log('Received message:', message);
});

redisClient.subscribe('my-channel');

レート制限を実装する

Memorystore は、特定の時間枠内に実行できる操作の数を制限することで、アプリケーションに対するリクエストのレートを制限するために使用できます。

const redis = require('node_redis');

const redisClient = redis.createClient({
  url: 'rediss://<your-memorystore-instance-id>@<your-memorystore-instance-region>.redis.cache.gcp.cloud.google.com:<your-memorystore-instance-port>',
});

const key = 'rate-limit:user-123';
const limit = 100; // 1 分間に許可されるリクエスト数
const period = 60; // 1 分 (秒単位)

const checkRateLimit = async (req, res, next) => {
  const remaining = await redisClient.decr(key);

  if (remaining === null) {
    // キーが存在しない場合は、レート制限を適用しない
    next();
    return;
  }

  if (remaining < 0) {
    res.status(429).send('Too Many Requests');
    return;
  }

  next();
};

app.use(checkRateLimit);

セッションデータを保存する

Memorystore は、Web アプリケーションのセッションデータを保存するために使用できます。

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

const app = express();

const redisClient = redis.createClient({
  url: 'rediss://<your-memorystore-instance-id>@<your-memorystore-instance-region>.redis.cache.gcp.cloud.google.com:<your-memorystore-instance-port>',
});

const RedisStore = redisStore(session);

app.use(session({
  store: new RedisStore({ client: redisClient }),
  secret: 'my-secret',
  resave: false,
  saveUninitialized: false,
}));

app.get('/', (req, res) => {
  // セッションデータにアクセス
  const user = req.session.user;

  if (user) {
    res.send(`Hello, ${user.name}!`);
  } else {
    res.send('Please login.');
  }
});

app.listen(3000);

キャッシュを実装する

Memorystore は、データベースからのデータのキャッシュに使用できます。

const redis = require('node_redis');
const knex = require('knex');

const redisClient = redis.createClient({
  url: 'rediss://<your-memorystore-instance-id>@<your-memorystore-instance-region>.redis.cache.gcp.cloud.google.com:<your-memorystore-instance-port>',
});

const db = knex({
  client: 'mysql',
  connection: {
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'my_database