一 百萬并發(fā)秒殺概述

1.1 可能遇到問題

1. 在一瞬間服務(wù)出現(xiàn)大量請求，服務(wù)可能會崩潰。
2. 在秒殺商品時候，可能出現(xiàn)超賣。

1.2 秒殺的業(yè)務(wù)流程

1. 秒殺的商品有熱點商品和非熱點商品，熱點商品可能流量占整個的90%.
2. 后臺商品管理可以將商品加入到秒殺商品，根據(jù)商品訪問量分位熱點商品和非熱點商品。
3. 用戶搶到商品支付，發(fā)貨商品。超時不付款，訂單取消。

二 秒殺架構(gòu)

在這里插入圖片描述

我們Java項目時用tomcat部署的。nginx的并發(fā)量能達(dá)到五萬，tomcat最優(yōu)能支持1千。所以首要問題就是讓tomcat直接處理請求，減少tomcat處理請求。
由于商品的詳情頁除了數(shù)量其他基本不改變。因此可以采用詳情頁放到nginx緩存中。還有就是考慮熱點商品的搶購能直接經(jīng)過nginx處理不到服務(wù)端，
這樣就完美解決了問題了。

Lua腳本對JWT校驗
用戶請求到達(dá)nginx，用lua腳本進(jìn)行jwt校驗，減少非法請求對服務(wù)器的訪問。從而減少服務(wù)器壓力。

2.1 靜態(tài)頁面處理

因為秒殺商品的瀏覽量很高，而且商品的描述，價格，圖片，標(biāo)題基本上是不變的。因此考慮用freemarker做商品靜態(tài)化。
所以先考慮靜態(tài)頁面的生成，商品數(shù)量發(fā)生改變靜態(tài)頁面從新生成。

1. 后臺將設(shè)置商品成為秒殺商品流程：

比如京東的秒殺都是一個時間點到另外一個時間點。當(dāng)秒殺的時間點到了，需要從索引庫中刪除對應(yīng)索引和刪除對應(yīng)的靜態(tài)頁面。我們可以在商品添加秒殺時候，
設(shè)置定時任務(wù)。然后定時任務(wù)到達(dá)后執(zhí)行對應(yīng)操作。在添加秒殺時候，更改數(shù)據(jù)庫中商品是處于秒殺，然后生成靜態(tài)頁面。

2. 商品數(shù)量修改，靜態(tài)頁面的同步(canal數(shù)據(jù)同步)：

使用canal對數(shù)據(jù)庫的表進(jìn)行監(jiān)控時候，當(dāng)新增，刪除，編輯表中是數(shù)據(jù)時候，canal都能監(jiān)控到。從而觸發(fā)canal書寫的Java服務(wù)，然后根據(jù)業(yè)務(wù)進(jìn)行靜態(tài)頁面的修改。

3. 靜態(tài)頁面的生成和刪除：

當(dāng)商品變成秒殺商品，生成靜態(tài)頁面。當(dāng)商品賣完或者變?yōu)槠胀ㄉ唐?，刪除靜態(tài)頁面。

2.3 將秒殺熱點數(shù)據(jù)隔離

我們可以根據(jù)商品的瀏覽量判定當(dāng)前商品是否位熱點數(shù)據(jù)。所以需要商品瀏覽記錄收集，和收集瀏覽記錄的分析。

2.3.1 日志收集

用戶訪問商品詳情，首先請求經(jīng)過nginx，然后使用nginx和lua腳本對請求商品詳情路徑進(jìn)行攔截，讓后將請求商品數(shù)據(jù)發(fā)送到kafka。數(shù)據(jù)庫接受到kafka數(shù)據(jù)，完成商品瀏覽數(shù)據(jù)收集。

2.3.2 數(shù)據(jù)分析

Apache Druid訂閱Kafka從而獲取商品的訪問日志，druid能實時獲取商品訪問記錄。druid支持sql，對數(shù)據(jù)進(jìn)行分析。找出熱點數(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ù)如下:商品庫存，價格，名稱等。

備注:
用戶進(jìn)行下單時候，在redis中就是熱點商品，走熱點下單。不在redis中不是熱點商品，走服務(wù)直接下單。

在將熱點商品放到redis中，需要根據(jù)商品的鎖定字段，將商品鎖定。然后再將商品信息放到redis中。用戶搶購商品和熱點商品放到redis中同時進(jìn)行，導(dǎo)致庫存混亂。

2.4 熱點商品和非熱點商品搶購流程

需要判斷當(dāng)前用戶對當(dāng)前商品24小時內(nèi)是否搶過。判斷搶購商品是冷商品還是熱門商品。判斷庫存是否充足。

1. 非熱點商品秒殺：

a 判定為非熱點數(shù)據(jù)，進(jìn)入服務(wù)中進(jìn)行下單系統(tǒng)。
b 對庫存進(jìn)行判斷，如果庫存充足，進(jìn)行下單。如果庫存不充足，事務(wù)回滾。
c 如果庫存充足，但是商品變?yōu)闊狳c商品。應(yīng)將下單操作發(fā)送到kafka,然后變成熱點商品下單操作(防止商品庫存混亂)。
d 記錄該用戶搶的該商品，用于提示該用戶24小時不能搶該商品。

2. 熱點商品秒殺：

a lua腳本進(jìn)行JWT校驗，判斷用戶是否登錄。
b 從redis查詢看該用戶是否搶了該商品(在搶購商品成功后，會將商品和用戶信息存儲到redis中)。
c 從redis熱點商品中查詢，商品是否為熱點商品。如果是熱點商品且?guī)齑?gt;0，熱點商品搶購流程。
d 判斷該用戶該商品是否處于排隊(用redis的incr自增來判斷當(dāng)前用戶該商品是否重復(fù)排隊)。是，提示用戶正在排隊。否，直接排隊。
e 訂單系統(tǒng)通過隊列訂閱讀取用戶下單信息，并進(jìn)行下單。

三 流量監(jiān)控

在秒殺項目中需要集成Sentinel進(jìn)行限流操作。在秒殺過程中冷門商品變?yōu)闊衢T商品時候，訪問服務(wù)流量瞬間激增，需要采用Sentinel進(jìn)行限流，保護(hù)服務(wù)的穩(wěn)定性。