快捷導(dǎo)航

redis防止重復(fù)提交的實(shí)現(xiàn)示例

更新時(shí)間：2024年06月06日 11:28:46 作者：MurphyGuan

在開發(fā)中我們都需要處理重復(fù)提交的問題,本文主要介紹了redis防止重復(fù)提交的實(shí)現(xiàn)示例,具有一定的參考價(jià)值,感興趣的可以了解一下

第一次遇到這個(gè)問題，是在我們的app點(diǎn)贊功能發(fā)現(xiàn)的。產(chǎn)品要求點(diǎn)贊只能點(diǎn)一次，但是發(fā)現(xiàn)快速多次點(diǎn)贊也是可以成功的。因?yàn)榭蛻舳嗽诘谝淮握埱蠼涌诤螅€沒有來得及把點(diǎn)贊圖標(biāo)置灰，就發(fā)起了第二次請求。

最后這個(gè)問題的解決方案是利用redis原子特性解決，在接口請求后設(shè)置一個(gè)短有效期的緩存，下次接口請求時(shí)繼續(xù)設(shè)置這個(gè)緩存，如果緩存沒有設(shè)置成功則代表重復(fù)提交。

下面說一下具體實(shí)現(xiàn)：

1.redis依賴

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

2.redis配置

package com.example.redis.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * redis配置類
 * @author murphy
 * @date 2024/6/6
 */
@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(connectionFactory);
        template.setKeySerializer(new StringRedisSerializer());
        template.setValueSerializer(new GenericJackson2JsonRedisSerializer());
        return template;
    }
}

3.application.yml配置redis連接信息

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    database: 0

4.redis緩存操作實(shí)現(xiàn)

在這里我們使用RedisTemplate的setIfAbsent方法設(shè)置了緩存并設(shè)置了一個(gè)10s的有效期，具體過期時(shí)間可以根據(jù)業(yè)務(wù)來定。setIfAbsent方法的意思是如果緩存之前不存在，設(shè)置成功后返回true。如果緩存之前存在了則不進(jìn)行設(shè)置并且返回false。

package com.example.redis.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.concurrent.TimeUnit;

/**
 * redis操作實(shí)現(xiàn)
 * @author murphy
 * @date 2024/6/6
 */
@Service
public class RedisService {

    private static final int TTL = 10; // 過期時(shí)間，單位是秒

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    public boolean preventDuplicateSubmission(String userId) {
        String key = "praise_:" + userId;
        Boolean success = redisTemplate.opsForValue().setIfAbsent(key, "1", TTL, TimeUnit.SECONDS);
        return Boolean.TRUE.equals(success);
    }
}

5.測試

我們可以根據(jù)preventDuplicateSubmission方法的返回結(jié)果來判斷是否屬于重復(fù)提交。下面模擬多次請求：

@Test
void contextLoads() {
  boolean res1 = redisService.preventDuplicateSubmission("1");
  System.out.println("第一次提交結(jié)果:" + res1);
  boolean res2 = redisService.preventDuplicateSubmission("1");
  System.out.println("第二次提交結(jié)果:" + res2);
  boolean res3 = redisService.preventDuplicateSubmission("1");
  System.out.println("第三次提交結(jié)果:" + res3);
}

返回結(jié)果：