前言

高並發經常會發生在有大活躍用戶量,用戶高聚集的業務場景中,如:秒殺活動,定時領取紅包等。

為了讓業務可以流暢的運行並且給用戶一個好的交互體驗,我們需要根據業務場景預估達到的並發量等因素,來設計適合自己業務場景的高並發處理方案。

在電商相關產品開發的這些年,我有幸的遇到了並發下的各種坑,這一路摸爬滾打過來有著不少的血淚史,這裡進行的總結,作為自己的歸檔記錄,同時分享給大家。

伺服器架構

業務從發展的初期到逐漸成熟,伺服器架構也是從相對單一到集群,再到分散式服務。

一個可以支持高並發的服務少不了好的伺服器架構,需要有均衡負載,資料庫需要主從集群,nosql緩存需要主從集群,靜態文件需要上傳cdn,這些都是能讓業務程序流暢運行的強大後盾。

伺服器這塊多是需要運維人員來配合搭建,具體我就不多說了,點到為止。

大致需要用到的伺服器架構如下:

  • 伺服器
  • 均衡負載(如:nginx,阿里雲SLB)
  • 資源監控
  • 分散式
  • 資料庫
  • 主從分離,集群
  • DBA 表優化,索引優化,等
  • 分散式
  • nosql
  • 主從分離,集群
  • 主從分離,集群
  • 主從分離,集群
  • redis
  • mongodb
  • memcache
  • cdn
  • html
  • css
  • js
  • image

並發測試

高並發相關的業務,需要進行並發的測試,通過大量的數據分析評估出整個架構可以支撐的並發量。

測試高並發可以使用第三方伺服器或者自己測試伺服器,利用測試工具進行並發請求測試,分析測試數據得到可以支撐並發數量的評估,這個可以作為一個預警參考,俗話說知己自彼百戰不殆。

第三方服務:

  • 阿里雲性能測試

並發測試工具:

  • Apache JMeter
  • Visual Studio性能負載測試
  • Microsoft Web Application Stress Tool

實戰方案

通用方案

日用戶流量大,但是比較分散,偶爾會有用戶高聚的情況;

場景: 用戶簽到,用戶中心,用戶訂單,等

伺服器架構圖:

說明:

場景中的這些業務基本是用戶進入APP後會操作到的,除了活動日(618,雙11,等),這些業務的用戶量都不會高聚集,同時這些業務相關的表都是大數據表,業務多是查詢操作,所以我們需要減少用戶直接命中DB的查詢;優先查詢緩存,如果緩存不存在,再進行DB查詢,將查詢結果緩存起來。

更新用戶相關緩存需要分散式存儲,比如使用用戶ID進行hash分組,把用戶分布到不同的緩存中,這樣一個緩存集合的總量不會很大,不會影響查詢效率。

方案如:

  • 用戶簽到獲取積分
  • 計算出用戶分布的key,redis hash中查找用戶今日簽到信息
  • 如果查詢到簽到信息,返回簽到信息
  • 如果沒有查詢到,DB查詢今日是否簽到過,如果有簽到過,就把簽到信息同步redis緩存。
  • 如果DB中也沒有查詢到今日的簽到記錄,就進行簽到邏輯,操作DB添加今日簽到記錄,添加簽到積分(這整個DB操作是一個事務)
  • 緩存簽到信息到redis,返回簽到信息
  • 注意這裡會有並發情況下的邏輯問題,如:一天簽到多次,發放多次積分給用戶。

  • 用戶訂單
  • 這裡我們只緩存用戶第一頁的訂單信息,一頁40條數據,用戶一般也只會看第一頁的訂單數據
  • 用戶訪問訂單列表,如果是第一頁讀緩存,如果不是讀DB
  • 計算出用戶分布的key,redis hash中查找用戶訂單信息
  • 如果查詢到用戶訂單信息,返回訂單信息
  • 如果不存在就進行DB查詢第一頁的訂單數據,然後緩存redis,返回訂單信息

  • 用戶中心
  • 計算出用戶分布的key,redis hash中查找用戶訂單信息
  • 如果查詢到用戶信息,返回用戶信息
  • 如果不存在進行用戶DB查詢,然後緩存redis,返回用戶信息

  • 其他業務
  • 上面例子多是針對用戶存儲緩存,如果是公用的緩存數據需要注意一些問題,如下
  • 注意公用的緩存數據需要考慮並發下的可能會導致大量命中DB查詢,可以使用管理後台更新緩存,或者DB查詢的鎖住操作。

以上例子是一個相對簡單的高並發架構,並發量不是很高的情況可以很好的支撐,但是隨著業務的壯大,用戶並發量增加,我們的架構也會進行不斷的優化和演變,比如對業務進行服務化,每個服務有自己的並發架構,自己的均衡伺服器,分散式資料庫,nosql主從集群,如:用戶服務、訂單服務;

