springboot項(xiàng)目Redis統(tǒng)計(jì)在線用戶的實(shí)現(xiàn)示例
我的項(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)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring Data JPA實(shí)現(xiàn)分頁(yè)P(yáng)ageable的實(shí)例代碼
本篇文章主要介紹了Spring Data JPA實(shí)現(xiàn)分頁(yè)P(yáng)ageable的實(shí)例代碼,具有一定的參考價(jià)值,有興趣的可以了解一下2017-07-07詳解Java并發(fā)編程基礎(chǔ)之volatile
volatile作為Java多線程中輕量級(jí)的同步措施,保證了多線程環(huán)境中“共享變量”的可見(jiàn)性。這里的可見(jiàn)性簡(jiǎn)單而言可以理解為當(dāng)一個(gè)線程修改了一個(gè)共享變量的時(shí)候,另外的線程能夠讀到這個(gè)修改的值。本文將詳解介紹Java并發(fā)編程基礎(chǔ)之volatile2021-06-06淺談在頁(yè)面中獲取到ModelAndView綁定的值方法
下面小編就為大家分享一篇淺談在頁(yè)面中獲取到ModelAndView綁定的值方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2018-03-03springboot redis使用lettuce配置多數(shù)據(jù)源的實(shí)現(xiàn)
這篇文章主要介紹了springboot redis使用lettuce配置多數(shù)據(jù)源的實(shí)現(xiàn),文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04java中instanceof與Class的等價(jià)性代碼示例
這篇文章主要介紹了java中instanceof與Class的等價(jià)性代碼示例,小編覺(jué)得還是挺不錯(cuò)的,具有一定借鑒價(jià)值,需要的朋友可以參考下2018-01-01feign服務(wù)端發(fā)現(xiàn)異??蛻舳颂幚淼姆椒ń榻B
這篇文章主要給大家介紹了關(guān)于feign服務(wù)端發(fā)現(xiàn)異??蛻舳颂幚淼姆椒ǎ闹型ㄟ^(guò)示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用feign具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-07-07