// 商品實(shí)體類
public class Product {
    private String id;
    private String name;
    private int stock;

    // 省略構(gòu)造方法和Getter/Setter
}

// 秒殺訂單實(shí)體類
public class Order {
    private String id;
    private String productId;
    private String userId;
    private Date createTime;

    // 省略構(gòu)造方法和Getter/Setter
}

// 秒殺服務(wù)類
@Service
public class SeckillService {
    private static final int MAX_STOCK = 100; // 商品的最大庫(kù)存數(shù)量

    private final Map<String, Product> products = new ConcurrentHashMap<>(); // 商品信息
    private final Set<String> seckillUsers = new HashSet<>(); // 已秒殺用戶

    @PostConstruct
    public void init() {
        // 初始化商品信息
        Product product = new Product("1", "iPhone 12", MAX_STOCK);
        products.put(product.getId(), product);
    }

    // 執(zhí)行秒殺操作
    public synchronized boolean seckill(String productId, String userId) {
        // 判斷商品是否存在
        Product product = products.get(productId);
        if (product == null) {
            return false;
        }

        // 判斷商品庫(kù)存是否足夠
        if (product.getStock() <= 0) {
            return false;
        }

        // 判斷用戶是否已經(jīng)秒殺過(guò)
        if (seckillUsers.contains(userId)) {
            return false;
        }

        // 執(zhí)行秒殺邏輯
        product.setStock(product.getStock() - 1);
        Order order = new Order(UUID.randomUUID().toString(), productId, userId, new Date());
        // 保存訂單信息到數(shù)據(jù)庫(kù)或消息隊(duì)列等
        // ...

        // 添加已秒殺用戶
        seckillUsers.add(userId);

        return true;
    }
}

// 秒殺控制器
@RestController
public class SeckillController {
    private final SeckillService seckillService;

    public SeckillController(SeckillService seckillService) {
        this.seckillService = seckillService;
    }

    @PostMapping("/seckill")
    public String seckill(@RequestParam("productId") String productId,
                          @RequestParam("userId") String userId) {
        boolean success = seckillService.seckill(productId, userId);
        if (success) {
            return "秒殺成功";
        } else {
            return "秒殺失敗";
        }
    }
}

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.UUID;
import java.util.concurrent.TimeoutException;

public class SeckillProducer {

    private static final String QUEUE_NAME = "seckillQueue";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 創(chuàng)建連接工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("guest");
        factory.setPassword("guest");

        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            // 聲明隊(duì)列
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            // 模擬秒殺請(qǐng)求
            String productId = "12345";
            String userId = UUID.randomUUID().toString();

            // 發(fā)送秒殺消息到隊(duì)列
            String message = productId + "," + userId;
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
            System.out.println("秒殺消息發(fā)送成功：" + message);
        }
    }
}

import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class SeckillConsumer {

    private static final String QUEUE_NAME = "seckillQueue";

    public static void main(String[] args) throws IOException, TimeoutException {
        // 創(chuàng)建連接工廠
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        factory.setUsername("guest");
        factory.setPassword("guest");

        // 創(chuàng)建連接
        Connection connection = factory.newConnection();

        // 創(chuàng)建通道
        Channel channel = connection.createChannel();

        // 聲明隊(duì)列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

        // 創(chuàng)建消費(fèi)者
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println("收到秒殺消息：" + message);

                // 處理秒殺邏輯
                processSeckillMessage(message);

                // 手動(dòng)確認(rèn)消息已被消費(fèi)
                channel.basicAck(envelope.getDeliveryTag(), false);
            }
        };

        // 監(jiān)聽(tīng)隊(duì)列并消費(fèi)消息
        channel.basicConsume(QUEUE_NAME, false, consumer);
    }

    private static void processSeckillMessage(String message) {
        // 解析消息，執(zhí)行秒殺邏輯
        String[] parts = message.split(",");
        String productId = parts[0];
        String userId = parts[1];

        // 執(zhí)行秒殺操作
        // ...
    }
}