هندسة الأداء المتقدمة: تصميم طبقة ذاكرة مؤقتة موزعة لـ Next.js باستخدام Redis و Redis Cluster

// lib/redis-cluster.js
import Redis from 'ioredis';

const clusterNodes = [
  { host: process.env.REDIS_NODE_1, port: 6379 },
  { host: process.env.REDIS_NODE_2, port: 6379 },
  { host: process.env.REDIS_NODE_3, port: 6379 },
];

let redisClusterInstance = null;

export function getRedisCluster() {
  if (!redisClusterInstance) {
    redisClusterInstance = new Redis.Cluster(clusterNodes, {
      redisOptions: {
        password: process.env.REDIS_PASSWORD,
        tls: process.env.NODE_ENV === 'production' ? {} : undefined,
      },
      scaleReads: 'slave', // توجيه عمليات القراءة للخوادم التابعة لتخفيف الضغط
    });
  }
  return redisClusterInstance;
}

// next.config.js
module.exports = {
  cacheHandler: require.resolve('./cache-handler.js'),
  cacheMaxMemorySize: 0, // إيقاف الكاش الداخلي في الذاكرة تماماً
};

// cache-handler.js
const { getRedisCluster } = require('./lib/redis-cluster');

module.exports = class RedisCacheHandler {
  constructor(options) {
    this.options = options;
    this.redis = getRedisCluster();
  }

  async get(key) {
    try {
      const data = await this.redis.get(key);
      if (!data) return null;
      return JSON.parse(data);
    } catch (error) {
      console.error('Redis Get Error:', error);
      return null; // الفشل الآمن: العودة لقاعدة البيانات في حال تعطل الكاش
    }
  }

  async set(key, data, ctx) {
    try {
      const ttl = ctx.revalidate || 3600; // صلاحية الكاش الافتراضية ساعة
      await this.redis.set(key, JSON.stringify(data), 'EX', ttl);
    } catch (error) {
      console.error('Redis Set Error:', error);
    }
  }
};