業務場景

在一個社交媒體平臺中，我們需要實時統計用戶的點贊數和在線人數。為了滿足實時性和高并發的需求，我們決定使用 Redis 來實現一個實時計數器。

業務需求

• 實時統計用戶的點贊數，以便在用戶界面上顯示點贊數的實時更新。
• 實時統計在線用戶人數，以便在管理后臺實時監控在線用戶的數量。

需求分析

• 計數器需要能夠實時更新，并能夠處理高并發的請求。
• 計數器的數據需要持久化，以防止數據丟失。

實現方案

• 使用 Redis 的計數器功能來存儲和更新點贊數和在線用戶數。
• 使用 Redis 的鍵過期功能來自動清除超時的在線用戶。
• 使用 Redis 的持久化功能，如 AOF 或 RDB，來保證數據的持久性。
• 使用 Redis 的事務功能來確保計數器的原子性更新。

示例代碼

以下是一個簡化的示例代碼，展示了如何使用 Redis 實現實時計數器的關鍵部分：

// 用戶點贊操作
public void likePost(String postId, String userId) {
    Jedis jedis = new Jedis("localhost");
    jedis.incr("post_likes:" + postId);  // 增加點贊數
    jedis.sadd("post_liked_users:" + postId, userId);  // 添加點贊用戶
    jedis.close();
}

// 獲取帖子的點贊數
public long getPostLikes(String postId) {
    Jedis jedis = new Jedis("localhost");
    long likes = Long.parseLong(jedis.get("post_likes:" + postId));
    jedis.close();
    return likes;
}

// 用戶上線操作
public void userOnline(String userId) {
    Jedis jedis = new Jedis("localhost");
    jedis.setex("user_online:" + userId, 300, "true");  // 設置用戶在線標志，并設置過期時間為 300 秒
    jedis.close();
}

// 獲取在線用戶數
public long getOnlineUserCount() {
    Jedis jedis = new Jedis("localhost");
    long count = jedis.keys("user_online:*").size();
    jedis.close();
    return count;
}

在上述示例代碼中，我們使用 Redis 的計數器功能來存儲點贊數，并使用 Redis 的集合數據類型來存儲點贊的用戶。對于在線用戶數的統計，我們使用 Redis 的鍵過期功能來設置用戶在線標志的過期時間，并使用 Redis 的鍵查詢功能來獲取在線用戶數。