ZF/spring-boot-seckill
1
0
Fork 0
mirror of https://gitee.com/52itstyle/spring-boot-seckill.git synced 2026-03-01 15:50:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

zk分布式锁案例

Browse Source
This commit is contained in:
小柒2012
2018-08-01 09:06:04 +08:00
parent 11ea796aaf
commit 84502c2b74
5 changed files with 73 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/itstyle/seckill/queue/redis/RedisConsumer.java
View File

@@ -23,7 +23,7 @@ public class RedisConsumer {
public void receiveMessage(String message) {
//收到通道的消息之后执行秒杀操作(超卖)
String[] array = message.split(";");
if(redisUtil.getValue(array[0])==null){//control层已经判断了，其实这里不需要再判断了
if(redisUtil.getValue(array[0])!=null){//control层已经判断了，其实这里不需要再判断了
Result result = seckillService.startSeckilDBPCC_TWO(Long.parseLong(array[0]), Long.parseLong(array[1]));
if(result.equals(Result.ok(SeckillStatEnum.SUCCESS))){
WebSocketServer.sendInfo(array[0].toString(), "秒杀成功");//推送给前台