五.Redis_事务秒杀案例

5.1 解决计数器和人员记录的事务操作

5.2 Redis 事务 — 秒杀并发模拟

使用工具 ab 模拟测试：

CentOS6 默认安装

CentOS7 需要手动安装

通过 ab 测试

im postfile 模拟表单提交参数， 以 & 符号结尾，存放当前目录。

内容：prodid=0101&

执行：ab -n 2000 -c 200 -k -p ~/postfile -T application/x-www-form-urlencoded

访问：http://192.168.2.115:8081/Seckill/doseckill

超卖

5.3 超卖问题

利用乐观锁淘汰用户，解决超卖问题。

主要代码：

1. public class SecKill_redis {
2. 
3. 	public static void main(String[] args) {
4. 		Jedis jedis =new Jedis("192.168.44.168",6379);
5. 		System.out.println(jedis.ping());
6. 		jedis.close();
7. 	}
8. 
9. 	//秒杀过程
10. 	public static boolean doSecKill(String uid,String prodid) throws IOException {
11. 		//1 uid和prodid非空判断
12. 		if(uid == null || prodid == null) {
13. 			return false;
14. 		}
15. 
16. 		//2 连接redis
17. 		//Jedis jedis = new Jedis("192.168.44.168",6379);
18. 		//通过连接池得到jedis对象
19. 		JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();
20. 		Jedis jedis = jedisPoolInstance.getResource();
21. 
22. 		//3 拼接key
23. 		// 3.1 库存key
24. 		String kcKey = "sk:"+prodid+":qt";
25. 		// 3.2 秒杀成功用户key
26. 		String userKey = "sk:"+prodid+":user";
27. 
28. 		//监视库存
29. 		jedis.watch(kcKey);
30. 
31. 		//4 获取库存，如果库存null，秒杀还没有开始
32. 		String kc = jedis.get(kcKey);
33. 		if(kc == null) {
34. 			System.out.println("秒杀还没有开始，请等待");
35. 			jedis.close();
36. 			return false;
37. 		}
38. 
39. 		// 5 判断用户是否重复秒杀操作
40. 		if(jedis.sismember(userKey, uid)) {
41. 			System.out.println("已经秒杀成功了，不能重复秒杀");
42. 			jedis.close();
43. 			return false;
44. 		}
45. 
46. 		//6 判断如果商品数量，库存数量小于1，秒杀结束
47. 		if(Integer.parseInt(kc)<=0) {
48. 			System.out.println("秒杀已经结束了");
49. 			jedis.close();
50. 			return false;
51. 		}
52. 
53. 		//7 秒杀过程
54. 		//使用事务
55. 		Transaction multi = jedis.multi();
56. 
57. 		//组队操作
58. 		multi.decr(kcKey);
59. 		multi.sadd(userKey,uid);
60. 
61. 		//执行
62. 		List