2. 程式人生 > >39、生鮮電商平臺-redis快取在商品中的設計與架構

39、生鮮電商平臺-redis快取在商品中的設計與架構

阿新 • • 發佈：2018-12-02

 說明：Java開源生鮮電商平臺-redis快取在商品中的設計與架構。

1. 各種計數，商品維度計數和使用者維度計數

　　說起電商，肯定離不開商品，而附帶商品有各種計數（喜歡數，評論數，鑑定數，瀏覽數,etc），Redis的命令都是原子性的，你可以輕鬆地利用INCR，DECR等命令來計數。

  • 商品維度計數（喜歡數，評論數，鑑定數，瀏覽數,etc）

　　  採用Redis 的型別: Hash. 如果你對redis資料型別不太熟悉，可以參考 http://redis.io/topics/data-types-intro。為product定義個key product:

，為每種數值定義hashkey, 譬如喜歡數like

   jedis.hset("product:1", "like", "5");
   jedis.hincrBy("product:1", "like", 1);//喜歡加一
   System.out.print(jedis.hget("product:1", "like"));
  • 使用者維度計數（動態數、關注數、粉絲數、喜歡商品數、發帖數 等）

　　   使用者維度計數同商品維度計數都採用 Hash. 為User定義個key user:，為每種數值定義hashkey, 譬如關注數follow

   jedis.hset("user:1", "follow", "5");
   jedis.hincrBy("user:1", "follow", 1);//關注數加一
   System.out.print(jedis.hget("user:1", "follow"));　

2. 儲存社交關係

　　   譬如將使用者的好友/粉絲/關注，可以存在一個sorted set中，score可以是timestamp，這樣求兩個人的共同好友的操作，可能就只需要用求交集命令即可。

複製程式碼 
   jedis.zadd("user:1000:friends", System.currentTimeMillis(), "user:1001");
                             //uid為1000使用者和uid為1001是朋友 , score值設定時間戳
   jedis.zadd("user:1000:friends", System.currentTimeMillis(), "user:1002");
                            //uid為1000使用者和uid為1002是朋友 , score值設定時間戳
        
   jedis.zadd("user:2000:friends", System.currentTimeMillis(), "user:1001");
   jedis.zadd("user:2000:friends", System.currentTimeMillis(), "user:1003");

   jedis.zinterstore("com_friends:1000:2000", "user:1000:friends", "user:2000:friends");
   System.out.println(jedis.zrange("com_friends:1000:2000", 0, -1));
複製程式碼

3. 用作快取代替memcached（商品列表，評論列表，@提示列表，etc）

　      相對memcached 簡單的key-value儲存來說，redis眾多的資料結構（list,set,sorted set,hash, etc）可以更方便cache各種業務資料，效能也不亞於memcached。

4. 反spam系統（評論，釋出商品，論壇發貼，etc）

　　  作為一個電商網站被各種spam攻擊是少不免（垃圾評論、釋出垃圾商品、廣告、刷自家商品排名等），針對這些spam制定一系列anti-spam規則，其中有些規則可以利用redis做實時分

析，譬如：1分鐘評論不得超過2次、5分鐘評論少於5次等（更多機制/規則需要結合drools ）。

　　  採用sorted set將最近一天使用者操作記錄起來（為什麼不全部記錄？節省memory，全部操作會記錄到log，後續利用hadoop進行更全面分析統計）

複製程式碼 
    if(!jedis.exists("user:1000:comment")){//還沒有評論
        jedis.zadd("user:1000:comment", System.currentTimeMillis(), "uid為1000的評論內容");        
        System.out.println(jedis.zrange("user:1000:comment", 0, -1));
    }else{
        //獲取一分鐘內的評論記錄
        Set<String> result = jedis.zrangeByScore("user:1000:comment", System.currentTimeMillis() - 60 * 1000, System.currentTimeMillis());
        if(!result.isEmpty()){
            System.out.println("1分鐘內不能評論兩次");
        }else{
            jedis.zadd("user:1000:comment", System.currentTimeMillis(), "uid為1000的評論內容"+System.currentTimeMillis());
            System.out.println(jedis.zrange("user:1000:comment", 0, -1));
        }
    }