消息隊列

秒殺、秒搶等活動業務,用戶在瞬間湧入產生高並發請求

場景:定時領取紅包,等

伺服器架構圖:伺服器架構圖:

說明:

場景中的定時領取是一個高並發的業務,像秒殺活動用戶會在到點的時間湧入,DB瞬間就接受到一記暴擊,hold不住就會宕機,然後影響整個業務;

像這種不是只有查詢的操作並且會有高並發的插入或者更新數據的業務,前面提到的通用方案就無法支撐,並發的時候都是直接命中DB;

設計這塊業務的時候就會使用消息隊列的,可以將參與用戶的信息添加到消息隊列中,然後再寫個多線程程序去消耗隊列,給隊列中的用戶發放紅包;

方案如:

  • 定時領取紅包
  • 一般習慣使用 redis的 list
  • 當用戶參與活動,將用戶參與信息push到隊列中
  • 然後寫個多線程程序去pop數據,進行發放紅包的業務
  • 這樣可以支持高並發下的用戶可以正常的參與活動,並且避免資料庫伺服器宕機的危險

附加:

通過消息隊列可以做很多的服務。

如:定時簡訊發送服務,使用sset(sorted set),發送時間戳作為排序依據,簡訊數據隊列根據時間升序,然後寫個程序定時循環去讀取sset隊列中的第一條,當前時間是否超過發送時間,如果超過就進行簡訊發送。

一級緩存

高並發請求連接緩存伺服器超出伺服器能夠接收的請求連接量,部分用戶出現建立連接超時無法讀取到數據的問題;

因此需要有個方案當高並發時候時候可以減少命中緩存伺服器;

這時候就出現了一級緩存的方案,一級緩存就是使用站點伺服器緩存去存儲數據,注意只存儲部分請求量大的數據,並且緩存的數據量要控制,不能過分的使用站點伺服器的內存而影響了站點應用程序的正常運行,一級緩存需要設置秒單位的過期時間,具體時間根據業務場景設定,目的是當有高並發請求的時候可以讓數據的獲取命中到一級緩存,而不用連接緩存nosql數據伺服器,減少nosql數據伺服器的壓力

比如APP首屏商品數據介面,這些數據是公共的不會針對用戶自定義,而且這些數據不會頻繁的更新,像這種介面的請求量比較大就可以加入一級緩存;

伺服器架構圖:

合理的規範和使用nosql緩存資料庫,根據業務拆分緩存資料庫的集群,這樣基本可以很好支持業務,一級緩存畢竟是使用站點伺服器緩存所以還是要善用。

靜態化數據

高並發請求數據不變化的情況下如果可以不請求自己的伺服器獲取數據那就可以減少伺服器的資源壓力。

對於更新頻繁度不高,並且數據允許短時間內的延遲,可以通過數據靜態化成JSON,XML,HTML等數據文件上傳CDN,在拉取數據的時候優先到CDN拉取,如果沒有獲取到數據再從緩存,資料庫中獲取,當管理人員操作後台編輯數據再重新生成靜態文件上傳同步到CDN,這樣在高並發的時候可以使數據的獲取命中在CDN伺服器上。

CDN節點同步有一定的延遲性,所以找一個靠譜的CDN伺服器商也很重要

其他方案

  • 對於更新頻繁度不高的數據,APP,PC瀏覽器,可以緩存數據到本地,然後每次請求介面的時候上傳當前緩存數據的版本號,服務端接收到版本號判斷版本號與最新數據版本號是否一致,如果不一樣就進行最新數據的查詢並返回最新數據和最新版本號,如果一樣就返回狀態碼告知數據已經是最新。減少伺服器壓力:資源、帶寬

針對上面的技術我特意整理了一下,有很多技術不是靠幾句話能講清楚,所以乾脆找朋友錄製了一些視頻,很多問題其實答案很簡單,但是背後的思考和邏輯不簡單,要做到知其然還要知其所以然。如果想學習Java工程化、高性能及分散式、深入淺出。微服務、Spring,MyBatis,Netty源碼分析的朋友可以加我的Java進階群:433540541,群里有阿里大牛直播講解技術,以及Java大型互聯網技術的視頻免費分享給大家。

分層,分割,分散式

大型網站要很好支撐高並發,這是需要長期的規劃設計

