快捷導(dǎo)航

Springboot項(xiàng)目通過(guò)redis實(shí)現(xiàn)接口的冪等性

更新時(shí)間：2023年12月13日 11:12:14 作者：AD探草暴斃?

這篇文章主要為大家介紹了Springboot項(xiàng)目通過(guò)redis實(shí)現(xiàn)接口的冪等性,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

Spring Boot項(xiàng)目中通過(guò)Redis實(shí)現(xiàn)接口的冪等性

通常是通過(guò)在Redis中存儲(chǔ)唯一標(biāo)識(shí)符（token、UUID等）的方式來(lái)實(shí)現(xiàn)。當(dāng)接口第一次被調(diào)用時(shí)，生成并存儲(chǔ)一個(gè)唯一標(biāo)識(shí)符到Redis，然后將該標(biāo)識(shí)符返回給客戶端?？蛻舳嗽诤罄m(xù)的請(qǐng)求中攜帶該標(biāo)識(shí)符，服務(wù)端在處理請(qǐng)求之前檢查Redis中是否存在該標(biāo)識(shí)符，如果存在，則認(rèn)為是重復(fù)請(qǐng)求，直接返回之前的結(jié)果，如果不存在，則繼續(xù)處理請(qǐng)求并存儲(chǔ)標(biāo)識(shí)符。

添加依賴

確保在pom.xml中添加Redis依賴：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置Redis連接信息

在application.properties或application.yml中配置Redis連接信息：

spring.redis.host=localhost
spring.redis.port=6379
spring.redis.password=
spring.redis.database=0

編寫冪等性工具類

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
@Component
public class IdempotenceUtil {
    private static final String IDEMPOTENCE_KEY_PREFIX = "idempotence:";
    @Autowired
    private StringRedisTemplate redisTemplate;
    public boolean isRequestProcessed(String requestId) {
        return redisTemplate.hasKey(idempotenceKey(requestId));
    }
    public void markRequestProcessed(String requestId, long timeoutSeconds) {
        redisTemplate.opsForValue().set(idempotenceKey(requestId), "processed", timeoutSeconds, TimeUnit.SECONDS);
    }
    private String idempotenceKey(String requestId) {
        return IDEMPOTENCE_KEY_PREFIX + requestId;
    }
}

實(shí)現(xiàn)冪等性的Controller

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/api")
public class IdempotentController {
    @Autowired
    private IdempotenceUtil idempotenceUtil;
    @PostMapping("/idempotent-operation")
    public ResponseEntity<String> idempotentOperation(@RequestHeader("request-id") String requestId) {
        // 檢查是否已處理過(guò)該請(qǐng)求
        if (idempotenceUtil.isRequestProcessed(requestId)) {
            return ResponseEntity.ok("Operation already processed");
        }
        // 處理業(yè)務(wù)邏輯...
        // 標(biāo)記請(qǐng)求已處理
        idempotenceUtil.markRequestProcessed(requestId, 60);
        return ResponseEntity.ok("Operation processed successfully");
    }
}

在上述示例中，IdempotenceUtil類封裝了檢查和標(biāo)記請(qǐng)求是否已處理的邏輯。IdempotentController中的idempotentOperation方法通過(guò)@RequestHeader注解獲取請(qǐng)求頭中的唯一標(biāo)識(shí)符（request-id），然后檢查Redis中是否已處理過(guò)該請(qǐng)求，如果已處理，則返回結(jié)果，否則執(zhí)行業(yè)務(wù)邏輯，標(biāo)記請(qǐng)求已處理，并返回結(jié)果。

以上就是Springboot項(xiàng)目通過(guò)redis實(shí)現(xiàn)接口的冪等性的詳細(xì)內(nèi)容，更多關(guān)于Springboot redis接口冪等性的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: