偷偷摘套内射激情视频,久久精品99国产国产精,中文字幕无线乱码人妻,中文在线中文a,性爽19p

互聯(lián)網(wǎng)業(yè)務(wù)冪等性實(shí)現(xiàn)之基于MySQL

數(shù)據(jù)庫(kù) 其他數(shù)據(jù)庫(kù)
以某互聯(lián)網(wǎng)電商的取消訂單為例子,當(dāng)訂單取消,需要返回給消費(fèi)者下單所消費(fèi)的虛擬產(chǎn)品,如優(yōu)惠券、紅包、京豆等。通過(guò)冪等形式,確保返還給消費(fèi)者的權(quán)益不多、不少。那冪等性具體開(kāi)發(fā)是怎么實(shí)現(xiàn)的呢?本文帶來(lái)基于MySQL的UNIQUE KEY的實(shí)現(xiàn)方案。

背景

在互聯(lián)網(wǎng)業(yè)務(wù)領(lǐng)域中,我們經(jīng)常會(huì)遇到應(yīng)用到請(qǐng)求冪等性問(wèn)題,即多次重復(fù)請(qǐng)求,所得到的結(jié)果,和一次請(qǐng)求一致。

以某互聯(lián)網(wǎng)電商的取消訂單為例子,當(dāng)訂單取消,需要返回給消費(fèi)者下單所消費(fèi)的虛擬產(chǎn)品,如優(yōu)惠券、紅包、京豆等。通過(guò)冪等形式,確保返還給消費(fèi)者的權(quán)益不多、不少。

那冪等性具體開(kāi)發(fā)是怎么實(shí)現(xiàn)的呢?本文帶來(lái)基于MySQL的UNIQUE KEY的實(shí)現(xiàn)方案。

實(shí)現(xiàn)

眾所周知,UNIQUE KEY是數(shù)據(jù)庫(kù)中的唯一索引,數(shù)據(jù)庫(kù)的記錄中不允許有重復(fù)的值,我們可以利用這點(diǎn),在處理業(yè)務(wù)前,先進(jìn)行唯一索引數(shù)據(jù)(如訂單id)的插入操作:

  • 插入成功,說(shuō)明是第一次插入,正常處理業(yè)務(wù);
  • 插入失敗,說(shuō)明該業(yè)務(wù)邏輯已經(jīng)處理過(guò)了,不做處理,提前返回;

如此,即可實(shí)現(xiàn)冪等性。

1.數(shù)據(jù)庫(kù)設(shè)計(jì)

冪等性輔助表設(shè)計(jì)如下:

CREATE TABLE `idempotent_validate` (
`id` bigint NOT NULL,
`create_time` time DEFAULT NULL,
`order_id` bigint DEFAULT NULL,
PRIMARY KEY (`id`),
UNIQUE KEY `UK_orssam7fgn4uj0lo2sn4on6vg` (`order_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;

其中的一個(gè)字段order_id,我們定義為唯一索引。

2.代碼編寫(xiě)

我們主要實(shí)現(xiàn)了訂單取消方法cancelOrder:

package com.example.idempotentmysql.service.impl;

import com.example.idempotentmysql.bean.IdempotentValidate;
import com.example.idempotentmysql.bean.OrderInfo;
import com.example.idempotentmysql.bean.ProductInfo;
import com.example.idempotentmysql.bean.UserInfo;
import com.example.idempotentmysql.repository.IdempotentValidateRepository;
import com.example.idempotentmysql.repository.OrderInfoRepository;
import com.example.idempotentmysql.repository.ProductInfoRepository;
import com.example.idempotentmysql.repository.UserInfoRepository;
import com.example.idempotentmysql.service.OrderService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Optional;

/**
* 訂單服務(wù)
*
* @author hongcunlin
*/
@Service
public class OrderServiceImpl implements OrderService {
/**
* 日志
*/
private static final Logger LOGGER = LoggerFactory.getLogger(OrderServiceImpl.class);

/**
* 用戶(hù)repository
*/
@Resource
private UserInfoRepository userInfoRepository;

/**
* 商品repository
*/
@Resource
private ProductInfoRepository productInfoRepository;

/**
* 訂單repository
*/
@Resource
private OrderInfoRepository orderInfoRepository;

/**
* 冪等性校驗(yàn)
*/
@Resource
private IdempotentValidateRepository idempotentValidateRepository;

/**
* 取消訂單(帶冪等性校驗(yàn))
*
* @param orderId 訂單id
*/
@Override
public void cancelOrder(Long orderId) {
// 1.冪等性校驗(yàn)
try {
IdempotentValidate idempotentValidate = new IdempotentValidate();
idempotentValidate.setOrderId(orderId);
idempotentValidateRepository.save(idempotentValidate);
} catch (Exception e) {
LOGGER.info("訂單退款冪等");
return;
}

// 2.退款
Optional<OrderInfo> orderInfoOptional = orderInfoRepository.findById(orderId);
if (orderInfoOptional.isPresent()) {
OrderInfo orderInfo = orderInfoOptional.get();
Optional<UserInfo> userInfoOptional = userInfoRepository.findById(orderInfo.getUserId());
Optional<ProductInfo> productInfoOptional = productInfoRepository.findById(orderInfo.getProductId());
if (userInfoOptional.isPresent() && productInfoOptional.isPresent()) {
UserInfo userInfo = userInfoOptional.get();
ProductInfo productInfo = productInfoOptional.get();
userInfo.setMoney(userInfo.getMoney().add(productInfo.getPrice()));
userInfoRepository.save(userInfo);
}
}
LOGGER.info("訂單成功退款");
}
}

從代碼中可以看到,我們?cè)诔擞唵瓮丝钋?,冪等性表先拿訂單id進(jìn)行插入操作,若插入成功,說(shuō)明是第一次取消訂單,執(zhí)行下面的退款邏輯;

若插入失敗,說(shuō)明之前已經(jīng)進(jìn)行過(guò)退款邏輯了,我們提前返回,不做下面的退款操作。

如此,便實(shí)現(xiàn)了訂單退款的冪等性。

3.測(cè)試

我們對(duì)訂單進(jìn)行3次取消操作:

package com.example.idempotentmysql.service;


import com.example.idempotentmysql.bean.OrderInfo;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import javax.annotation.Resource;

@SpringBootTest
public class OrderServiceTest {

@Resource
private OrderService orderService;

@Test
public void cancelOrderTest() {
orderService.cancelOrder(6L);
orderService.cancelOrder(6L);
orderService.cancelOrder(6L);
}
}

可以看到,只有第一次是退款成功的,后面2次觸發(fā)冪等性,退款失敗,符合我們的預(yù)期。

其他

冪等性的實(shí)現(xiàn)方式還有很多種,基于MySQL的UNIQUE KEY的實(shí)現(xiàn)方案,實(shí)現(xiàn)起來(lái)相當(dāng)簡(jiǎn)單,僅適合業(yè)務(wù)簡(jiǎn)單,并發(fā)量不高的場(chǎng)景。原因是MySQL的qps有限,且MySQL作為系統(tǒng)的最底層的應(yīng)用,過(guò)于后置,如果最終冪等返回,比較浪費(fèi)前置的業(yè)務(wù)處理所消耗的資源。

本文代碼已經(jīng)上傳到github上了,有需要的同學(xué)可以下載參考:https://github.com/larger5/idempotent-mysql

責(zé)任編輯:武曉燕 來(lái)源: 今日頭條
相關(guān)推薦

2024-11-01 09:28:02

2011-12-19 16:45:22

2022-07-26 09:03:50

冪等性數(shù)據(jù)狀態(tài)機(jī)

2015-06-24 15:35:54

2011-08-19 11:33:32

2020-12-31 09:24:27

互聯(lián)網(wǎng)存款業(yè)務(wù)互聯(lián)網(wǎng)金融

2015-09-09 14:24:14

2009-06-15 08:48:23

2014-10-11 09:16:59

互聯(lián)網(wǎng)協(xié)議

2014-01-15 14:35:35

云計(jì)算

2015-05-28 16:11:07

互聯(lián)網(wǎng)+

2025-03-17 08:07:11

2015-10-08 15:20:34

互聯(lián)網(wǎng)物聯(lián)網(wǎng)

2015-08-03 10:49:07

用友IUAP

2017-08-11 13:03:54

互聯(lián)網(wǎng)+工業(yè)轉(zhuǎn)型

2015-09-22 09:17:33

互聯(lián)網(wǎng)發(fā)展史

2015-10-30 17:50:18

互聯(lián)網(wǎng)金融

2018-08-15 09:02:59

產(chǎn)業(yè)互聯(lián)網(wǎng)工業(yè)互聯(lián)網(wǎng)物聯(lián)網(wǎng)

2023-12-05 15:49:29

2014-05-30 17:53:43

移動(dòng)互聯(lián)網(wǎng)
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)