Redis: عندما تتجاوز الـ Cache وتصبح العمود الفقري لنظامك

# مثال عملي: استخدام Redis كقاعدة بيانات رئيسية لنظام تداول الأسهم
import redis
import json

# إعداد الاتصال مع Redis مع تفعيل AOF و RDB
r = redis.Redis(
 host='localhost',
 port=6379,
 db=0,
 decode_respTrue,
 # تفعيل AOF مع fsync كل ثانية
 socket_timeout=5,
 health_check_interval=30
)

# نموذج بيانات بسيط لصفقة تداول
trade_data = {
 "symbol": "AAPL",
 "price": 175.30,
 "quantity": 100,
 "timestamp": 1712345678.123456,
 "buyer_id": "user_4567",
 "seller_id": "user_8901"
}

# استخدام SET مع EX لتخزين الصفقة مع انتهاء صلاحية بعد 30 يوماً
r.set(f"trade:{trade_data['timestamp']}", json.dumps(trade_data), ex=2592000)

# استرجاع الصفقة باستخدام GET
retrieved_trade = json.loads(r.get(f"trade:{trade_data['timestamp']}"))
print(f"تم استرجاع صفقة {retrieved_trade['symbol']} بسعر {retrieved_trade['price']}")

# استخدام SET مع NX لتنفيذ عمليات ذرية (مثل منع الصفقة المكررة)
if r.set(f"trade:{trade_data['timestamp']}", json.dumps(trade_data), nx=True, ex=2592000):
 print("تم تسجيل الصفقة بنجاح")
else:
 print("الصفقة موجودة مسبقاً - منع التكرار")

# استخدام HSET لتخزين بيانات إضافية عن المستخدم
r.hset(
 f"user:{trade_data['buyer_id']}",
 mapping={
 "last_trade_time": str(trade_data['timestamp']),
 "total_trades": "1",
 "balance": "50000.00"
 }
)

# استخدام INCR لزيادة عدد الصفقات بشكل ذري
r.hincrby(f"user:{trade_data['buyer_id']}", "total_trades", 1)

// مثال عملي: استخدام Redis Pub/Sub لبناء نظام إعلانات في الوقت الفعلي
const redis = require("redis");

// إنشاء الناشر
const publisher = redis.createClient({
 url: "redis://localhost:6379"
});

// إنشاء المشترك
const subscriber = redis.createClient({
 url: "redis://localhost:6379"
});

// تعريف قناة الرسائل
const CHANNEL_NAME = "real_time_ads";

// إعداد المشترك
subscriber.on("error", (err) => console.error("Redis Client Error", err));

subscriber.subscribe(CHANNEL_NAME, (message) => {
 const adData = JSON.parse(message);
 console.log(`تم استلام إعلان جديد: ${adData.adId} للمستخدم ${adData.userId}`);
 // هنا يمكنك معالجة الإعلان في الوقت الفعلي
 processAdInRealTime(adData);
});

// وظيفة النشر
async function publishAd(adData) {
 await publisher.connect();
 await publisher.publish(CHANNEL_NAME, JSON.stringify(adData));
 console.log(`تم نشر الإعلان ${adData.adId}`);
 await publisher.quit();
}

// وظيفة معالجة الإعلان في الوقت الفعلي
function processAdInRealTime(adData) {
 // محاكاة معالجة الإعلان
 console.log(`جاري معالجة الإعلان ${adData.adId} للمستخدم ${adData.userId}`);
 // يمكن هنا تحديث واجهة المستخدم أو تسجيل البيانات في قاعدة بيانات أخرى
}

// مثال على نشر إعلان
publishAd({
 adId: "ad_12345",
 userId: "user_67890",
 content: "خصم 50% على جميع المنتجات!",
 timestamp: Date.now()
});

// استخدام Redis Lists لبناء نظام قوائم انتظار
async function useRedisAsQueue() {
 const queueClient = redis.createClient({
 url: "redis://localhost:6379"
 });
 await queueClient.connect();
 
 // إضافة مهام إلى قائمة الانتظار
 await queueClient.lPush("ad_processing_queue", JSON.stringify({
 taskId: "task_1",
 adId: "ad_54321",
 priority: "high"
 }));
 
 // استخراج المهام من قائمة الانتظار
 const task = await queueClient.rPop("ad_processing_queue");
 if (task) {
 const taskData = JSON.parse(task);
 console.log(`جاري معالجة المهمة ${taskData.taskId}`);
 // معالجة المهمة هنا
 }
 
 await queueClient.quit();
}