在初期就需要把系統進行分層,在發展過程中把核心業務進行拆分成模塊單元,根據需求進行分散式部署,可以進行獨立團隊維護開發。

  • 分層
  • 將系統在橫向維度上切分成幾個部分,每個部門負責一部分相對簡單並比較單一的職責,然後通過上層對下層的依賴和調度組成一個完整的系統
  • 比如把電商系統分成:應用層,服務層,數據層。(具體分多少個層次根據自己的業務場景)
  • 應用層:網站首頁,用戶中心,商品中心,購物車,紅包業務,活動中心等,負責具體業務和視圖展示
  • 服務層:訂單服務,用戶管理服務,紅包服務,商品服務等,為應用層提供服務支持
  • 數據層:關係資料庫,nosql資料庫 等,提供數據存儲查詢服務
  • 分層架構是邏輯上的,在物理部署上可以部署在同一台物理機器上,但是隨著網站業務的發展,必然需要對已經分層的模塊分離部署,分別部署在不同的伺服器上,使網站可以支撐更多用戶訪問

  • 分割
  • 在縱向方面對業務進行切分,將一塊相對複雜的業務分割成不同的模塊單元
  • 包裝成高內聚低耦合的模塊不僅有助於軟體的開發維護,也便於不同模塊的分散式部署,提高網站的並發處理能力和功能擴展
  • 比如用戶中心可以分割成:賬戶信息模塊,訂單模塊,充值模塊,提現模塊,優惠券模塊等

  • 分散式
  • 分散式應用和服務,將分層或者分割後的業務分散式部署,獨立的應用伺服器,資料庫,緩存伺服器
  • 當業務達到一定用戶量的時候,再進行伺服器均衡負載,資料庫,緩存主從集群
  • 分散式靜態資源,比如:靜態資源上傳cdn
  • 分散式計算,比如:使用hadoop進行大數據的分散式計算
  • 分散式數據和存儲,比如:各分布節點根據哈希演算法或其他演算法分散存儲數據

網站分層-圖1來自網路

集群

對於用戶訪問集中的業務獨立部署伺服器,應用伺服器,資料庫,nosql資料庫。 核心業務基本上需要搭建集群,即多台伺服器部署相同的應用構成一個集群,通過負載均衡設備共同對外提供服務, 伺服器集群能夠為相同的服務提供更多的並發支持,因此當有更多的用戶訪問時,只需要向集群中加入新的機器即可, 另外可以實現當其中的某台伺服器發生故障時,可以通過負載均衡的失效轉移機制將請求轉移至集群中其他的伺服器上,因此可以提高系統的可用性

  • 應用伺服器集群
  • nginx 反向代理
  • slb
  • … …
  • (關係/nosql)資料庫集群
  • 主從分離,從庫集群

通過反向代理均衡負載-圖2來自網路

非同步

在高並發業務中如果涉及到資料庫操作,主要壓力都是在資料庫伺服器上面,雖然使用主從分離,但是資料庫操作都是在主庫上操作,單台資料庫伺服器連接池允許的最大連接數量是有限的

當連接數量達到最大值的時候,其他需要連接數據操作的請求就需要等待有空閑的連接,這樣高並發的時候很多請求就會出現connection time out 的情況

那麼像這種高並發業務我們要如何設計開發方案可以降低資料庫伺服器的壓力呢?

  • 如:
  • 自動彈窗簽到,雙11跨0點的時候並發請求籤到介面
  • 雙11搶紅包活動
  • 雙11訂單入庫

  • 設計考慮:
  • 逆向思維,壓力在資料庫,那業務介面就不進行資料庫操作不就沒壓力了
  • 數據持久化是否允許延遲?
  • 如何讓業務介面不直接操作DB,又可以讓數據持久化?

  • 方案設計:
  • 像這種涉及資料庫操作的高並發的業務,就要考慮使用非同步了
  • 客戶端發起介面請求,服務端快速響應,客戶端展示結果給用戶,資料庫操作通過非同步同步
  • 如何實現非同步同步?
  • 使用消息隊列,將入庫的內容enqueue到消息隊列中,業務介面快速響應給用戶結果(可以溫馨提示高峰期延遲到賬)
  • 然後再寫個獨立程序從消息隊列dequeue數據出來進行入庫操作,入庫成功後刷新用戶相關緩存,如果入庫失敗記錄日誌,方便反饋查詢和重新持久化
  • 這樣一來資料庫操作就只有一個程序(多線程)來完成,不會給數據帶來壓力

  • 補充:
  • 消息隊列除了可以用在高並發業務,其他只要有相同需求的業務也是可以使用,如:簡訊發送中間件等
  • 高並發下非同步持久化數據可能會影響用戶的體驗,可以通過可配置的方式,或者自動化監控資源消耗來切換時時或者使用非同步,這樣在正常流量的情況下可以使用時時操作資料庫來提高用戶體驗
  • 非同步同時也可以指編程上的非同步函數,非同步線程,在有的時候可以使用非同步操作,把不需要等待結果的操作放到非同步中,然後繼續後面的操作,節省了等待的這部分操作的時間

緩存

高並發業務介面多數都是進行業務數據的查詢,如:商品列表,商品信息,用戶信息,紅包信息等,這些數據都是不會經常變化,並且持久化在資料庫中

高並發的情況下直接連接從庫做查詢操作,多台從庫伺服器也抗不住這麼大量的連接請求數(前面說過,單台資料庫伺服器允許的最大連接數量是有限的)

那麼我們在這種高並發的業務介面要如何設計呢?

  • 設計考慮:
  • 還是逆向思維,壓力在資料庫,那麼我們就不進行資料庫查詢
  • 數據不經常變化,我們為啥要一直查詢DB?
  • 數據不變化客戶端為啥要向伺服器請求返回一樣的數據?

  • 方案設計:
  • 數據不經常變化,我們可以把數據進行緩存,緩存的方式有很多種,一般的:應用伺服器直接Cache內存,主流的:存儲在memcache、redis內存資料庫
  • Cache是直接存儲在應用伺服器中,讀取速度快,內存資料庫伺服器允許連接數可以支撐到很大,而且數據存儲在內存,讀取速度快,再加上主從集群,可以支撐很大的並發查詢
  • 根據業務情景,使用配合客戶端本地存,如果我們數據內容不經常變化,為啥要一直請求伺服器獲取相同數據,可以通過匹配數據版本號,如果版本號不一樣介面重新查詢緩存返回數據和版本號,如果一樣則不查詢數據直接響應
  • 這樣不僅可以提高介面響應速度,也可以節約伺服器帶寬,雖然有些伺服器帶寬是按流量計費,但是也不是絕對無限的,在高並發的時候伺服器帶寬也可能導致請求響應慢的問題

  • 補充:
  • 緩存同時也指靜態資源客戶端緩存
  • cdn緩存,靜態資源通過上傳cdn,cdn節點緩存我們的靜態資源,減少伺服器壓力

面向服務

  • SOA面向服務架構設計
  • 微服務更細粒度服務化,一系列的獨立的服務共同組成系統

使用服務化思維,將核心業務或者通用的業務功能抽離成服務獨立部署,對外提供介面的方式提供功能。

最理想化的設計是可以把一個複雜的系統抽離成多個服務,共同組成系統的業務,優點:松耦合,高可用性,高伸縮性,易維護。

通過面向服務化設計,獨立伺服器部署,均衡負載,資料庫集群,可以讓服務支撐更高的並發

  • 服務例子:
  • 用戶行為跟蹤記錄統計

  • 說明:
  • 通過上報應用模塊,操作事件,事件對象,等數據,記錄用戶的操作行為
  • 比如:記錄用戶在某個商品模塊,點擊了某一件商品,或者瀏覽了某一件商品

  • 背景:
  • 由於服務需要記錄用戶的各種操作行為,並且可以重複上報,準備接入服務的業務又是核心業務的用戶行為跟蹤,所以請求量很大,高峰期會產生大量並發請求。

  • 架構:
  • nodejs WEB應用伺服器均衡負載
  • redis主從集群
  • mysql主
  • nodejs+express+ejs+redis+mysql
  • 服務端採用nodejs,nodejs是單進程(PM2根據cpu核數開啟多個工作進程),採用事件驅動機制,適合I/O密集型業務,處理高並發能力強

  • 業務設計:
  • 並發量大,所以不能直接入庫,採用:非同步同步數據,消息隊列
  • 請求介面上報數據,介面將上報數據push到redis的list隊列中
  • nodejs寫入庫腳本,循環pop redis list數據,將數據存儲入庫,並進行相關統計Update,無數據時sleep幾秒
  • 因為數據量會比較大,上報的數據表按天命名存儲

  • 介面:
  • 上報數據介面
  • 統計查詢介面

  • 上線跟進:
  • 服務業務基本正常
  • 每天的上報表有上千萬的數據

冗餘,自動化

當高並發業務所在的伺服器出現宕機的時候,需要有備用伺服器進行快速的替代,在應用伺服器壓力大的時候可以快速添加機器到集群中,所以我們就需要有備用機器可以隨時待命。 最理想的方式是可以通過自動化監控伺服器資源消耗來進行報警,自動切換降級方案,自動的進行伺服器替換和添加操作等,通過自動化可以減少人工的操作的成本,而且可以快速操作,避免人為操作上面的失誤。

  • 冗餘
  • 資料庫備份
  • 備用伺服器
  • 自動化
  • 自動化監控
  • 自動化報警
  • 自動化降級

通過GitLab事件,我們應該反思,做了備份數據並不代表就萬無一失了,我們需要保證高可用性,首先備份是否正常進行,備份數據是否可用,需要我們進行定期的檢查,或者自動化監控, 還有包括如何避免人為上的操作失誤問題。(不過事件中gitlab的開放性姿態,積極的處理方式還是值得學習的)

總結

高並發架構是一個不斷衍變的過程,冰洞三尺非一日之寒,長城築成非一日之功 。

打好基礎架構方便以後的拓展,這點很重要。


推薦閱讀:
相关文章