1、消息隊(duì)列(以下簡稱MQ)天生就是處理高并發(fā)的有力工具,因?yàn)樗梢园岩粋€(gè)完整的流程拆為多部分,并發(fā)進(jìn)行,或者不是很重要的步驟模塊延遲進(jìn)行。大家所熟悉的是消息隊(duì)列在大基數(shù)用戶項(xiàng)目的注冊模塊和電商項(xiàng)目的訂單模塊運(yùn)用的比較多,淘寶就是最好的案例。但是這里并不是想要介紹這個(gè),而是想簡談一下消息隊(duì)列處理拼團(tuán)秒殺活動的高并發(fā)的運(yùn)用:
【1】秒殺活動有個(gè)特點(diǎn),就是在某個(gè)特定的時(shí)間點(diǎn),并發(fā)請求量特別大,峰值遠(yuǎn)遠(yuǎn)高于平常,所以秒殺應(yīng)用服務(wù)器就有可能承受不了這么大的并發(fā)而導(dǎo)致系統(tǒng)崩潰;
【2】這個(gè)時(shí)候就可以考慮使用MQ,MQ在這里可以起到削減高峰流量的作用,實(shí)現(xiàn)場景是搭一個(gè)MQ服務(wù)器,擋在秒殺應(yīng)用服務(wù)器前面,承受這個(gè)大量的請求數(shù),然后再把符合條件的前多少個(gè)請求發(fā)送到應(yīng)用服務(wù)器,去正常消費(fèi)庫存,MQ在這個(gè)流程中做了三件事:收集請求-->篩選過濾請求-->發(fā)送符合條件請求/返回秒殺失敗信息給不符合條件的請求者,其中"返回秒殺失敗信息給不符合條件的請求者"這個(gè)可以最后來做,往大的方向來說就是轉(zhuǎn)發(fā)請求;
【3】舉個(gè)實(shí)際的例子,我配置了一個(gè)秒殺活動,活動配置是開始時(shí)間為第二天早上八點(diǎn),名額數(shù)為100個(gè)人。到了第二天7點(diǎn)50多分,估計(jì)好人都在守著手機(jī)等著搶秒殺商品,所以到了準(zhǔn)時(shí)8:00這個(gè)點(diǎn),所有人一擁而入,1000個(gè)人同時(shí)進(jìn)來搶秒殺的商品,如果直接訪問秒殺應(yīng)用服務(wù)器,可能會讓系統(tǒng)受不了這么高的并發(fā)直接服務(wù)器崩潰,但是有了消息隊(duì)列的話,可以將這1000個(gè)人先擋住,收集他們的信息,然后將符合條件的前100個(gè)人的請求發(fā)給秒殺服務(wù)器,從而達(dá)到削減并發(fā)高峰和篩選的作用,以下是實(shí)現(xiàn)方案圖:
