建站
咨詢
售后
建站咨詢
新聞中心
一 百萬并發(fā)秒殺概述
1.1 可能遇到問題
在一瞬間服務(wù)出現(xiàn)大量請求，服務(wù)可能會崩潰。
創(chuàng)新互聯(lián)公司，是一家集策劃、設(shè)計、技術(shù)開發(fā)一體的專業(yè)互聯(lián)網(wǎng)產(chǎn)品服務(wù)公司，致力于為企業(yè)信息化提供驅(qū)動力。技術(shù)團隊10多年來致力于為客戶提供企業(yè)網(wǎng)站定制，手機網(wǎng)站開發(fā)。先后服務(wù)了千余家客戶，包括各類中小企業(yè)、高校、政府。 創(chuàng)新互聯(lián)公司將利用公司在過去10多年的資源積累，力爭為客戶打造真正革命性的口碑產(chǎn)品！
在秒殺商品時候，可能出現(xiàn)超賣。
1.2 秒殺的業(yè)務(wù)流程
秒殺的商品有熱點商品和非熱點商品，熱點商品可能流量占整個的90%.
后臺商品管理可以將商品加入到秒殺商品，根據(jù)商品訪問量分位熱點商品和非熱點商品。
用戶搶到商品支付，發(fā)貨商品。超時不付款，訂單取消。
二 秒殺架構(gòu)
秒殺系統(tǒng)架構(gòu)圖
- 我們Java項目時用tomcat部署的。nginx的并發(fā)量能達到五萬，tomcat最優(yōu)能支持1千。所以首要問題就是讓tomcat直接處理請求，減少tomcat處理請求。由于商品的詳情頁除了數(shù)量其他基本不改變。因此可以采用詳情頁放到nginx緩存中。還有就是考慮熱點商品的搶購能直接經(jīng)過nginx處理不到服務(wù)端，這樣就完美解決了問題了。
Lua腳本對JWT校驗：
用戶請求到達nginx，用lua腳本進行jwt校驗，減少非法請求對服務(wù)器的訪問。從而減少服務(wù)器壓力。
2.1 靜態(tài)頁面處理
- 因為秒殺商品的瀏覽量很高，而且商品的描述，價格，圖片，標題基本上是不變的。因此考慮用freemarker做商品靜態(tài)化。所以先考慮靜態(tài)頁面的生成，商品數(shù)量發(fā)生改變靜態(tài)頁面從新生成。
1. 后臺將設(shè)置商品成為秒殺商品流程：
- 比如京東的秒殺都是一個時間點到另外一個時間點。當秒殺的時間點到了，需要從索引庫中刪除對應(yīng)索引和刪除對應(yīng)的靜態(tài)頁面。我們可以在商品添加秒殺時候，設(shè)置定時任務(wù)。然后定時任務(wù)到達后執(zhí)行對應(yīng)操作。在添加秒殺時候，更改數(shù)據(jù)庫中商品是處于秒殺，然后生成靜態(tài)頁面。
2. 商品數(shù)量修改，靜態(tài)頁面的同步(canal數(shù)據(jù)同步)：
- 使用canal對數(shù)據(jù)庫的表進行監(jiān)控時候，當新增，刪除，編輯表中是數(shù)據(jù)時候，canal都能監(jiān)控到。從而觸發(fā)canal書寫的Java服務(wù)，然后根據(jù)業(yè)務(wù)進行靜態(tài)頁面的修改。
3. 靜態(tài)頁面的生成和刪除：
- 當商品變成秒殺商品，生成靜態(tài)頁面。當商品賣完或者變?yōu)槠胀ㄉ唐?，刪除靜態(tài)頁面。
2.3 將秒殺熱點數(shù)據(jù)隔離
- 我們可以根據(jù)商品的瀏覽量判定當前商品是否位熱點數(shù)據(jù)。所以需要商品瀏覽記錄收集，和收集瀏覽記錄的分析。
2.3.1 日志收集
用戶訪問商品詳情，首先請求經(jīng)過nginx，然后使用nginx和lua腳本對請求商品詳情路徑進行攔截，然后將請求商品數(shù)據(jù)發(fā)送到kafka。數(shù)據(jù)庫接受到kafka數(shù)據(jù)，完成商品瀏覽數(shù)據(jù)收集。
2.3.2 數(shù)據(jù)分析
Apache Druid訂閱Kafka從而獲取商品的訪問日志，druid能實時獲取商品訪問記錄。druid支持sql，對數(shù)據(jù)進行分析。找出熱點數(shù)據(jù)。
- # lua腳本發(fā)送給kafka日志格式
- {
- "actime": "2020‐4‐10 9:50:30",
- "uri": "http://192.168.211.137/items/S1235433012716498944.html",
- "ip": "119.123.33.231",
- "token": "Bearer ITHEIMAOOPJAVAITCAST"
- }
2.3.3 熱點數(shù)據(jù)隔離
可以采用定時任務(wù)(elastic-job)實時查詢Druid,把近期訪問量最多的商品放入redis緩存中。緩存中數(shù)據(jù)如下:商品庫存，價格，名稱等。
備注:
用戶進行下單時候，在redis中就是熱點商品，走熱點下單。不在redis中不是熱點商品，走服務(wù)直接下單。
在將熱點商品放到redis中，需要根據(jù)商品的鎖定字段，將商品鎖定。然后再將商品信息放到redis中。用戶搶購商品和熱點商品放到redis中同時進行，導(dǎo)致庫存混亂。
2.4 熱點商品和非熱點商品搶購流程
需要判斷當前用戶對當前商品24小時內(nèi)是否搶過。判斷搶購商品是冷商品還是熱門商品。判斷庫存是否充足。
1. 非熱點商品秒殺：
- a 判定為非熱點數(shù)據(jù)，進入服務(wù)中進行下單系統(tǒng)。
- b 對庫存進行判斷，如果庫存充足，進行下單。如果庫存不充足，事務(wù)回滾。
- c 如果庫存充足，但是商品變?yōu)闊狳c商品。應(yīng)將下單操作發(fā)送到kafka,然后變成熱點商品下單操作(防止商品庫存混亂)。
- d 記錄該用戶搶的該商品，用于提示該用戶24小時不能搶該商品。
2. 熱點商品秒殺：
- a lua腳本進行JWT校驗，判斷用戶是否登錄。
- b 從redis查詢看該用戶是否搶了該商品(在搶購商品成功后，會將商品和用戶信息存儲到redis中)。
- c 從redis熱點商品中查詢，商品是否為熱點商品。如果是熱點商品且?guī)齑?0，熱點商品搶購流程。
- d 判斷該用戶該商品是否處于排隊(用redis的incr自增來判斷當前用戶該商品是否重復(fù)排隊)。是，提示用戶正在排隊。否，直接排隊。e 訂單系統(tǒng)通過隊列訂閱讀取用戶下單信息，并進行下單。
三 流量監(jiān)控
在秒殺項目中需要集成Sentinel進行限流操作。在秒殺過程中冷門商品變?yōu)闊衢T商品時候，訪問服務(wù)流量瞬間激增，需要采用Sentinel進行限流，保護服務(wù)的穩(wěn)定性。
本文名稱：100W并發(fā)秒殺系統(tǒng)架構(gòu)
地址分享：http://www.5511xx.com/article/ccejhsp.html
