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