模拟秒杀1

 

package com.anyec.goodsKill.controller;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicBoolean;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
public class KillController {
	private static final String ORDERINFO = "ORDERINFO";
	final String GOODSCACHE="goods-id";
	
	static ExecutorService pools=Executors.newFixedThreadPool(100);
	static AtomicBoolean ab=new AtomicBoolean(true);
	
	static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
	@Resource 
	RedisTemplate<String,Integer> redisTemplate;
	java.util.concurrent.atomic.AtomicInteger userids=new java.util.concurrent.atomic.AtomicInteger ();
	@RequestMapping("killPage")
	@ResponseBody
	public String killPage(){
		try {
			if((new Date()).after(sdf.parse("2018-09-20 16:05:00")))
				return "<h1>秒杀</h1><a href=\"secondsKill\">秒杀</a>";
			
		} catch (ParseException e) {
			e.printStackTrace();
		}
		return "等待开始";
	}
	
	@RequestMapping("secondsKill")
	@ResponseBody
	public Callable secondsKill(HttpServletRequest request){
		
		Callable call=	new Callable(){

			@Override
			public Object call() throws Exception {
				if(ab.get()){
					Integer i=redisTemplate.opsForList().leftPop(GOODSCACHE);
					if(i!=null&&i>0){
						redisTemplate.opsForHash().put(ORDERINFO, "USER"+userids.incrementAndGet(), i);
						return "success";
					}else{
						ab.set(false);
						return "failure";
					}
				}else{
					return "failure";
				}
			}
			
		};
		
		pools.submit(call);
		return call;
	}
	
	@RequestMapping("initStock")
	@ResponseBody
	public String initStock(@RequestParam("stockNum")Integer stockNum){
		redisTemplate.delete(GOODSCACHE);
		redisTemplate.delete(ORDERINFO);
		Integer ars[] = new Integer[stockNum];
		for(int i=0;i<stockNum;i++){
			ars[i]=i+1;
		}
		redisTemplate.opsForList().leftPushAll(GOODSCACHE, ars);
		return "ok";
	}
	@RequestMapping("listStock")
	@ResponseBody
	public List<Integer> listStock(){
		List<Integer> list=redisTemplate.boundListOps(GOODSCACHE).range(0, redisTemplate.boundListOps(GOODSCACHE).size()-1);
		return list;
	}
	@RequestMapping("clearStock")
	@ResponseBody
	public String clearStock(){
		redisTemplate.delete(GOODSCACHE);
		redisTemplate.delete(ORDERINFO);
		ab.set(true);
		return "ok";
	}
	@RequestMapping("listOrder")
	@ResponseBody
	public Object listOrder(){
		List<Object> list=redisTemplate.boundHashOps(ORDERINFO).values();
		list.sort(new Comparator<Object>() {

			@Override
			public int compare(Object x, Object y) {
				return Integer.compare((Integer)x, (Integer)y);
			}
		});
		return list;
	}
	
	@RequestMapping("test")
	@ResponseBody
	public Object test(){
		Callable call=	new Callable(){

			@Override
			public Object call() throws Exception {
				return "ok";
			}
			
		};
		
		pools.submit(call);
		return call;
	}
}