:ambulance:redis队列超卖情况的分析以及解决方案

src/main/java/com/itstyle/seckill/queue/redis/RedisConsumer.java

@@ -1,38 +1,40 @@
-package com.itstyle.seckill.queue.redis;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import com.itstyle.seckill.common.entity.Result;
-import com.itstyle.seckill.common.enums.SeckillStatEnum;
-import com.itstyle.seckill.common.redis.RedisUtil;
-import com.itstyle.seckill.common.webSocket.WebSocketServer;
-import com.itstyle.seckill.service.ISeckillService;
-/**
- * 消费者
- * @author 科帮网 By https://blog.52itstyle.com
- */
-@Service
-public class RedisConsumer {
-	
-	@Autowired
-	private ISeckillService seckillService;
-	@Autowired
-	private RedisUtil redisUtil;
-	
-    public void receiveMessage(String message) {
-        //收到通道的消息之后执行秒杀操作(超卖)
-    	String[] array = message.split(";"); 
-    	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(), "秒杀成功");//推送给前台
-    		}else{
-    			WebSocketServer.sendInfo(array[0].toString(), "秒杀失败");//推送给前台
-    			redisUtil.cacheValue(array[0], "ok");//秒杀结束
-    		}
-    	}else{
-    		WebSocketServer.sendInfo(array[0].toString(), "秒杀失败");//推送给前台
-    	}
-    }
+package com.itstyle.seckill.queue.redis;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.itstyle.seckill.common.entity.Result;
+import com.itstyle.seckill.common.enums.SeckillStatEnum;
+import com.itstyle.seckill.common.redis.RedisUtil;
+import com.itstyle.seckill.common.webSocket.WebSocketServer;
+import com.itstyle.seckill.service.ISeckillService;
+/**
+ * 消费者
+ * @author 科帮网 By https://blog.52itstyle.vip
+ */
+@Service
+public class RedisConsumer {
+	
+	@Autowired
+	private ISeckillService seckillService;
+	@Autowired
+	private RedisUtil redisUtil;
+	
+    public void receiveMessage(String message) {
+		Thread th=Thread.currentThread();
+		System.out.println("Tread name:"+th.getName());
+        //收到通道的消息之后执行秒杀操作(超卖)
+    	String[] array = message.split(";"); 
+    	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], "秒杀成功");//推送给前台
+    		}else{
+    			WebSocketServer.sendInfo(array[0], "秒杀失败");//推送给前台
+    			redisUtil.cacheValue(array[0], "ok");//秒杀结束
+    		}
+    	}else{
+    		WebSocketServer.sendInfo(array[0], "秒杀失败");//推送给前台
+    	}
+    }
 }

src/main/java/com/itstyle/seckill/queue/redis/RedisSubListenerConfig.java

@@ -1,32 +1,48 @@
-package com.itstyle.seckill.queue.redis;
-
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.listener.PatternTopic;
-import org.springframework.data.redis.listener.RedisMessageListenerContainer;
-import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
-
-@Configuration
-public class RedisSubListenerConfig {
-    //初始化监听器
-    @Bean
-    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
-            MessageListenerAdapter listenerAdapter) {
-        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
-        container.setConnectionFactory(connectionFactory);
-        container.addMessageListener(listenerAdapter, new PatternTopic("seckill"));
-        return container;
-    }
-    //利用反射来创建监听到消息之后的执行方法
-    @Bean
-    MessageListenerAdapter listenerAdapter(RedisConsumer redisReceiver) {
-        return new MessageListenerAdapter(redisReceiver, "receiveMessage");
-    }
-   //使用默认的工厂初始化redis操作模板
-    @Bean
-    StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
-        return new StringRedisTemplate(connectionFactory);
-    }
+package com.itstyle.seckill.queue.redis;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.listener.PatternTopic;
+import org.springframework.data.redis.listener.RedisMessageListenerContainer;
+import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
+
+import java.util.concurrent.*;
+
+@Configuration
+public class RedisSubListenerConfig {
+    //初始化监听器
+    @Bean
+    RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
+            MessageListenerAdapter listenerAdapter) {
+        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
+        container.setConnectionFactory(connectionFactory);
+        container.addMessageListener(listenerAdapter, new PatternTopic("seckill"));
+        /**
+         * 如果不定义线程池，每一次消费都会创建一个线程，如果业务层面不做限制，就会导致秒杀超卖
+         */
+        ThreadFactory factory = new ThreadFactoryBuilder()
+                .setNameFormat("redis-listener-pool-%d").build();
+        Executor executor = new ThreadPoolExecutor(
+                1,
+                1,
+                5L,
+                TimeUnit.SECONDS,
+                new LinkedBlockingQueue<>(1000),
+                factory);
+        container.setTaskExecutor(executor);
+        return container;
+    }
+    //利用反射来创建监听到消息之后的执行方法
+    @Bean
+    MessageListenerAdapter listenerAdapter(RedisConsumer redisReceiver) {
+        return new MessageListenerAdapter(redisReceiver, "receiveMessage");
+    }
+   //使用默认的工厂初始化redis操作模板
+    @Bean
+    StringRedisTemplate template(RedisConnectionFactory connectionFactory) {
+        return new StringRedisTemplate(connectionFactory);
+    }
 }

src/main/java/com/itstyle/seckill/web/SeckillPageController.java

@@ -55,7 +55,7 @@ public class SeckillPageController {
 		return Result.ok(List);
 	}
 	
-	@RequestMapping("/startSeckill")
+	@PostMapping("/startSeckill")
     public Result  startSeckill(String ticket,String randstr,HttpServletRequest request) {
         HttpMethod method =HttpMethod.POST;
         MultiValueMap<String, String> params= new LinkedMultiValueMap<String, String>();