2. 程式人生 > >利用Redis BitMap 統計使用者活躍指標

利用Redis BitMap 統計使用者活躍指標

阿新 • • 發佈：2019-02-02
  bitMap原理 :

    如下： index 從 0 到 9 ，依次對應到一個bit位上，如果index 代表使用者id,bit位上的0 1分表 代表使用者是否登入；
  1. 1     0     1     1     0     1     1     0     1     1
  2. 0     1     2     3     4     5     6     7     8     9
複製程式碼

   redis資料結構中 string 型別，包含了對bitmap的實現;在redis-cli中，可以通過setbit getbit 來對bit進行操作；本文通過jedis來對redis進行操作； 


BitSet工具類：實現對通過jedis.get(key)取出的byte[]值與BitSet的轉換


  1. public class BitSetUtils {
  2.     /**
  3.      * 將BitSet物件轉化為ByteArray
  4.      * @param bitSet
  5.      * @return
  6.      */
  7.     public static byte[] bitSet2ByteArray(BitSet bitSet) {
  8.         byte[] bytes = new byte[bitSet.size() / 8];
  9.         for (int i = 0; i < bitSet.size(); i++) {
  10.             int index = i / 8;
  11.             int offset = 7 - i % 8;
  12.             bytes[index] |= (bitSet.get(i) ? 1 : 0) << offset;
  13.         }
  14.         return bytes;
  15.     }
  16.     /**
  17.      * 
  18.      * @param bytes
  19.      * @return
  20.      */
  21.     public static BitSet byteArray2BitSet(byte[] bytes) {
  22.         BitSet bitSet = new BitSet(bytes.length * 8);
  23.         int index = 0;
  24.         for (int i = 0; i < bytes.length; i++) {
  25.             for (int j = 7; j >= 0; j--) {
  26.                 bitSet.set(index++, (bytes[i] & (1 << j)) >> j == 1 ? true
  27.                         : false);
  28.             }
  29.         }
  30.         return bitSet;
  31.     }
  32. }
複製程式碼


    具體對java中BitSet操作，見http://my.oschina.net/cloudcoder/blog/294810 ，該篇對bitSet用法介紹很詳細；

redis工具類：


  1. public class RedisUtil {
  2.     static {
  3.         initPool();
  4.     }
  5.     private static volatile JedisPool jedisPool;
  6.     private static ResourceBundle resourceBundle;
  7.     public static Jedis getResource() {
  8.         return jedisPool.getResource();
  9.     }
  10.     public static void returnResource(Jedis jedis) {
  11.         jedisPool.returnResource(jedis);
  12.     }
  13.     public static void initPool() {
  14.             if(jedisPool != null){
  15.                 return;
  16.             }
  17.             loadProperties();
  18.             String host = resourceBundle.getString("redis.host");
  19.             String passwd= resourceBundle.getString("redis.passwd");
  20.             int port = Integer.parseInt(resourceBundle.getString("redis.port"));
  21.             JedisPoolConfig config = config();
  22.             jedisPool = new JedisPool(config,host,port,60,passwd);
  23.     }
  24.     private static void loadProperties() {
  25.         resourceBundle = ResourceBundle.getBundle("config/redis-config");
  26.     }
  27.     private static JedisPoolConfig config() {
  28.         JedisPoolConfig config = new JedisPoolConfig();
  29.         return config;
  30.     }
  31.     public static void main(String[]args){
  32.        Jedis jedis= RedisUtil.getResource();
  33.        RedisUtil.returnResource(jedis);
  34.     }
  35. }
複製程式碼


1 統計系統中某天使用者登入的情況：以當天日期做為key ,比如 ‘20150410’ ，對應的 bitMap 的 index 用userId來標示，UserId這裡用  long 型表示，如果id不是以0開頭，可以加上相應的偏移量就OK了；如果該天使用者登入，呼叫activeUser方法，來更改bitMap相應index上的標示；


  1. public void activeUser(long userId, String dateKey) {
  2.     Jedis jedis= RedisUtil.getResource();
  3.     try{
  4.         jedis.setbit(dateKey,userId,true);
  5.     }finally {
  6.         RedisUtil.returnResource(jedis);
  7.     }
  8. }
複製程式碼

如果我們想統計該天使用者登入的數量，及登入的使用者id,可以通過如下方法實現：


