单机秒杀系统样例

秒杀系统是你们面试的时候问的最多的东西,咱们写一个最简单的单机秒杀样例（非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等等。