秒殺功能

秒殺場(chǎng)景現(xiàn)在已經(jīng)非常常見(jiàn)了，各種電商平臺(tái)都有秒殺的產(chǎn)品，接下來(lái)我們模擬一個(gè)秒殺的項(xiàng)目，最終能夠確保高并發(fā)下的線程安全。界面比較簡(jiǎn)單，但是功能基本實(shí)現(xiàn)。

界面

點(diǎn)擊“秒殺點(diǎn)我”按鈕后臺(tái)就會(huì)輸出秒殺結(jié)果。

第一版

使用Redis緩存數(shù)據(jù)庫(kù)，使用一個(gè)key-value存儲(chǔ)秒殺商品數(shù)量，使用set集合存儲(chǔ)秒殺成功的用戶。我們以商品0101為示例，設(shè)置商品的初始數(shù)量為200件。不考慮并發(fā)問(wèn)題，實(shí)現(xiàn)功能。

html、jsp、servlet文件不重要省略。

package com.redis.secondskill; import java.util.List; import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.Transaction; public class SS0 { public static boolean doSecKill(String uid,String prodid) { JedisPool jedisPool = JedisPollTool.getInstance(); Jedis jedis = jedisPool.getResource(); String productCountStr = 'sec:'+prodid+':count'; String productUserStr = 'sec:'+prodid+':user'; String productCount = jedis.get(productCountStr); if(null == productCount) { System.out.println('秒殺還沒(méi)有開(kāi)始'); JedisPollTool.distroy(jedisPool, jedis); return false; } if(jedis.sismember(productUserStr, uid)) { System.out.println(uid + '用戶已經(jīng)秒殺成功'); JedisPollTool.distroy(jedisPool, jedis); return false; } int prodCount = Integer.parseInt(productCount); if(prodCount <= 0) { System.out.println('秒殺結(jié)束'); JedisPollTool.distroy(jedisPool, jedis); return false; } jedis.decr(productCountStr); jedis.sadd(productUserStr, uid); JedisPollTool.distroy(jedisPool, jedis); System.out.println(uid + '秒殺成功'); return true; }}

使用linux httpd-tools工具進(jìn)行并發(fā)測(cè)試。

ab -n 1000 -c 200 -p /test/file.txt -T 'application/x-www-form-urlencoded' 192.168.0.101:8080/redis-demo/ss

結(jié)果

從結(jié)果大致來(lái)看，沒(méi)有什么問(wèn)題，來(lái)查看一個(gè)后臺(tái)Redis的數(shù)據(jù)

秒殺的結(jié)果里面居然有負(fù)數(shù)，證明賣超了。

第二版

使用Redis的事務(wù)，保證沒(méi)有超賣的情況發(fā)生。

package com.redis.secondskill; import java.util.List; import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.Transaction; public class SS1 { public static boolean doSecKill(String uid,String prodid) { JedisPool jedisPool = JedisPollTool.getInstance(); Jedis jedis = jedisPool.getResource(); String productCountStr = 'sec:'+prodid+':count'; String productUserStr = 'sec:'+prodid+':user'; jedis.watch(productCountStr); //開(kāi)始監(jiān)視 String productCount = jedis.get(productCountStr); if(null == productCount) { System.out.println('秒殺還沒(méi)有開(kāi)始'); JedisPollTool.distroy(jedisPool, jedis); return false; } if(jedis.sismember(productUserStr, uid)) { System.out.println(uid + '用戶已經(jīng)秒殺成功'); JedisPollTool.distroy(jedisPool, jedis); return false; } int prodCount = Integer.parseInt(productCount); if(prodCount <= 0) { System.out.println('秒殺結(jié)束'); JedisPollTool.distroy(jedisPool, jedis); return false; } Transaction transaction = jedis.multi(); transaction.decr(productCountStr); transaction.sadd(productUserStr, uid); List<Object> exec = transaction.exec(); if(exec == null || exec.size() == 0) { System.out.println('秒殺失敗，稍后重試'); JedisPollTool.distroy(jedisPool, jedis); return false; } JedisPollTool.distroy(jedisPool, jedis); System.out.println(uid + '秒殺成功'); return true; }}

結(jié)果

由于使用了watch和事務(wù)，每次的并發(fā)線程訪問(wèn)中只有一個(gè)線程能夠提交成功，可以保證不出現(xiàn)超賣的現(xiàn)象，但是對(duì)于一些用戶來(lái)說(shuō)是極其不公平的。

第三版

使用Lua腳本來(lái)實(shí)現(xiàn)，因?yàn)镽edis是單線程的，又是C語(yǔ)言編寫(xiě)的，可以使用Lua調(diào)用Redis的命令，Lua會(huì)具有排他性，所以能夠保證安全。

package com.redis.secondskill; import java.util.HashSet;import java.util.Set; import redis.clients.jedis.HostAndPort;import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool; public class SS2 { static String luaScript ='local userid=KEYS[1];rn' + 'local prodid=KEYS[2];rn' + 'local qtkey=’sec:’..prodid..':count';rn' + 'local usersKey=’sec:’..prodid..':user';rn' + 'local userExists=redis.call('sismember',usersKey,userid);rn' + 'if tonumber(userExists)==1 then rn' + ' return 2;rn' + 'endrn' + 'local num = redis.call('get' ,qtkey);rn' + 'if tonumber(num)<=0 then rn' + ' return 0;rn' + 'else rn' + ' redis.call('decr',qtkey);rn' + ' redis.call('sadd',usersKey,userid);rn' + 'endrn' + 'return 1' ; public static boolean doSecKill(String uid,String prodid) { JedisPool jedisPool = JedisPollTool.getInstance(); Jedis jedis = jedisPool.getResource(); String sha1 = jedis.scriptLoad(luaScript); Object result= jedis.evalsha(sha1, 2, uid,prodid); String reString=String.valueOf(result); if ('0'.equals( reString ) ) { System.err.println('已搶空！！'); }else if('1'.equals( reString ) ) { System.out.println(uid + '搶購(gòu)成功！！！！'); }else if('2'.equals( reString ) ) { System.err.println('該用戶已搶過(guò)！！'); }else{ System.err.println('搶購(gòu)異常！！'); } JedisPollTool.distroy(jedisPool, jedis); return true; }}

結(jié)果

這才是我們最希望看到的結(jié)果！

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。