Redis在旅游預訂系統(tǒng)中的作用及應用案例

// 首先嘗試從Redis緩存中獲取城市信息
String cityKey = "city:" + cityId;
String cityInfo = redis.get(cityKey);

if (cityInfo != null) {
    // 如果緩存中存在城市信息，則直接返回
    return cityInfo;
} else {
    // 從數據庫中獲取城市信息
    City city = db.getCity(cityId);

    if (city != null) {
        // 將城市信息存儲到Redis緩存中，設置過期時間為1天
        redis.setex(cityKey, 24 * 3600, city.toString());
        
        return city.toString();
    } else {
        return "城市信息不存在";
    }
}

# 嘗試獲取酒店房間數的分布式鎖
lockKey = "lock:hotel:" + hotelId
lockValue = redis.get(lockKey)

if lockValue is None:
    # 如果鎖不存在，則嘗試獲取鎖
    if redis.set(lockKey, "locked", nx=True, ex=5):
        try:
            # 獲取酒店剩余房間數
            roomCount = db.getRoomCount(hotelId)

            # 更新酒店剩余房間數
            if roomCount > 0:
                db.updateRoomCount(hotelId, roomCount - 1)
        finally:
            # 釋放鎖
            redis.delete(lockKey)

// 將訂單信息放入消息隊列
redis.lpush("order:queue", JSON.stringify(order));

// 后臺工作線程處理消息隊列中的訂單信息
function processOrderQueue() {
    while (true) {
        let order = redis.rpop("order:queue");

        if (order) {
            try {
                // 發(fā)送訂單確認郵件
                sendEmail(order.email, "訂單確認", "您的訂單已確認。");
            } catch (e) {
                // 處理發(fā)送郵件失敗的情況
                console.error("發(fā)送郵件失敗: " + e.message);
            }
        } else {
            // 休眠1秒，避免空循環(huán)
            sleep(1000);
        }
    }
}