複製程式碼

5. 使用者Timeline/Feeds

　　應用於關注的人、主題、品牌及專欄，redis在這邊主要當作cache使用

    jedis.zadd("user:2000:feed:topic", System.currentTimeMillis(), "13topic" + System.currentTimeMillis());
    //score為timestamp uid為2000的使用者關注tid為13的topic
    jedis.expire("user:2000:feed:topic", 10);
    //關注有效期為10秒
    System.out.println(jedis.zrange("user:2000:feed:topic", 0, -1));

6. 最新列表&排行榜

　　用於記錄使用者剛剛喜歡的商品最新列表or排行榜 等業務場景

複製程式碼 
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "003");
    Thread.currentThread();
    Thread.sleep(10);  
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "001");
    Thread.sleep(10); 
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "004");
    Thread.sleep(10); 
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "002");
    Thread.sleep(10); 
    
    //預設喜歡時間升序排列    
    Set<String> result = jedis.zrange("user:1000:product:like", 0, -1); 
    System.out.println(result);
    
    //按喜歡時間降序排列    
    result = jedis.zrevrange("user:1000:product:like", 0, -1);
    System.out.println(result);
複製程式碼 
[003, 001, 004, 002]
[002, 004, 001, 003]

7. 訊息通知

　　採用Hash結構對訊息通知業務場景計數

複製程式碼 
    //設定1條未讀系統訊息
    jedis.hset("user:1000:message:num", "sysmessagenum", "1");
    jedis.sadd("user:1000:message:content",  "第一條未讀資訊");
    //未讀系統訊息+1
    jedis.hincrBy("user:1000:message:num", "sysmessagenum", 1);
    jedis.sadd("user:1000:message:content", "第二條未讀資訊");
    //檢視所有訊息通知數量
    System.out.println(jedis.hgetAll("user:1000:message:num"));
    //檢視所有訊息通知內容
    System.out.println(jedis.smembers("user:1000:message:content"));
複製程式碼 複製程式碼 
{sysmessagenum=2}
[第二條未讀資訊, 第一條未讀資訊]

