springboot項目Redis統(tǒng)計在線用戶的實現(xiàn)示例
我的項目有個顯示用戶的遺忘曲線,需要統(tǒng)計在線用戶以計算他們的曲線
思考了兩種方案,但都是用Redis的bitmap數(shù)據(jù)結(jié)構(gòu)
Bitmap是一種特殊類型的數(shù)組,其中每個元素只能存儲0或1。在Redis中,Bitmap實際上是字符串,每個字符的每一位都被視為一個獨立的位,因此一個字符串可以存儲多達8*字符串長度的位。 這段代碼中,markUserActive方法接收一個用戶ID作為參數(shù)。然后,它創(chuàng)建一個鍵,該鍵由字符串"active_users:"和當(dāng)前日期組成,格式為ISO_DATE。這樣,每天都會有一個新的鍵,用于存儲當(dāng)天活躍的用戶。 然后,它使用redisUtils.setBit方法將用戶ID對應(yīng)的位設(shè)置為1。這里,用戶ID被用作位的索引。例如,如果用戶ID為10,那么第10位將被設(shè)置為1。 這樣,我們就可以通過檢查特定位的值來確定用戶是否活躍。如果位的值為1,那么用戶就是活躍的;如果位的值為0,那么用戶就是不活躍的。 這種方法的優(yōu)點是,它可以在非常小的空間內(nèi)存儲大量的信息。此外,由于Redis是內(nèi)存數(shù)據(jù)庫,因此這種方法的速度非??臁?/p>
方案一
- 使用心跳包來追蹤和統(tǒng)計用戶活躍狀態(tài),客戶端每隔30分鐘或者一段時間給服務(wù)端發(fā)送一個心跳,服務(wù)端獲取到用戶id然后存儲到Redis
- 但這樣的話客戶端要定時任務(wù),且依賴客戶端。
方案二
- 在用戶每次請求操作的時候,由于我后端配置了Shiro的攔截器判斷每次請求是否token過期,加入標(biāo)記用戶活躍的邏輯,并redis設(shè)置過期時間2小時
- 缺點是資源消耗大,每次請求都要標(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小時的過期時間 redisUtils.expire(key, 2, TimeUnit.HOURS); }
markUserActive(int userId) 方法: 這個方法用于標(biāo)記一個用戶為活躍狀態(tài)。它接收一個用戶ID作為參數(shù)。方法首先構(gòu)造一個鍵,鍵的格式是 “active_users:” 加上當(dāng)前的日期和時間。然后,它在 Redis 數(shù)據(jù)庫中將這個鍵對應(yīng)的位(由用戶ID指定)設(shè)置為 true,表示該用戶是活躍的。最后,它設(shè)置這個鍵的過期時間為2小時。這意味著,如果2小時內(nèi)沒有再次標(biāo)記該用戶為活躍,那么這個鍵就會從 Redis 數(shù)據(jù)庫中刪除。
@Override public List<Integer> getActiveUserIds() { List<Integer> activeUserIds = new ArrayList<>(); // 當(dāng)前時間 LocalDateTime currentTime = LocalDateTime.now(); for (int i = 0; i < 2; i++) { // 遍歷過去2小時內(nèi)的鍵 String key = "active_users:" + currentTime.minusHours(i).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME); if (redisUtils.hasKey(key)) { // 遍歷1000個用戶 for (int j = 0; j < 1000; j++) { Boolean isUserActive = redisUtils.getBit(key, j); if (isUserActive != null && isUserActive) { activeUserIds.add(j); } } } } return activeUserIds; }
但是之后測試的時候發(fā)現(xiàn)在查找活躍用戶的時候并沒有找到,可能是時間戳精度問題,所以修改代碼將其key保留到分鐘形式
String key = "active_users:" + LocalDateTime.now().truncatedTo(ChronoUnit.MINUTES).format(DateTimeFormatter.ISO_LOCAL_DATE_TIME);
到此這篇關(guān)于springboot項目Redis統(tǒng)計在線用戶的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)springboot Redis統(tǒng)計在線用戶內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring Data JPA實現(xiàn)分頁Pageable的實例代碼
本篇文章主要介紹了Spring Data JPA實現(xiàn)分頁Pageable的實例代碼,具有一定的參考價值,有興趣的可以了解一下2017-07-07詳解Java并發(fā)編程基礎(chǔ)之volatile
volatile作為Java多線程中輕量級的同步措施,保證了多線程環(huán)境中“共享變量”的可見性。這里的可見性簡單而言可以理解為當(dāng)一個線程修改了一個共享變量的時候,另外的線程能夠讀到這個修改的值。本文將詳解介紹Java并發(fā)編程基礎(chǔ)之volatile2021-06-06springboot redis使用lettuce配置多數(shù)據(jù)源的實現(xiàn)
這篇文章主要介紹了springboot redis使用lettuce配置多數(shù)據(jù)源的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04feign服務(wù)端發(fā)現(xiàn)異常客戶端處理的方法介紹
這篇文章主要給大家介紹了關(guān)于feign服務(wù)端發(fā)現(xiàn)異??蛻舳颂幚淼姆椒?,文中通過示例代碼介紹的非常詳細,對大家學(xué)習(xí)或者使用feign具有一定的參考學(xué)習(xí)價值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2019-07-07