秒殺系統(tǒng)設(shè)計(jì)

功能需求:設(shè)計(jì)一個(gè)秒殺系統(tǒng)

初始方案

商品表設(shè)計(jì):熱銷(xiāo)商品提供給用戶(hù)秒殺,有初始庫(kù)存膏燕。

@Entity

public class SecKillGoods implements Serializable{

? ? @Id

? ? private String id;

? ? /**

? ? * 剩余庫(kù)存

? ? */

? ? private Integer remainNum;

? ? /**

? ? * 秒殺商品名稱(chēng)

? ? */

? ? private String goodsName;

}

秒殺訂單表設(shè)計(jì):記錄秒殺成功的訂單情況

@Entity

public class SecKillOrder implements Serializable {

? ? @Id

? ? @GenericGenerator(name = "PKUUID", strategy = "uuid2")

? ? @GeneratedValue(generator = "PKUUID")

? ? @Column(length = 36)

? ? private String id;

? ? //用戶(hù)名稱(chēng)

? ? private String consumer;

? ? //秒殺產(chǎn)品編號(hào)

? ? private String goodsId;

? ? //購(gòu)買(mǎi)數(shù)量

? ? private Integer num;

}

Dao設(shè)計(jì):主要就是一個(gè)減少庫(kù)存方法钥屈,其他CRUD使用JPA自帶的方法

public interface SecKillGoodsDao extends JpaRepository<SecKillGoods,String>{

? ? @Query("update SecKillGoods g set g.remainNum = g.remainNum - ?2 where g.id=?1")

? ? @Modifying(clearAutomatically = true)

? ? @Transactional

? ? int reduceStock(String id,Integer remainNum);

}

數(shù)據(jù)初始化以及提供保存訂單的操作:

@Service

public class SecKillService {

? ? @Autowired

? ? SecKillGoodsDao secKillGoodsDao;

? ? @Autowired

? ? SecKillOrderDao secKillOrderDao;

? ? /**

? ? * 程序啟動(dòng)時(shí):

? ? * 初始化秒殺商品,清空訂單數(shù)據(jù)

? ? */

? ? @PostConstruct

? ? public void initSecKillEntity(){

? ? ? ? secKillGoodsDao.deleteAll();

? ? ? ? secKillOrderDao.deleteAll();

? ? ? ? SecKillGoods secKillGoods = new SecKillGoods();

? ? ? ? secKillGoods.setId("123456");

? ? ? ? secKillGoods.setGoodsName("秒殺產(chǎn)品");

? ? ? ? secKillGoods.setRemainNum(10);

? ? ? ? secKillGoodsDao.save(secKillGoods);

? ? }

? ? /**

? ? * 購(gòu)買(mǎi)成功,保存訂單

? ? * @param consumer

? ? * @param goodsId

? ? * @param num

? ? */

? ? public void generateOrder(String consumer, String goodsId, Integer num) {

? ? ? ? secKillOrderDao.save(new SecKillOrder(consumer,goodsId,num));

? ? }

}

下面就是controller層的設(shè)計(jì)

@Controller

public class SecKillController {

? ? @Autowired

? ? SecKillGoodsDao secKillGoodsDao;

? ? @Autowired

? ? SecKillService secKillService;

? ? /**

? ? * 普通寫(xiě)法

? ? * @param consumer

? ? * @param goodsId

? ? * @return

? ? */

? ? @RequestMapping("/seckill.html")

? ? @ResponseBody

? ? public String SecKill(String consumer,String goodsId,Integer num) throws InterruptedException {

? ? ? ? //查找出用戶(hù)要買(mǎi)的商品

? ? ? ? SecKillGoods goods = secKillGoodsDao.findOne(goodsId);

? ? ? ? //如果有這么多庫(kù)存

? ? ? ? if(goods.getRemainNum()>=num){

? ? ? ? ? ? //模擬網(wǎng)絡(luò)延時(shí)

? ? ? ? ? ? Thread.sleep(1000);

? ? ? ? ? ? //先減去庫(kù)存

? ? ? ? ? ? secKillGoodsDao.reduceStock(num);

? ? ? ? ? ? //保存訂單

? ? ? ? ? ? secKillService.generateOrder(consumer,goodsId,num);

? ? ? ? ? ? return "購(gòu)買(mǎi)成功";

? ? ? ? }

? ? ? ? return "購(gòu)買(mǎi)失敗,庫(kù)存不足";

? ? }

}

