我的項(xiàng)目有個(gè)顯示用戶的遺忘曲線，需要統(tǒng)計(jì)在線用戶以計(jì)算他們的曲線

思考了兩種方案，但都是用Redis的bitmap數(shù)據(jù)結(jié)構(gòu)

Bitmap是一種特殊類型的數(shù)組，其中每個(gè)元素只能存儲(chǔ)0或1。在Redis中，Bitmap實(shí)際上是字符串，每個(gè)字符的每一位都被視為一個(gè)獨(dú)立的位，因此一個(gè)字符串可以存儲(chǔ)多達(dá)8*字符串長(zhǎng)度的位。 這段代碼中，markUserActive方法接收一個(gè)用戶ID作為參數(shù)。然后，它創(chuàng)建一個(gè)鍵，該鍵由字符串"active_users:"和當(dāng)前日期組成，格式為ISO_DATE。這樣，每天都會(huì)有一個(gè)新的鍵，用于存儲(chǔ)當(dāng)天活躍的用戶。 然后，它使用redisUtils.setBit方法將用戶ID對(duì)應(yīng)的位設(shè)置為1。這里，用戶ID被用作位的索引。例如，如果用戶ID為10，那么第10位將被設(shè)置為1。 這樣，我們就可以通過(guò)檢查特定位的值來(lái)確定用戶是否活躍。如果位的值為1，那么用戶就是活躍的；如果位的值為0，那么用戶就是不活躍的。 這種方法的優(yōu)點(diǎn)是，它可以在非常小的空間內(nèi)存儲(chǔ)大量的信息。此外，由于Redis是內(nèi)存數(shù)據(jù)庫(kù)，因此這種方法的速度非?？?。

方案一

• 使用心跳包來(lái)追蹤和統(tǒng)計(jì)用戶活躍狀態(tài)，客戶端每隔30分鐘或者一段時(shí)間給服務(wù)端發(fā)送一個(gè)心跳，服務(wù)端獲取到用戶id然后存儲(chǔ)到Redis
• 但這樣的話客戶端要定時(shí)任務(wù)，且依賴客戶端。

方案二

• 在用戶每次請(qǐng)求操作的時(shí)候，由于我后端配置了Shiro的攔截器判斷每次請(qǐng)求是否token過(guò)期，加入標(biāo)記用戶活躍的邏輯，并redis設(shè)置過(guò)期時(shí)間2小時(shí)
• 缺點(diǎn)是資源消耗大，每次請(qǐng)求都要標(biāo)記

@Override
    public void markUserActive(int userId) {
        String key = "active_users:" + LocalDateTime.now().format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
        redisUtils.setBit(key, userId, true);
        // 設(shè)置2小時(shí)的過(guò)期時(shí)間
        redisUtils.expire(key, 2, TimeUnit.HOURS);
    }

markUserActive(int userId) 方法： 這個(gè)方法用于標(biāo)記一個(gè)用戶為活躍狀態(tài)。它接收一個(gè)用戶ID作為參數(shù)。方法首先構(gòu)造一個(gè)鍵，鍵的格式是 “active_users:” 加上當(dāng)前的日期和時(shí)間。然后，它在 Redis 數(shù)據(jù)庫(kù)中將這個(gè)鍵對(duì)應(yīng)的位（由用戶ID指定）設(shè)置為 true，表示該用戶是活躍的。最后，它設(shè)置這個(gè)鍵的過(guò)期時(shí)間為2小時(shí)。這意味著，如果2小時(shí)內(nèi)沒(méi)有再次標(biāo)記該用戶為活躍，那么這個(gè)鍵就會(huì)從 Redis 數(shù)據(jù)庫(kù)中刪除。

@Override
    public List<Integer> getActiveUserIds() {
        List<Integer> activeUserIds = new ArrayList<>();

        // 當(dāng)前時(shí)間
        LocalDateTime currentTime = LocalDateTime.now();
        for (int i = 0; i < 2; i++) {
            // 遍歷過(guò)去2小時(shí)內(nèi)的鍵
            String key = "active_users:" + currentTime.minusHours(i).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);

            if (redisUtils.hasKey(key)) {
                // 遍歷1000個(gè)用戶
                for (int j = 0; j < 1000; j++) {
                    Boolean isUserActive = redisUtils.getBit(key, j);
                    if (isUserActive != null && isUserActive) {
                        activeUserIds.add(j);
                    }
                }
            }
        }

        return activeUserIds;
    }

但是之后測(cè)試的時(shí)候發(fā)現(xiàn)在查找活躍用戶的時(shí)候并沒(méi)有找到，可能是時(shí)間戳精度問(wèn)題，所以修改代碼將其key保留到分鐘形式

String key = "active_users:" + LocalDateTime.now().truncatedTo(ChronoUnit.MINUTES).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);

到此這篇關(guān)于springboot項(xiàng)目Redis統(tǒng)計(jì)在線用戶的實(shí)現(xiàn)示例的文章就介紹到這了,更多相關(guān)springboot Redis統(tǒng)計(jì)在線用戶內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論