//該天使用者總數
  1. public long totalCount(String dateKey) {
  2.     Jedis jedis= RedisUtil.getResource();
  3.     try{
  4.         return jedis.bitcount(dateKey);
  5.     }finally {
  6.         RedisUtil.returnResource(jedis);
  7.     }
  8. }
複製程式碼


//該天登入所有的使用者id
  1. public List<Long> activeUserIds(String  dateKey) {
  2.     Jedis jedis= RedisUtil.getResource();
  3.     try{
  4.         if(jedis.get(key)==null){
  5.                  return null;
  6.          }
  7.         BitSet set= BitSetUtils.byteArray2BitSet(jedis.get(key).getBytes());
  8.         List<Long>list=new ArrayList<Long>();
  9.         for (long i=0;i<set.size();i++){
  10.             if(set.get(i)){
  11.                 list.add(i);
  12.             }
  13.         }
  14.         return list;
  15.     }finally {
  16.         RedisUtil.returnResource(jedis);
  17.     }
  18. }
複製程式碼


   2 如果我們想統計n天，連續登入的使用者數，及UserId:


  1. public List<Long> continueActiveUserCount(String... dateKeys) {
  2.     Jedis jedis= RedisUtil.getResource();
  3.     try{
  4.         BitSet all = null;
  5.         for (String key:dateKeys){
  6.              if(jedis.get(key)==null){
  7.                  continue;
  8.              }
  9.              BitSet set= BitSetUtils.byteArray2BitSet(jedis.get(key).getBytes());
  10.              if(all==null){
  11.                  all=set;
  12.              }
  13.              System.out.println(set.size());
  14.              all.and(set);
  15.         }
  16.         List<Long>list=new ArrayList<Long>();
  17.         for (long i=0;i<all.size();i++){
  18.             if(all.get(i)){
  19.                 list.add(i);
  20.             }
  21.         }
  22.         return list;
  23.     }finally {
  24.         RedisUtil.returnResource(jedis);
  25.     }
  26. }
複製程式碼

相關推薦

利用Redis BitMap 統計使用者活躍指標

  bitMap原理 :    如下： index 從 0 到 9 ，依次對應到一個bit位上，如果index 代表使用者id,bit位上的0 1分表 代表使用者是否登入； 1     0     1     1     0     1     1     0     

利用redis和springsession實現線上人數統計

1.springSession相比以前的session機制，好處在於可以實現session共享。 2.通過攔截器（filter要寫在其他攔截器的前面）和裝飾者模式替換原有session機制，不需要改程式碼 3.配置： web.xml applicationcontext.

使用 Redis Bitmap 實現使用者上線次數統計

Bitmap 對於一些特定型別的計算非常有效。 假設現在我們希望記錄自己網站上的使用者的上線頻率，比如說，計算使用者 A 上線了多少天，使用者 B 上線了多少天，諸如此類，以此作為資料，從而決定讓哪些使用者參加 beta 測試等活動 —— 這個模式可以使用 S

Java利用Redis實現消息隊列

.get keys rpo throws max del 鍵值 先進先出 instance 應用場景 為什麽要用redis?二進制存儲、java序列化傳輸、IO連接數高、連接頻繁 一、序列化 　　這裏編寫了一個java序列化的工具,主要是將對象轉化為byte數組,和根

【redis】spring boot利用redis的Keyspace Notifications實現消息通知

客戶 無效 handler mage extend width psu 消息通知 queue 前言 需求：當redis中的某個key失效的時候，把失效時的value寫入數據庫。 github： https://github.com/vergilyn/RedisSampl

利用Redis撤銷JSON Web Token產生的令牌

redis數據庫 pre 是否 pop 實例 撤銷 logo send .post 利用Redis撤銷JSON Web Token產生的令牌 作者：chszs。版權全部。未經允許，不得轉載。博主主頁：http://blog.csdn.net/chszs

利用redis 漏洞入侵挖礦臨時解決辦法

which 入侵 發現 att 找到 服務器ip sent tin fig top 看到一個bashd的進程占據了cpu ps aux |grep bashd cd /tmp 發現ddg.2011 的文件。root dump.rdb 在/root/.ssh 也有奇怪的文

開啟tomcat的apr模式，並利用redis做tomcat7的session的共享。