Java開源生鮮電商平臺-redis快取在商品中的設計與架構(原始碼可下載）,如果需要下載的話，可以在我的github下面進行下載。  
https://github.com/137071249/

群號：168096884

複製程式碼      

轉載自-- https://www.cnblogs.com/jurendage/p/9181380.html

1. 各種計數，商品維度計數和使用者維度計數

　　說起電商，肯定離不開商品，而附帶商品有各種計數（喜歡數，評論數，鑑定數，瀏覽數,etc），Redis的命令都是原子性的，你可以輕鬆地利用INCR，DECR等命令來計數。

  • 商品維度計數（喜歡數，評論數，鑑定數，瀏覽數,etc）

　　  採用Redis 的型別: Hash. 如果你對redis資料型別不太熟悉，可以參考 http://redis.io/topics/data-types-intro。為product定義個key product:，為每種數值定義hashkey, 譬如喜歡數like

   jedis.hset("product:1", "like", "5");
   jedis.hincrBy("product:1", "like", 1);//喜歡加一
   System.out.print(jedis.hget("product:1", "like"));
  • 使用者維度計數（動態數、關注數、粉絲數、喜歡商品數、發帖數 等）

　　   使用者維度計數同商品維度計數都採用 Hash. 為User定義個key user:，為每種數值定義hashkey, 譬如關注數follow

   jedis.hset("user:1", "follow", "5");
   jedis.hincrBy("user:1", "follow", 1);//關注數加一
   System.out.print(jedis.hget("user:1", "follow"));　

2. 儲存社交關係

　　   譬如將使用者的好友/粉絲/關注，可以存在一個sorted set中，score可以是timestamp，這樣求兩個人的共同好友的操作，可能就只需要用求交集命令即可。

複製程式碼 
   jedis.zadd("user:1000:friends", System.currentTimeMillis(), "user:1001");
                             //uid為1000使用者和uid為1001是朋友 , score值設定時間戳
   jedis.zadd("user:1000:friends", System.currentTimeMillis(), "user:1002");
                            //uid為1000使用者和uid為1002是朋友 , score值設定時間戳
        
   jedis.zadd("user:2000:friends", System.currentTimeMillis(), "user:1001");
   jedis.zadd("user:2000:friends", System.currentTimeMillis(), "user:1003");

   jedis.zinterstore("com_friends:1000:2000", "user:1000:friends", "user:2000:friends");
   System.out.println(jedis.zrange("com_friends:1000:2000", 0, -1));
複製程式碼

3. 用作快取代替memcached（商品列表，評論列表，@提示列表，etc）

　      相對memcached 簡單的key-value儲存來說，redis眾多的資料結構（list,set,sorted set,hash, etc）可以更方便cache各種業務資料，效能也不亞於memcached。

4. 反spam系統（評論，釋出商品，論壇發貼，etc）

　　  作為一個電商網站被各種spam攻擊是少不免（垃圾評論、釋出垃圾商品、廣告、刷自家商品排名等），針對這些spam制定一系列anti-spam規則，其中有些規則可以利用redis做實時分

析，譬如：1分鐘評論不得超過2次、5分鐘評論少於5次等（更多機制/規則需要結合drools ）。

　　  採用sorted set將最近一天使用者操作記錄起來（為什麼不全部記錄？節省memory，全部操作會記錄到log，後續利用hadoop進行更全面分析統計）

複製程式碼 
    if(!jedis.exists("user:1000:comment")){//還沒有評論
        jedis.zadd("user:1000:comment", System.currentTimeMillis(), "uid為1000的評論內容");        
        System.out.println(jedis.zrange("user:1000:comment", 0, -1));
    }else{
        //獲取一分鐘內的評論記錄
        Set<String> result = jedis.zrangeByScore("user:1000:comment", System.currentTimeMillis() - 60 * 1000, System.currentTimeMillis());
        if(!result.isEmpty()){
            System.out.println("1分鐘內不能評論兩次");
        }else{
            jedis.zadd("user:1000:comment", System.currentTimeMillis(), "uid為1000的評論內容"+System.currentTimeMillis());
            System.out.println(jedis.zrange("user:1000:comment", 0, -1));
        }
    }
複製程式碼

5. 使用者Timeline/Feeds

　　應用於關注的人、主題、品牌及專欄，redis在這邊主要當作cache使用

    jedis.zadd("user:2000:feed:topic", System.currentTimeMillis(), "13topic" + System.currentTimeMillis());
    //score為timestamp uid為2000的使用者關注tid為13的topic
    jedis.expire("user:2000:feed:topic", 10);
    //關注有效期為10秒
    System.out.println(jedis.zrange("user:2000:feed:topic", 0, -1));

6. 最新列表&排行榜

　　用於記錄使用者剛剛喜歡的商品最新列表or排行榜 等業務場景

複製程式碼 
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "003");
    Thread.currentThread();
    Thread.sleep(10);  
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "001");
    Thread.sleep(10); 
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "004");
    Thread.sleep(10); 
    jedis.zadd("user:1000:product:like", System.currentTimeMillis(), "002");
    Thread.sleep(10); 
    
    //預設喜歡時間升序排列    
    Set<String> result = jedis.zrange("user:1000:product:like", 0, -1); 
    System.out.println(result);
    
    //按喜歡時間降序排列    
    result = jedis.zrevrange("user:1000:product:like", 0, -1);
    System.out.println(result);
複製程式碼 
[003, 001, 004, 002]
[002, 004, 001, 003]

7. 訊息通知

　　採用Hash結構對訊息通知業務場景計數

複製程式碼 
    //設定1條未讀系統訊息
    jedis.hset("user:1000:message:num", "sysmessagenum", "1");
    jedis.sadd("user:1000:message:content",  "第一條未讀資訊");
    //未讀系統訊息+1
    jedis.hincrBy("user:1000:message:num", "sysmessagenum", 1);
    jedis.sadd("user:1000:message:content", "第二條未讀資訊");
    //檢視所有訊息通知數量
    System.out.println(jedis.hgetAll("user:1000:message:num"));
    //檢視所有訊息通知內容
    System.out.println(jedis.smembers("user:1000:message:content"));
