springboot集成redis实现简单秒杀系统

下面我将详细讲解“springboot集成redis实现简单秒杀系统”的完整攻略。

一、准备工作

1.1 安装Redis

首先需要安装Redis，在官网下载Redis并进行安装，安装完成后启动Redis服务。

1.2 创建SpringBoot项目

使用IDEA等开发工具创建SpringBoot项目，并在pom.xml中添加Redis依赖。

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

二、代码实现

2.1 配置Redis连接

在application.properties文件中添加Redis连接信息，并在代码中创建JedisPool。

spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.database=0

@Configuration
public class RedisConfig {

    @Value("${spring.redis.host}")
    private String host;

    @Value("${spring.redis.port}")
    private int port;

    @Bean
    public JedisPool jedisPool() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        return new JedisPool(jedisPoolConfig, host, port);
    }
}

2.2 实现秒杀功能

2.2.1 商品减库存

@Service
public class SecKillService {

    private static final String STOCK_PREFIX = "stock:";

    @Autowired
    private JedisPool jedisPool;

    /**
     * 减库存
     *
     * @param productId 商品ID
     * @return true：成功，false：失败
     */
    public boolean decrStock(String productId) {
        try (Jedis jedis = jedisPool.getResource()) {
            String key = STOCK_PREFIX + productId;
            Long result = jedis.decr(key);
            return result >= 0;
        }
    }
}

2.2.2 购买商品

@Service
public class SecKillService {

    private static final String STOCK_PREFIX = "stock:";
    private static final String ORDER_PREFIX = "order:";

    @Autowired
    private JedisPool jedisPool;

    /**
     * 购买商品
     *
     * @param productId 商品ID
     * @return true：成功，false：失败
     */
    public boolean buy(String productId) {
        try (Jedis jedis = jedisPool.getResource()) {
            String key = STOCK_PREFIX + productId;
            String orderKey = ORDER_PREFIX + UUID.randomUUID().toString();
            jedis.watch(key);
            long stock = Long.parseLong(jedis.get(key));
            if (stock > 0) {
                Transaction transaction = jedis.multi();
                transaction.decr(key);
                transaction.sadd(orderKey, productId);
                transaction.exec();
                return true;
            } else {
                jedis.unwatch();
            }
        }
        return false;
    }
}

三、测试运行

3.1 测试商品减库存

在代码中调用decrStock方法，测试商品减库存是否成功。

@RunWith(SpringRunner.class)
@SpringBootTest
public class SecKillServiceTest {

    @Autowired
    private SecKillService secKillService;

    @Test
    public void testDecrStock() {
        String productId = "10001";
        boolean result = secKillService.decrStock(productId);
        System.out.println("减库存结果：" + result);
    }
}

3.2 测试购买商品

在代码中调用buy方法，测试购买商品是否成功。

@RunWith(SpringRunner.class)
@SpringBootTest
public class SecKillServiceTest {

    @Autowired
    private SecKillService secKillService;

    @Test
    public void testBuy() {
        String productId = "10001";
        boolean result = secKillService.buy(productId);
        System.out.println("购买商品结果：" + result);
    }
}

这便是“springboot集成redis实现简单秒杀系统”的完整攻略，希望对您有所帮助。