基于mysql樂觀鎖實現(xiàn)秒殺的示例代碼
更新時間：2022年07月01日 09:15:31 作者：yy1209357299
本文主要介紹了基于mysql樂觀鎖實現(xiàn)秒殺，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
說明
如果你的項目流量非常小，完全不用擔心有并發(fā)的購買請求，那么做這樣一個系統(tǒng)意義不大。但如果你的系統(tǒng)要像12306那樣，接受高并發(fā)訪問和下單的考驗，那么你就需要一套完整的流程保護措施，來保證你系統(tǒng)在用戶流量高峰期不會被搞掛了。
進階redis+mq實現(xiàn)：參考springboot + rabbitmq + redis實現(xiàn)秒殺
嚴格防止超賣
保證用戶體驗：高并發(fā)下，別網(wǎng)頁打不開了，支付不成功了，購物車進不去了，地址改不了了
防止黑產(chǎn)：防止不懷好意的人群通過各種技術(shù)手段把你本該下發(fā)給群眾的利益全收入了囊中
具體實現(xiàn)
1、核心
mysql樂觀鎖防止超賣
樂觀鎖是指操作數(shù)據(jù)庫時(更新操作)，想法很樂觀，認為這次的操作不會導致沖突，在操作數(shù)據(jù)時，并不進行任何其他的特殊處理（也就是不加鎖），而在進行更新后，再去判斷是否有沖突了。
這里是引用通常實現(xiàn)是這樣的：在表中的數(shù)據(jù)進行操作時(更新)，先給數(shù)據(jù)表加一個版本(version)字段，每操作一次，將那條記錄的版本號加1。也就是先查詢出那條記錄，獲取出version字段,如果要對那條記錄進行操作(更新),則先判斷此刻version的值是否與剛剛查詢出來時的version的值相等，如果相等，則說明這段期間，沒有其他程序?qū)ζ溥M行操作，則可以執(zhí)行更新，將version字段的值加1；如果更新時發(fā)現(xiàn)此刻的version值與剛剛獲取出來的version的值不相等，則說明這段期間已經(jīng)有其他程序?qū)ζ溥M行操作了，則不進行更新操作。
2、建表語句
stock商品表
-- ---------------------------- -- Table structure for stock -- ---------------------------- DROP TABLE IF EXISTS `stock`; CREATE TABLE `stock` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(50) NOT NULL DEFAULT '' COMMENT '名稱', `count` int(11) NOT NULL COMMENT '庫存', `sale` int(11) NOT NULL COMMENT '已售', `version` int(11) NOT NULL COMMENT '樂觀鎖，版本號', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
初始化數(shù)據(jù)：
stock_order訂單表
-- ---------------------------- -- Table structure for stock_order -- ---------------------------- DROP TABLE IF EXISTS `stock_order`; CREATE TABLE `stock_order` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `sid` int(11) NOT NULL COMMENT '庫存ID', `name` varchar(30) NOT NULL DEFAULT '' COMMENT '商品名稱', `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '創(chuàng)建時間', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
3、業(yè)務(wù)流程
代碼實現(xiàn)
1、pom
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!--mysql-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!--druid-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.10</version>
</dependency>
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>5.2.0</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.8</version>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<version>5.8.2</version>
<scope>test</scope>
</dependency>
2、model
可通過逆向工程進行配置，參考idea+mybatis逆向工程
4、dao
public interface StockMapper {
Stock checkStock(Integer id);//校驗庫存
int updateSale(Stock stock);//扣除庫存
}
public interface StockOrderMapper {
//創(chuàng)建訂單
void createOrder(StockOrder order);
}
5、sql
商品校驗和減庫存
<select id="checkStock" parameterType="java.lang.Integer" resultType="com.yy.msserver.model.vo.Stock">
select * from stock where id = #{id}
</select>
<update id="updateSale" parameterType="com.yy.msserver.model.vo.Stock" >
update stock
set sale = #{sale,jdbcType=INTEGER} + 1,
version = #{version,jdbcType=INTEGER} + 1,
count = #{count,jdbcType=INTEGER} - 1
where id = #{id,jdbcType=INTEGER}
AND count > 0 AND version = #{version}
</update>
下訂單
<insert id="createOrder" parameterType="com.yy.msserver.model.vo.StockOrder">
insert into stock_order (sid, name,
create_time)
values (#{sid,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR},
#{createTime,jdbcType=TIMESTAMP})
</insert>
6、service
public interface StockOrderService {
public Integer createOrder(Integer id);
}7、實現(xiàn)
/**
* @author code
* @Date 2022/6/24 9:25
* Description 訂單實現(xiàn)
* Version 1.0
*/
@Service
public class StockOrderServiceImpl implements StockOrderService {
@Autowired
private StockOrderMapper stockOrderMapper;
@Autowired
private StockMapper stockMapper;
@Override
@Transactional(rollbackFor = Exception.class)
public Integer createOrder(Integer id) {
//校驗庫存
Stock stock = checkStock(id);
if(stock.getCount()>0){
System.out.println("當前庫存：" + stock.getCount());
//扣庫存
if(updateSale(stock) == 1){
return createOrder(stock);
}else {
return 0;
}
}
return 0;
}
//校驗庫存
private Stock checkStock(Integer id) {
return stockMapper.checkStock(id);
}
//扣庫存
private int updateSale(Stock stock){
return stockMapper.updateSale(stock);
}
//下訂單
private Integer createOrder(Stock stock){
StockOrder order = new StockOrder();
order.setSid(stock.getId());
order.setCreateTime(new Date());
order.setName(stock.getName());
stockOrderMapper.createOrder(order);
return order.getId();
}
}
8、測試
模擬100人參與活動
@SpringBootTest
class MsServerApplicationTests {
@Autowired
private StockOrderService stockOrderService;
@Test
void contextLoads() throws InterruptedException {
// 庫存初始化為10，這里通過CountDownLatch和線程池模擬100個并發(fā)
int threadTotal = 100;
ExecutorService executorService = Executors.newCachedThreadPool();
final CountDownLatch countDownLatch = new CountDownLatch(threadTotal);
for (int i = 0; i < threadTotal ; i++) {
int uid = i;
executorService.execute(() -> {
try {
stockOrderService.createOrder(1);
} catch (Exception e) {
e.printStackTrace();
}
countDownLatch.countDown();
});
}
countDownLatch.await();
executorService.shutdown();
}
}
9、結(jié)果
商品表
訂單表
到此這篇關(guān)于基于mysql樂觀鎖實現(xiàn)秒殺的示例代碼的文章就介紹到這了,更多相關(guān)mysql樂觀鎖秒殺內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
虛擬列是MySQL中的一種特殊列,它不存儲在表中,而是在查詢時動態(tài)計算生成,虛擬列可以提高查詢效率、減少存儲需求、確保數(shù)據(jù)一致性、簡化查詢和保護敏感數(shù)據(jù),感興趣的可以了解一下2024-11-11
這篇文章主要為大家詳細介紹了mysql 5.7.15安裝配置方法圖文教程，更改數(shù)據(jù)庫data的存儲路徑，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-11-11
這篇文章介紹了MYSQL主從不同步延遲原理分析及解決方案，有需要的朋友可以參考一下2013-09-09
文章介紹了MySQL 8的安裝步驟,包括配置忽略大小寫、備份數(shù)據(jù)、停止和刪除數(shù)據(jù)庫文件、配置my.cnf文件、初始化、啟動服務(wù)和登錄設(shè)置密碼,還討論了在配置遠程連接時遇到的常見問題,特別是MySQL 8版本中由于密碼加密方法變化導致的問題解決方法2024-11-11
MySQL中報錯：Can’t find file: ‘./mysql/plugin.frm’的解決方法
這篇文章主要給大家介紹了關(guān)于在MySQL中報錯：Can't find file: './mysql/plugin.frm'的解決方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧。2017-11-11
這篇文章主要介紹了MyCAT上新增一個庫及MyCAT報錯1184的問題及解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-11-11
Mysql 5.7.18安裝方法及啟動MySQL服務(wù)的過程詳解
這篇文章主要介紹了Mysql 5.7.18安裝方法及啟動MySQL服務(wù)的過程,非常不錯，具有參考借鑒價值，需要的朋友可以參考下2017-05-05
Linux下MySQL安裝配置 MySQL配置參數(shù)詳解
Linux下MySQL安裝配置 MySQL配置參數(shù)詳解，在linux下配置mysql的朋友可以參考下。2011-07-07
Mysql 5.6使用配置文件my.ini來設(shè)置長時間連接數(shù)據(jù)庫的問題
這篇文章主要介紹了Mysql 5.6使用配置文件my.ini來設(shè)置長時間連接數(shù)據(jù)庫,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-07-07
結(jié)合PHP腳本添加和查詢MySQL數(shù)據(jù)的基本教程
這篇文章主要介紹了結(jié)合PHP腳本添加和查詢MySQL數(shù)據(jù)的基本教程,即在PHP程序中使用基本的SELECT FROM和INSERT INTO語句,需要的朋友可以參考下2015-12-12