複製程式碼 複製程式碼 
{sysmessagenum=2}
[第二條未讀資訊, 第一條未讀資訊]

Java開源生鮮電商平臺-redis快取在商品中的設計與架構(原始碼可下載）,如果需要下載的話，可以在我的github下面進行下載。  
https://github.com/137071249/

群號：168096884

複製程式碼

相關推薦

39、生鮮電商平臺-redis快取在商品中的設計與架構

 說明：Java開源生鮮電商平臺-redis快取在商品中的設計與架構。 1. 各種計數，商品維度計數和使用者維度計數 　　說起電商，肯定離不開商品，而附帶商品有各種計數（喜歡數，評論數，鑑定數，瀏覽數,etc），Redis的命令都是原子性的，你可以輕鬆地利用INCR，DECR等命令來計數

8、生鮮電商平臺-購物車模塊的設計與架構

等等 method github orm log rtc gif cto dsl 說明：任何一個電商無論是B2C還是B2B都有一個購物車模塊，其中最重要的原因就是客戶需要的東西放在一起，形成一個購物清單，確認是否有問題，然後再進行下單與付款. 1. 購物車數據庫設計：

10、生鮮電商平臺-財務系統模組的設計與架構

前言:任何一個平臺也好，系統也好，掙錢養活團隊這個是無可厚非的，那麼對於一個生鮮B2B平臺盈利模式( 檢視：http://www.cnblogs.com/jurendage/p/9016411.html)而言， 其中財務模組無論是對於買家而言還是賣家而言都至關重要，老百姓對錢的看重是沒有經歷的人想不到的，一

9、生鮮電商平臺-推薦系統模組的設計與架構

業務需求：          對於一個B2B的生鮮電商平臺，對於買家而言，他需要更加快速的購買到自己的產品，跟自己的餐飲店不相關的東西，他是不關心的，而且過多無用的東西摻雜在一起，反而不便 於買家下單，使用者體驗也很差，嚴重的會因此丟了客戶。（客戶覺得太難

26、生鮮電商平臺-RBAC系統許可權的設計與架構

說明:根據上面的需求描述以及對需求的分析，我們得知通常的一箇中小型系統對於許可權系統所需實現的功能以及非功能性的需求，在下面我們將根據需求從技術角度上分析實現的策略以及基於目前兩種比較流行的許可權設計思想來討論關於許可權系統的實現。 1.1.     &nb

16、生鮮電商平臺-監控模塊的設計與架構

stack 方法 tool param nature () contex new ima 說明：Java開源生鮮電商平臺-監控模塊的設計與架構，我們談到監控，一般設計到兩個方面的內容： 1. 服務器本身的監控。(比如：linux服務器的CPU，內存，磁

38、生鮮電商平臺-會員積分系統的設計與架構

說明：網際網路平臺積分體系主要用於激勵和回饋使用者在平臺的消費行為和活動行為，一個良好的積分體系可以很好的提升使用者的粘性及活躍度。 一、網際網路平臺積分體系設計必要性 網際網路平臺積分體系是一個獨立、完整的系統模組，主要用於激勵和回饋使用者在平臺的消費行為和活動行為，通過積分體系可以激發與引導使用者在平

37、生鮮電商平臺-供應鏈模組的設計與架構

說明：Java開源生鮮電商平臺中供應鏈模組屬於賣家的行為，也就是賣家如何管理他們自己的供應商，包括結算方式，壓款方式，結算週期等等，超出了我這個B2B平臺所提供的服務範疇，但是這塊也是非常重要的一塊，只是屬於另外的一個領域，對此我只釋出我自己的看法與見解，包括設計等。    近段時間有

電商平臺-財務系統模組的設計與架構

前言:任何一個平臺也好，系統也好，掙錢養活團隊這個是無可厚非的，那麼對於一個生鮮B2B平臺盈利模式( 檢視： 其中財務模組無論是對於買家而言還是賣家而言都至關重要，老百姓對錢的看重是沒有經歷的人想不到的，一句話說清楚了：一分錢也不能少。   買家或者賣家對財務模組的要求很簡單：

電商平臺-供應鏈模組的設計與架構

說明：Java開源生鮮電商平臺中供應鏈模組屬於賣家的行為，也就是賣家如何管理他們自己的供應商，包括結算方式，壓款方式，結算週期等等，超出了我這個B2B平臺所提供的服務範疇，但是這塊也是非常重要的一塊，只是屬於另外的一個領域，對此我只釋出我自己的看法與見解，包括設計等。    

7、生鮮電商平臺-支付模組的設計與架構

開源生鮮電商平臺支付目前支援支付寶與微信。針對的是APP端（android or IOS）   1。 資料庫表設計。   說明：無論是支付寶還是微信支付，都會有一個服務端的回撥，業務根據回撥的結果處理相應的業務邏輯。         &

6、生鮮電商平臺-訂單表的設計

場景分析說明： 買家（餐館）使用者，通過APP進行選菜，放入購物車，然後下單，最終支付的流程，我們稱為下單過程。 買家可以在張三家買茄子，李四家買蘿蔔，王五家買白菜，趙六家買豬肉等 那麼買家就應該有個訂單主表，我們稱為訂單表，同時還有 上面所說的具體的訂單明細表，清楚的檢視自己買了什麼菜，多少元一斤，買

8、生鮮電商平臺-購物車模組的設計與架構

說明：任何一個電商無論是B2C還是B2B都有一個購物車模組，其中最重要的原因就是客戶需要的東西放在一起，形成一個購物清單，確認是否有問題，然後再進行下單與付款.   1. 購物車資料庫設計：     說明：業務需求：       &n

11、生鮮電商平臺-賬單模組的設計與架構

補充說明：生鮮電商平臺-賬單模組的設計與架構，即使用者的賬單形成過程。   由於系統存在一個押賬功能的需求，（何為押賬，就是形成公司的資金池，類似摩拜單車，ofo單車等等）。目前B2B平臺也是採用押賬的這種功能策略。   這裡有個特別說明的押賬方式：就是比如有個賣家張三，他是5月1

21、生鮮電商平臺-通知模組設計與架構

說明：對於一個生鮮的B2B平臺而言，通知對於我們實際的運營而言來講分為三種方式：           1. 訊息推送：（採用極光推送）           2. 主頁彈窗通知。（比如：現在有什麼新的活動，有

20、生鮮電商平臺-優惠券設計與架構

  說明：現在電商白熱化的程度，無論是生鮮電商還是其他的電商等等，都會有促銷的這個體系，目的就是增加訂單量與知名度等等            那麼對於Java開源生鮮電商平臺而言，我們採用優惠券的這種方式進行促銷。（補貼價格戰對燒錢而言

19、生鮮電商平臺-安全設計與架構

說明：Java開源生鮮電商平臺是一個B2B的生鮮電商平臺，由於是APP的一種模式，所以安全方面一般會思考以下幾個維度：            1.資料安全。             2.

18、生鮮電商平臺-效能優化以及伺服器優化的設計與架構 Java開源生鮮電商平臺-監控模組的設計與架構(原始碼可下載）

說明：Java開源生鮮電商平臺-效能優化以及伺服器優化的設計與架構，我採用以下三種維度來講解           1.  程式碼層面。           2.  資料庫層面。 &nb

25、生鮮電商平臺-原始碼地址公佈與思考和建議

說明：今天是承諾給大家的最後一天，我公佈了github地址（QQ群裡面有）。誠然這個是我的計劃中的事情，但是有以下幾點思考請大家共勉：   1. 你下了那麼多的github程式碼，你學了多少呢？你又學會了多少呢？       github的確是21世紀IT研發人

28、生鮮電商平臺-庫存管理設計與架構

說明：Java開源生鮮電商平臺-庫存管理設計與架構有以下幾個功能   WMS的功能：1、業務批次管理 該功能提供完善的物料批次資訊、批次管理設定、批號編碼規則設定、日常業務處理、報表查詢，以及庫存管理等綜合批次管理功能，使企業進一步完善批次管理，滿足經營管理的需求。 2、保質期管理在批次管理