上面是全部的基礎(chǔ)準(zhǔn)備坝辫,下面使用一個(gè)單元測(cè)試方法焕蹄,模擬高并發(fā)下,很多人來(lái)購(gòu)買(mǎi)同一個(gè)熱門(mén)商品的情況阀溶。

@Controller

public class SecKillSimulationOpController {

? ? final String takeOrderUrl = "http://127.0.0.1:8080/seckill.html";

? ? /**

? ? * 模擬并發(fā)下單

? ? */

? ? @RequestMapping("/simulationCocurrentTakeOrder")

? ? @ResponseBody

? ? public String simulationCocurrentTakeOrder() {

? ? ? ? //httpClient工廠

? ? ? ? final SimpleClientHttpRequestFactory httpRequestFactory = new SimpleClientHttpRequestFactory();

? ? ? ? //開(kāi)50個(gè)線程模擬并發(fā)秒殺下單

? ? ? ? for (int i = 0; i < 50; i++) {

? ? ? ? ? ? //購(gòu)買(mǎi)人姓名

? ? ? ? ? ? final String consumerName = "consumer" + i;

? ? ? ? ? ? new Thread(new Runnable() {

? ? ? ? ? ? ? ? @Override

? ? ? ? ? ? ? ? public void run() {

? ? ? ? ? ? ? ? ? ? ClientHttpRequest request = null;

? ? ? ? ? ? ? ? ? ? try {

? ? ? ? ? ? ? ? ? ? ? ? URI uri = new URI(takeOrderUrl + "?consumer=consumer" + consumerName + "&goodsId=123456&num=1");

? ? ? ? ? ? ? ? ? ? ? ? request = httpRequestFactory.createRequest(uri, HttpMethod.POST);

? ? ? ? ? ? ? ? ? ? ? ? InputStream body = request.execute().getBody();

? ? ? ? ? ? ? ? ? ? ? ? BufferedReader br = new BufferedReader(new InputStreamReader(body));

? ? ? ? ? ? ? ? ? ? ? ? String line = "";

? ? ? ? ? ? ? ? ? ? ? ? String result = "";

? ? ? ? ? ? ? ? ? ? ? ? while ((line = br.readLine()) != null) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? result += line;//獲得頁(yè)面內(nèi)容或返回內(nèi)容

? ? ? ? ? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? ? ? ? ? System.out.println(consumerName+":"+result);

? ? ? ? ? ? ? ? ? ? } catch (Exception e) {

? ? ? ? ? ? ? ? ? ? ? ? e.printStackTrace();

? ? ? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? }

? ? ? ? ? ? }).start();

? ? ? ? }

? ? ? ? return "simulationCocurrentTakeOrder";

? ? }

}

訪問(wèn)localhost:8080/simulationCocurrentTakeOrder腻脏,就可以測(cè)試了

預(yù)期情況:因?yàn)槲覀冎粚?duì)秒殺商品(123456)初始化了10件,理想情況當(dāng)然是庫(kù)存減少到0银锻,訂單表也只有10條記錄永品。

實(shí)際情況:訂單表記錄


商品表記錄


下面分析一下為啥會(huì)出現(xiàn)超庫(kù)存的情況:

因?yàn)槎鄠€(gè)請(qǐng)求訪問(wèn),僅僅是使用dao查詢(xún)了一次數(shù)據(jù)庫(kù)有沒(méi)有庫(kù)存击纬,但是比較惡劣的情況是很多人都查到了有庫(kù)存鼎姐,這個(gè)時(shí)候因?yàn)槌绦蛱幚淼难舆t,沒(méi)有及時(shí)的減少庫(kù)存更振,那就出現(xiàn)了臟讀炕桨。如何在設(shè)計(jì)上避免呢?最笨的方法是對(duì)SecKillController的seckill方法做同步肯腕,每次只有一個(gè)人能下單献宫。但是太影響性能了,下單變成了同步操作实撒。

@RequestMapping("/seckill.html")

@ResponseBody

