單機秒殺系統樣例

秒殺系統是你們面試的時候問的最多的東西,咱們寫一個最簡單的單機秒殺樣例（非Web）

咱們是用一個無鎖多線程的例子來模擬一個千人秒殺10件商品。

public class SecKill {
    //商品數量
    private static volatile AtomicInteger count = new AtomicInteger(10);
    //商品隊列
    private static Queue<String> productQueue = new ConcurrentLinkedQueue<String>();
    //用戶隊列
    private static Queue<String> userQueue = new ConcurrentLinkedQueue<String>();
    //用戶與商品配對結果
    private static Map<String,String> userMap = new ConcurrentHashMap<String, String>();
    private static ExecutorService es = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors() * 2);
    private static CountDownLatch end = new CountDownLatch(1000);
    //模擬給商品隊列，用戶隊列添加數據
    public static void addQueue() {
        for (int i = 0;i < 1000;i++) {
            userQueue.add(Integer.toString(i));
        }
        for (int i = 0;i < 10;i++) {
            productQueue.add(Integer.toString(i + 1));
        }
    }
    public static class Kill implements Runnable {
        public void run() {
            if (count.get() > 0) {
                userMap.put(userQueue.poll(), productQueue.poll());
                count.decrementAndGet();
                System.out.println("秒殺成功");
            } else {
                System.out.println("別看了，沒貨了");
            }
            end.countDown();
        }
    }

    public static void main(String[] args) throws InterruptedException {
        addQueue();
        for (int i = 0;i < 1000;i++) {
            es.submit(new Kill());
        }
        end.await();
        System.out.println(count);
        for (String user:userMap.keySet()) {
            System.out.println(user + ":" + userMap.get(user));
        }
        es.shutdown();
    }
}

運行結果：

秒殺成功
秒殺成功
秒殺成功
秒殺成功
秒殺成功
秒殺成功
秒殺成功
秒殺成功
秒殺成功
秒殺成功
別看了，沒貨了
別看了，沒貨了
別看了，沒貨了
別看了，沒貨了
別看了，沒貨了
別看了，沒貨了
別看了，沒貨了

.

.

0
0:1
1:2
2:3
3:4
4:5
5:6
6:7
7:8
8:9
9:10

這個應該是秒殺的最基本的需求，若是改爲Web分佈式秒殺，原理也是同樣，不過要複雜一些，好比限流，分流，分佈式鎖以及MQ對數據庫的操做，對使用暴力秒殺工具的冪等，高防IP等等。