pen 目錄 b- classname xsl 集群配置 sent permsize ast 更新系統組件 yum -y install readline* xmlto kernel-devel yum* screen vim* psmisc wget lrzsz p

利用redis進行商品秒殺

開始 alt user 返回 num 關於 技術分享 線程 signed 這裏是用redis的list集合開發,redis的list集合是具有原子性的,不必擔心多線程時會取到重復的數據,即使請求同時到達也會排隊進行數據操作 1. 先說說大概思路,關於數據庫庫存字段的設計.數

十一、利用攔截器統計action執行時間

err cep time exceptio execute method current result ack 1.新建login.jsp <body> <a href="HelloAction.action">點擊統計action執行時間

springboot集成springsession利用redis來實現session共享

turn ges setattr work key session IE dmi server 轉：https://www.cnblogs.com/mengmeng89012/p/5519698.html 這次帶來的是spring boot + redis 實現sessi

利用redis主從+keepalived實現高可用

linux 運維 redisRedis簡介： Redis是一個開源的使用ANSI C語言編寫、支持網絡、可基於內存亦可持久化的日誌型、Key-Value數據庫，並提供多種語言的API。從2010年3月15日起，Redis的開發工作由VMware主持。 redis是一個key-value存儲系統。和Memc

redis bitmap實現點贊的思路

用戶 個人 bitmap get tco 圖片 偏移 進制數 允許 bitmap簡介： 　　bitmap時一連串的二進制數字（0,1），每位所在的位置為偏移（offset），在bitmap上可以執行and、or、xor以及其他操作。 位圖計數： 　　位圖計數 的意思是統計b

利用位運算統計文字文件中的漢字字數

在做C++教材練習題時，其中一題要求統計文字文件中的漢字個數，當我直接按char ch做的時候，發現統計出的字數和文字文件的位元組數相同。why? 也就是說，常規方法下統計的實際不是文字文件中的字元個數，而是這些字元的位元組和。 下面是我原先的程式碼： #include <io

利用EXCEL自動統計實驗結果的準確率

我們在做的實驗的時候，通常都需要計算實驗結果的準確率。當時資料量較大時，依靠人工來計算是不現實的，不僅十分慢而極易出錯。如果我們事先將實驗結果檔案進行合理的格式化，則可以利用EXCEL自動進行統計，不僅效率高，也不擔心出錯了。簡單地，利用EXCEL中的自動篩選或分類彙總功能也可實現一些統計，但是

利用Redis鎖解決併發問題

轉發 https://blog.csdn.net/fuyifang/article/details/83008884 用redis處理高併發是個很常見的方式，因為redis的訪問效率很高（直接訪問記憶體），一般我們會用來處理網站一瞬間的併發量。 那如果要使用redis來進行高併發問

遙感影象處理 | 利用GDAL繪製統計直方圖

GDAL獲取直方圖的函式叫做GDALRasterBand::GetHistogram()。定義如下： CPLErrGDALRasterBand::GetHistogram ( double dfMin, double dfMax, int nBuckets, int * panHis

利用Redis實現分散式鎖 使用mysql樂觀鎖解決併發問題

寫在最前面 我在之前總結冪等性的時候，寫過一種分散式鎖的實現，可惜當時沒有真正應用過，著實的心虛啊。正好這段時間對這部分實踐了一下，也算是對之前填坑了。 分散式鎖按照網上的結論，大致分為三種：1、資料庫樂觀鎖； 2、基於Redis的分散式鎖；3.、基於ZooKeeper的分散式鎖； 關於樂觀鎖的實現其實

利用Redis實現分散式鎖

為什麼需要分散式鎖？ 在傳統單體應用單機部署的情況下，可以使用Java併發相關的鎖，如ReentrantLcok或synchronized進行互斥控制。但是，隨著業務發展的需要，原單體單機部署的系統，漸漸的被部署在多機器多JVM上同時提供服務，這使得原單機部署情況下的併發控制鎖策略失效了，為了解決這個問

nginx叢集負責均衡利用redis實現共享session會話狀態,針對tomcat8

當前是隻針對tomcat8的部署， 如果你們的伺服器是tomcat7.x或7以下的版本，請看這個帖子：https://blog.csdn.net/hua1586981/article/details/78132710 目的 搭建好nginx負載均衡後，實現反向代理的叢集功能，當用戶訪問網