MySQL悲觀鎖 select for update實(shí)現(xiàn)秒殺案例(jfinal框架)

發(fā)布時(shí)間：2018-08-17作者：laosun閱讀(4287)

為了方便測(cè)試，博主使用最新的jfinal框架，里邊的東西就修改了一下a_little_config.txt，配置數(shù)據(jù)庫(kù)鏈接的，啟動(dòng)直接打開(kāi)DemoConfig.java，main方法啟動(dòng)即可(記得修改端口)，這樣就不用再去寫(xiě)jdbc了。感興趣的朋友可以去了解一下：

主要源碼(模擬120人同時(shí)搶購(gòu)100件商品)：package?com.demo.index;

import?java.sql.Connection;

import?java.sql.PreparedStatement;

import?java.sql.ResultSet;

import?java.sql.SQLException;

import?com.jfinal.core.Controller;

import?com.jfinal.plugin.activerecord.Db;

/**

*?秒殺/MySQL?悲觀鎖實(shí)現(xiàn)方式

*

*?@author?sun

*/

public?class?SecKillForPLController?extends?Controller?{

public?static?int?goodsTotalNum?=?100;

public?void?index()?{

//每一次新的請(qǐng)求都會(huì)模擬搶購(gòu)100件商品，所以先恢復(fù)商品的數(shù)量,這個(gè)可以不要，也可以手動(dòng)去更新數(shù)據(jù)庫(kù)

Db.update("update?t_goods?set?num?=???where?id?=?1",?goodsTotalNum);

SecKillPL?sk?=?new?SecKillPL();

//?模擬120個(gè)人搶購(gòu)

for?(int?i?=?1;?i?<=?120;?i++)?{

new?Thread(sk,?i?+?"?號(hào)人").start();

}

renderHtml("

搶購(gòu)成功!

");

}

}

/**

*?這里我們只是演示數(shù)據(jù)庫(kù)悲觀鎖的實(shí)現(xiàn)方式，至于事務(wù)等其他的都不添加了。

*

*?@author?sun

*/

class?SecKillPL?implements?Runnable?{

@Override

public?void?run()?{

Connection?conn?=?null;

PreparedStatement?ps?=?null;

try?{

conn?=?Db.use().getConfig().getConnection();

conn.setAutoCommit(false);

ps?=?conn.prepareStatement("select?*?from?t_goods?where?id?=?1?for?update");

ResultSet?rs?=?ps.executeQuery();

Integer?num?=?0;

while?(rs.next())?{

num?=?rs.getInt("num");

}

if?(num?>?0)?{

PreparedStatement?ps2?=?conn.prepareStatement("update?t_goods?set?num=num-1?where?id?=?1");

ps2.execute();

System.out.println(Thread.currentThread().getName()?+?"?搶到了第"?+?(SecKillForPLController.goodsTotalNum?-?num?+?1)?+?"商品");

conn.commit();

}else{

System.err.println(Thread.currentThread().getName()?+?"?太悲劇了，沒(méi)搶到商品...");

}

}?catch?(SQLException?e1)?{

e1.printStackTrace();

}?finally?{

try?{

ps.close();

}?catch?(SQLException?e)?{}

try?{

conn.close();

}?catch?(SQLException?e)?{}

}

}

}

代碼里有些jfinal的東西，看不懂的不要緊，只要知道是操作sql就行。

輸出結(jié)果：

3?號(hào)人?搶到了第1商品

2?號(hào)人?搶到了第2商品

1?號(hào)人?搶到了第3商品

4?號(hào)人?搶到了第4商品

9?號(hào)人?搶到了第5商品

6?號(hào)人?搶到了第6商品

5?號(hào)人?搶到了第7商品

......

95?號(hào)人?搶到了第92商品

94?號(hào)人?搶到了第93商品

97?號(hào)人?搶到了第94商品

98?號(hào)人?搶到了第95商品

99?號(hào)人?搶到了第96商品

100?號(hào)人?搶到了第97商品

80?號(hào)人?搶到了第98商品

83?號(hào)人?搶到了第99商品

102?號(hào)人?搶到了第100商品

96?號(hào)人?太悲劇了，沒(méi)搶到商品...

101?號(hào)人?太悲劇了，沒(méi)搶到商品...

103?號(hào)人?太悲劇了，沒(méi)搶到商品...

104?號(hào)人?太悲劇了，沒(méi)搶到商品...

105?號(hào)人?太悲劇了，沒(méi)搶到商品...

106?號(hào)人?太悲劇了，沒(méi)搶到商品...

107?號(hào)人?太悲劇了，沒(méi)搶到商品...

108?號(hào)人?太悲劇了，沒(méi)搶到商品...

109?號(hào)人?太悲劇了，沒(méi)搶到商品...

110?號(hào)人?太悲劇了，沒(méi)搶到商品...

111?號(hào)人?太悲劇了，沒(méi)搶到商品...

112?號(hào)人?太悲劇了，沒(méi)搶到商品...

113?號(hào)人?太悲劇了，沒(méi)搶到商品...

114?號(hào)人?太悲劇了，沒(méi)搶到商品...

115?號(hào)人?太悲劇了，沒(méi)搶到商品...

116?號(hào)人?太悲劇了，沒(méi)搶到商品...

117?號(hào)人?太悲劇了，沒(méi)搶到商品...

118?號(hào)人?太悲劇了，沒(méi)搶到商品...

119?號(hào)人?太悲劇了，沒(méi)搶到商品...

120?號(hào)人?太悲劇了，沒(méi)搶到商品...

t_goods表結(jié)構(gòu)：

CREATE?TABLE?`d_sunjs_test`.`t_goods`??(

`id`?int(11)?NOT?NULL?AUTO_INCREMENT,

`name`?varchar(255)?CHARACTER?SET?utf8?COLLATE?utf8_general_ci?NULL?DEFAULT?NULL,

`num`?int(11)?NULL?DEFAULT?NULL,

PRIMARY?KEY?(`id`)?USING?BTREE

)?ENGINE?=?InnoDB?AUTO_INCREMENT?=?2?CHARACTER?SET?=?utf8?COLLATE?=?utf8_general_ci?ROW_FORMAT?=?Dynamic;

下一篇文章： 用MySQL樂(lè)觀鎖來(lái)實(shí)現(xiàn)秒殺

7 +1

版權(quán)聲明

發(fā)表評(píng)論

請(qǐng)文明留言

發(fā)表

共 0 條評(píng)論

總結(jié)

以上是生活随笔為你收集整理的mysql悲观锁关键字_MySQL悲观锁 select for update实现秒杀案例（jfinal框架）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。