SpringBoot+RabbitMQ+Redis实现商品秒杀的示例代码

以下是“SpringBoot+RabbitMQ+Redis实现商品秒杀的示例代码”的完整攻略，包含两个示例说明。

简介

商品秒杀是一种高并发场景，需要使用分布式系统来实现。本教程将介绍如何使用SpringBoot、RabbitMQ和Redis实现商品秒杀，并提供相应的示例说明。

步骤1：添加依赖

在SpringBoot应用程序中，可以使用以下依赖来实现商品秒杀：

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

<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
</dependency>

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

示例1：使用RabbitMQ实现商品秒杀

以下是一个使用RabbitMQ实现商品秒杀的示例：

1. 创建RabbitMQ配置类

@Configuration
public class RabbitMQConfig {
    @Bean
    public Queue queue() {
        return new Queue("seckill.queue", true);
    }
}

在这个示例中，我们创建了一个名为RabbitMQConfig的RabbitMQ配置类，并使用@Bean注解创建了一个名为seckill.queue的队列。

2. 创建秒杀服务

@Service
public class SeckillService {
    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void seckill(String userId, String productId) {
        rabbitTemplate.convertAndSend("seckill.exchange", "seckill.routingKey", userId + ":" + productId);
    }
}

在这个示例中，我们创建了一个名为SeckillService的秒杀服务，并使用RabbitTemplate发送秒杀请求到RabbitMQ。

3. 创建秒杀消费者

@Component
public class SeckillConsumer {
    @Autowired
    private RedisTemplate<String, Integer> redisTemplate;

    @RabbitListener(queues = "seckill.queue")
    public void consume(String message) {
        String[] parts = message.split(":");
        String userId = parts[0];
        String productId = parts[1];
        Integer stock = redisTemplate.opsForValue().get(productId);
        if (stock != null && stock > 0) {
            redisTemplate.opsForValue().decrement(productId);
            System.out.println("秒杀成功：" + userId + ":" + productId);
        } else {
            System.out.println("秒杀失败：" + userId + ":" + productId);
        }
    }
}

在这个示例中，我们创建了一个名为SeckillConsumer的秒杀消费者，并使用@RabbitListener注解监听名为seckill.queue的队列。在消费者中，我们使用RedisTemplate来减少商品库存，并输出秒杀结果。

4. 测试

在测试中，我们可以使用SeckillService发送秒杀请求，使用redis-cli命令行工具查看商品库存。

示例2：使用Redis实现商品秒杀

以下是一个使用Redis实现商品秒杀的示例：

1. 创建秒杀服务

@Service
public class SeckillService {
    @Autowired
    private RedisTemplate<String, Integer> redisTemplate;

    public void seckill(String userId, String productId) {
        String key = "seckill:" + productId;
        Long stock = redisTemplate.opsForValue().decrement(key);
        if (stock >= 0) {
            System.out.println("秒杀成功：" + userId + ":" + productId);
        } else {
            redisTemplate.opsForValue().increment(key);
            System.out.println("秒杀失败：" + userId + ":" + productId);
        }
    }
}

在这个示例中，我们创建了一个名为SeckillService的秒杀服务，并使用RedisTemplate来减少商品库存，并输出秒杀结果。

2. 测试