public synchronized String SecKill

改進(jìn)方案

根據(jù)多線程編程的規(guī)范姊途,提倡對(duì)共享資源加鎖涉瘾,在最有可能出現(xiàn)并發(fā)爭(zhēng)搶的情況下加同步塊的思想。應(yīng)該同一時(shí)刻只有一個(gè)線程去減少庫(kù)存捷兰。但是這里給出一個(gè)最好的方案立叛,就是利用Oracle,MySQL的行級(jí)鎖–同一時(shí)間只有一個(gè)線程能夠操作同一行記錄,對(duì)SecKillGoodsDao進(jìn)行改造:

public interface SecKillGoodsDao extends JpaRepository<SecKillGoods,String>{

? ? @Query("update SecKillGoods g set g.remainNum = g.remainNum - ?2 where g.id=?1 and g.remainNum>0")

? ? @Modifying(clearAutomatically = true)

? ? @Transactional

? ? int reduceStock(String id,Integer remainNum);

}

僅僅是加了一個(gè)and贡茅,卻造成了很大的改變秘蛇,返回int值代表的是影響的行數(shù),對(duì)應(yīng)到controller做出相應(yīng)的判斷顶考。

@RequestMapping("/seckill.html")

? ? @ResponseBody

? ? public String SecKill(String consumer,String goodsId,Integer num) throws InterruptedException {

? ? ? ? //查找出用戶(hù)要買(mǎi)的商品

? ? ? ? SecKillGoods goods = secKillGoodsDao.findOne(goodsId);

? ? ? ? //如果有這么多庫(kù)存

? ? ? ? if(goods.getRemainNum()>=num){

? ? ? ? ? ? //模擬網(wǎng)絡(luò)延時(shí)

? ? ? ? ? ? Thread.sleep(1000);

? ? ? ? ? ? if(goods.getRemainNum()>0) {

? ? ? ? ? ? ? ? //先減去庫(kù)存

? ? ? ? ? ? ? ? int i = secKillGoodsDao.reduceStock(goodsId, num);

? ? ? ? ? ? ? ? if(i!=0) {

? ? ? ? ? ? ? ? ? ? //保存訂單

? ? ? ? ? ? ? ? ? ? secKillService.generateOrder(consumer, goodsId, num);

? ? ? ? ? ? ? ? ? ? return "購(gòu)買(mǎi)成功";

? ? ? ? ? ? ? ? }else{

? ? ? ? ? ? ? ? ? ? return "購(gòu)買(mǎi)失敗,庫(kù)存不足";

? ? ? ? ? ? ? ? }

? ? ? ? ? ? }else {

? ? ? ? ? ? ? ? return "購(gòu)買(mǎi)失敗,庫(kù)存不足";

? ? ? ? ? ? }

? ? ? ? }

? ? ? ? return "購(gòu)買(mǎi)失敗,庫(kù)存不足";

? ? }

在看看運(yùn)行情況


訂單表:


在高并發(fā)問(wèn)題下的秒殺情況尘惧,即使存在網(wǎng)絡(luò)延時(shí)改抡,也得到了保障挤巡。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末冀膝,一起剝皮案震驚了整個(gè)濱河市浮庐,隨后出現(xiàn)的幾起案子甚负,更是在濱河造成了極大的恐慌,老刑警劉巖审残,帶你破解...
    沈念sama閱讀 222,681評(píng)論 6 517
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件梭域,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡搅轿,警方通過(guò)查閱死者的電腦和手機(jī)病涨,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 95,205評(píng)論 3 399
  • 文/潘曉璐 我一進(jìn)店門(mén),熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)璧坟,“玉大人既穆,你說(shuō)我怎么就攤上這事∪妇椋” “怎么了幻工?”我有些...
    開(kāi)封第一講書(shū)人閱讀 169,421評(píng)論 0 362
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)黎茎。 經(jīng)常有香客問(wèn)我囊颅,道長(zhǎng),這世上最難降的妖魔是什么傅瞻? 我笑而不...
    開(kāi)封第一講書(shū)人閱讀 60,114評(píng)論 1 300
  • 正文 為了忘掉前任踢代,我火速辦了婚禮,結(jié)果婚禮上嗅骄,老公的妹妹穿的比我還像新娘胳挎。我一直安慰自己,他們只是感情好溺森,可當(dāng)我...
    茶點(diǎn)故事閱讀 69,116評(píng)論 6 398
  • 文/花漫 我一把揭開(kāi)白布串远。 她就那樣靜靜地躺著宏多,像睡著了一般。 火紅的嫁衣襯著肌膚如雪澡罚。 梳的紋絲不亂的頭發(fā)上伸但,一...
    開(kāi)封第一講書(shū)人閱讀 52,713評(píng)論 1 312
  • 那天,我揣著相機(jī)與錄音留搔,去河邊找鬼更胖。 笑死,一個(gè)胖子當(dāng)著我的面吹牛隔显,可吹牛的內(nèi)容都是我干的却妨。 我是一名探鬼主播,決...
    沈念sama閱讀 41,170評(píng)論 3 422
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼括眠,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼彪标!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起掷豺,我...
    開(kāi)封第一講書(shū)人閱讀 40,116評(píng)論 0 277
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤捞烟,失蹤者是張志新(化名)和其女友劉穎,沒(méi)想到半個(gè)月后当船,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體题画,經(jīng)...
    沈念sama閱讀 46,651評(píng)論 1 320
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,714評(píng)論 3 342
  • 正文 我和宋清朗相戀三年德频,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了苍息。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,865評(píng)論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡壹置,死狀恐怖竞思,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情钞护,我是刑警寧澤衙四,帶...
    沈念sama閱讀 36,527評(píng)論 5 351
  • 正文 年R本政府宣布,位于F島的核電站患亿,受9級(jí)特大地震影響传蹈,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜步藕,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,211評(píng)論 3 336
  • 文/蒙蒙 一惦界、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧咙冗,春花似錦沾歪、人聲如沸。這莊子的主人今日做“春日...
    開(kāi)封第一講書(shū)人閱讀 32,699評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)挫望。三九已至,卻和暖如春狂窑,著一層夾襖步出監(jiān)牢的瞬間媳板,已是汗流浹背。 一陣腳步聲響...
    開(kāi)封第一講書(shū)人閱讀 33,814評(píng)論 1 274
  • 我被黑心中介騙來(lái)泰國(guó)打工泉哈, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留蛉幸,地道東北人。 一個(gè)月前我還...
    沈念sama閱讀 49,299評(píng)論 3 379
  • 正文 我出身青樓丛晦,卻偏偏與公主長(zhǎng)得像奕纫,于是被迫代替她去往敵國(guó)和親。 傳聞我的和親對(duì)象是個(gè)殘疾皇子烫沙,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,870評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開(kāi)發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見(jiàn)模式的工具(例如配置管理匹层,服務(wù)發(fā)現(xiàn),斷路器锌蓄,智...
    卡卡羅2017閱讀 134,716評(píng)論 18 139
  • 功能需求:設(shè)計(jì)一個(gè)秒殺系統(tǒng) 初始方案 商品表設(shè)計(jì):熱銷(xiāo)商品提供給用戶(hù)秒殺升筏,有初始庫(kù)存。 @Entity publi...
    余平的余_余平的平閱讀 254評(píng)論 0 0
  • 寫(xiě)下這個(gè)題目時(shí)我的心情是很沉重的煤率,因?yàn)檫@代表著我要再次回憶,揭開(kāi)一段已經(jīng)塵封的歷史乏冀,那段歷史是我的青春中最絢爛的一...
    白山碧玉閱讀 1,405評(píng)論 15 10
  • 周辰開(kāi)啟了好友驗(yàn)證,你還不是他的朋友肢扯,請(qǐng)先發(fā)送朋友驗(yàn)證請(qǐng)求妒茬,對(duì)方驗(yàn)證通過(guò)后,才能聊天蔚晨。 “你今天在干...
    一片青瓦閱讀 1,263評(píng)論 2 4
  • 昨天和今天都在下雨铭腕。都說(shuō)心情就和天氣一樣银择,我想是的。 在這樣兩個(gè)陰雨天累舷,我想起了你浩考。準(zhǔn)確的說(shuō),和你分開(kāi)之后的這三年...
    喵嗚喵嗚A閱讀 736評(píng)論 0 0