Springboot项目通过redis实现接口的幂等性

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

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;
    }
}

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) {
        // 检查是否已处理过该请求
        if (idempotenceUtil.isRequestProcessed(requestId)) {
            return ResponseEntity.ok("Operation already processed");
        }
        // 处理业务逻辑...
        // 标记请求已处理
        idempotenceUtil.markRequestProcessed(requestId, 60);
        return ResponseEntity.ok("Operation processed successfully");
    }
}