useRedisAsQueue();

# مثال عملي: استخدام Redis لتحليل البيانات في الوقت الفعلي
import redis
import time
import random

# إعداد اتصال Redis
r = redis.Redis(host='localhost', port=6379, db=0)

# محاكاة تدفق بيانات المستخدمين
user_events = [
 {"user_id": f"user_{i}", "event_type": random.choice(["view", "click", "purchase"]), "product_id": f"prod_{random.randint(1, 100)}", "timestamp": int(time.time())}
 for i in range(1, 1001)
]

# تخزين وتحليل البيانات في الوقت الفعلي
for event in user_events:
 # استخدام Sorted Set لحساب عدد الأحداث لكل منتج
 r.zincrby("product_events", 1, event["product_id"])
 
 # استخدام Sorted Set لحساب الأحداث حسب النوع
 r.zincrby(f"event_type:{event['event_type']}", 1, event["product_id"])
 
 # استخدام Hash لتخزين آخر حدث لكل مستخدم
 r.hset(f"user_last_event:{event['user_id']}", mapping=event)
 
 # استخدام HyperLogLog لتقدير عدد المستخدمين الفريدين
 r.pfadd("unique_users", event["user_id"])

# الحصول على أكثر 5 منتجات مشاهدة
top_products = r.zrevrange("product_events", 0, 4, withscores=True)
print("أكثر 5 منتجات مشاهدة:")
for product, score in top_products:
 print(f"- {product.decode('utf-8')}: {int(score)} مشاهدة")

# الحصول على عدد المستخدمين الفريدين
unique_users_count = r.pfcount("unique_users")
print(f"عدد المستخدمين الفريدين: {unique_users_count}")

# تحليل الأحداث حسب النوع
for event_type in ["view", "click", "purchase"]:
 count = r.zcard(f"event_type:{event_type}")
 print(f"عدد المنتجات التي تم {event_type}: {count}")

# استخدام ZINTERSTORE لحساب المنتجات الأكثر تفاعلاً (مشاهدة + نقرة)
r.zinterstore("most_engaged_products", ["event_type:view", "event_type:click"])
top_engaged = r.zrevrange("most_engaged_products", 0, 4, withscores=True)
print("أكثر 5 منتجات تفاعلاً:")
for product, score in top_engaged:
 print(f"- {product.decode('utf-8')}: {int(score)} تفاعل")

# استخدام SET لتخزين المستخدمين الذين قاموا بعملية شراء
purchased_users = set()
for event in user_events:
 if event["event_type"] == "purchase":
 purchased_users.add(event["user_id"])

# تخزين المستخدمين الذين قاموا بعملية شراء في Redis SET
r.sadd("purchased_users", *purchased_users)
purchased_count = r.scard("purchased_users")
print(f"عدد المستخدمين الذين قاموا بعملية شراء: {purchased_count}")

// مثال عملي: إدارة جلسات المستخدمين المتعددة باستخدام Redis
const redis = require("redis");
const { v4: uuidv4 } = require("uuid");

// إعداد عميل Redis
const client = redis.createClient({
 url: "redis://localhost:6379"
});

// نموذج بيانات المستخدم
const userData = {
 userId: "user_12345",
 name: "أحمد خالد",
 email: "ahmed@example.com",
 lastLogin: Date.now()
};

// إنشاء جلسة جديدة
async function createSession(userId, deviceInfo) {
 await client.connect();
 
 const sessi uuidv4();
 const sessionData = {
 sessionId,
 userId,
 deviceInfo,
 createdAt: Date.now(),
 lastActivity: Date.now(),
 isActive: true
 };
 
 // تخزين الجلسة في Hash
 await client.hSet(`session:${sessionId}`, sessionData);
 
 // إضافة الجلسة إلى قائمة جلسات المستخدم
 await client.sAdd(`user_sessions:${userId}`, sessionId);
 
 // تعيين انتهاء صلاحية الجلسة بعد 24 ساعة
 await client.expire(`session:${sessionId}`, 86400);
 
 // تحديث آخر وقت نشاط للمستخدم
 await client.hSet(`user:${userId}`, "lastActivity", Date.now());
 
 console.log(`تم إنشاء جلسة جديدة للمستخدم ${userId}: ${sessionId}`);
 await client.quit();
 return sessionId;
}

// تحديث نشاط الجلسة
async function updateSessionActivity(sessionId) {
 await client.connect();
 
 // تحديث آخر وقت نشاط
 await client.hSet(`session:${sessionId}`, "lastActivity", Date.now());
 
 // إعادة تعيين انتهاء الصلاحية
 await client.expire(`session:${sessionId}`, 86400);
 
 // الحصول على userId من الجلسة
 const userId = await client.hGet(`session:${sessionId}`, "userId");
 
 // تحديث آخر وقت نشاط للمستخدم
 await client.hSet(`user:${userId}`, "lastActivity", Date.now());
 
 console.log(`تم تحديث نشاط الجلسة ${sessionId}`);
 await client.quit();
}

// إنهاء جلسة محددة
async function terminateSession(sessionId) {
 await client.connect();
 
 // الحصول على userId قبل حذف الجلسة
 const userId = await client.hGet(`session:${sessionId}`, "userId");
 
 // حذف الجلسة
 await client.del(`session:${sessionId}`);
 
 // إزالة الجلسة من قائمة جلسات المستخدم
 await client.sRem(`user_sessions:${userId}`, sessionId);
 
 console.log(`تم إنهاء الجلسة ${sessionId}`);
 await client.quit();
}

// إنهاء جميع جلسات المستخدم
async function terminateAllUserSessions(userId) {
 await client.connect();
 
 // الحصول على جميع جلسات المستخدم
 const sessions = await client.sMembers(`user_sessions:${userId}`);
 
 // إنهاء كل جلسة
 for (const sessionId of sessions) {
 await client.del(`session:${sessionId}`);
 }
 
 // مسح قائمة الجلسات
 await client.del(`user_sessions:${userId}`);
 
 console.log(`تم إنهاء جميع جلسات المستخدم ${userId}`);
 await client.quit();
}

// استخدام Pub/Sub لإرسال إشعارات لجميع جلسات المستخدم
async function notifyAllUserSessions(userId, message) {
 await client.connect();
 
 // إعداد الناشر
 const publisher = client.duplicate();
 await publisher.connect();
 
 // الحصول على جميع جلسات المستخدم
 const sessions = await client.sMembers(`user_sessions:${userId}`);
 
 // إرسال الإشعار لكل جلسة
 for (const sessionId of sessions) {
 await publisher.publish(`session_notifications:${sessionId}`, JSON.stringify({
 type: "user_notification",
 message,
 timestamp: Date.now()
 }));
 }
 
 console.log(`تم إرسال إشعار إلى جميع جلسات المستخدم ${userId}`);
 await publisher.quit();
 await client.quit();
}

// مثال على الاستخدام
(async () => {
 const session1 = await createSession(userData.userId, {
 device: "mobile",
 os: "iOS",
 ip: "192.168.1.1"
 });
 
 const session2 = await createSession(userData.userId, {
 device: "desktop",
 os: "Windows",
 ip: "192.168.1.2"
 });
 
 await updateSessionActivity(session1);
 
 await notifyAllUserSessions(userData.userId, "تم تحديث بيانات حسابك");
 
 await terminateSession(session1);
 // أو await terminateAllUserSessions(userData.userId);
})();

# أوامر مفيدة لتشخيص مشاكل Redis

# 1. فحص استخدام الذاكرة وتحديد المفاتيح الكبيرة
redis-cli --bigkeys

# 2. مراقبة استخدام الذاكرة في الوقت الفعلي
redis-cli info memory

# 3. فحص العمليات التي تستغرق وقتاً طويلاً
redis-cli --latency-history

# 4. فحص حالة الـ Replication
redis-cli info replication

# 5. فحص الـ Slow Log
redis-cli slowlog get 10

# 6. فحص الـ Clients المتصلين
redis-cli client list

# 7. فحص حالة الـ Persistence
redis-cli info persistence

# 8. فحص الـ CPU Usage
redis-cli info cpu

# 9. فحص الـ Commands التي يتم تنفيذها
redis-cli monitor

# 10. فحص حالة الـ Cluster (إذا كنت تستخدمه)
redis-cli --cluster check <host>:<port>