1.请求参数为空判断

先看一下效果图，需要输入phone、password缺少其中一项时提示缺少的字段
image.png
具体实现步骤

  1. public class LoginCodeDto {
  2.     @NotBlank
  3.     private String phone;
  4.     @NotBlank
  5.     private String code;
  6.     @NotNull
  7.     private Double price;
  8.     @NotEmpty
  9.     private Set<String> page;
  10. }
  • @NotNull：不能为null，但可以为empty (“”,” “,” “)
  • @NotEmpty：不能为null，而且长度必须大于0 (“ “,” “)
  • @NotBlank：只能作用在String上，不能为null，而且调用trim()后，长度必须大于0 (“test”) 即：必须有实际字符
  • 注意：一定得是装箱类型

捕获该异常信息

  1. @ExceptionHandler(MethodArgumentNotValidException.class)
  2.     @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
  3.     public ResponseVo<String> notValidExceptionHandle(MethodArgumentNotValidException e) {
  4.         BindingResult bindingResult = e.getBindingResult();
  5.         Objects.requireNonNull(bindingResult.getFieldError());
  6.         return ResponseVo.error(ResponseEnum.PARAM_ERROR,
  7.                 bindingResult.getFieldError().getField() + " " + bindingResult.getFieldError().getDefaultMessage());
  8.     }

加上@Valid才能生效

  1. @PostMapping("/passwordLogin")
  2.     ResponseVo<LoginDataInfo> passwordLogin(@Valid @RequestBody LoginPasswordDto passwordDto) {
  3.         return memberService.passwordLogin(passwordDto);
  4.     }

2.解决springboot跨域问题

  1. @Configuration
  2. public class CorsConfig implements WebMvcConfigurer {
  3.     @Override
  4.     public void addCorsMappings(CorsRegistry registry) {
  5.         registry.addMapping("/**")
  6.                 .allowedOrigins("*")
  7.                 .allowedMethods("GET", "HEAD", "POST", "PUT", "DELETE", "OPTIONS")
  8.                 .allowCredentials(true)
  9.                 .maxAge(7200)
  10.                 .allowedHeaders("*");
  11.     }
  12. }

3.环境配置注解Profile

使用方法非常的简单注解加到配置类或者Service上面就可以了。
如下两个使用场景：

1.使用在定时任务

希望定时发送邮件的任务在线上跑，但是测试环境和开发环境不跑，那我就这样配置。

  1. @Configuration
  2. @EnableScheduling
  3. @RequiredArgsConstructor(onConstructor = @__(@Autowired))
  4. @Slf4j
  5. @Profile(value = {"prod"})
  6. public class SchedulingTaskServiceImpl implements SchedulingTaskService {}

2.swagger

测试环境才允许看到swagger，线上不允许看到这种隐私的接口文档。

  1. @Configuration
  2. @EnableSwagger2
  3. @Profile(value = { "test"})
  4. public class SwaggerConfiguration implements WebMvcConfigurer {}

4. Redis秒杀超卖问题

1.没有加任何锁的情况下

  1. /**
  2.  * @author 杨胖胖
  3.  */
  4. public interface OversoldService {
  5.     /**
  6.      * redis解决超卖的问题
  7.      * @param repertory 库存id
  8.      * @param userId    用户id
  9.      * @return 秒杀结果
  10.      */
  11.     boolean oversold(String repertory, String userId);
  12. }
  1. /**
  2.  * @author 杨胖胖
  3.  */
  4. @Service
  5. @RequiredArgsConstructor(onConstructor = @__(@Autowired))
  6. @Slf4j
  7. public class OversoldServiceImpl implements OversoldService {
  8.     private final RedisTemplate<String, String> redisTemplate;
  10.     @Override
  11.     public boolean oversold(String repertory, String userId) {
  12.         // 拼接的用户id
  13.         String userIdKey = "userId:";
  14.         // 库存为null的时候，秒杀还没有开始
  15.         String repertoryNum = redisTemplate.opsForValue().get(repertory);
  16.         if (StringUtils.isEmpty(repertoryNum)) {
  17.             log.info("秒杀未开始");
  18.             return false;
  19.         }
  20.         // 判断用户是否重复秒杀
  21.         Boolean isOversold = redisTemplate.opsForSet().isMember(userIdKey, userId);
  22.         assert isOversold != null;
  23.         if (isOversold) {
  24.             log.info("已秒杀成功，不能重复秒杀");
  25.             return false;
  26.         }
  27.         // 商品数量少于1，秒杀结束
  28.         if (Integer.parseInt(repertoryNum) <= 0) {
  29.             log.info("秒杀已经结束了");
  30.             return false;
  31.         }
  32.         // 库存-1
  33.         redisTemplate.opsForValue().decrement(repertory);
  34.         // 把秒杀成功用户添加清单里面
  35.         redisTemplate.opsForSet().add(userIdKey, userId);
  36.         log.info("秒杀成功了");
  37.         return true;
  38.     }
  39. }
  1. /**
  2.  * @author 杨胖胖
  3.  */
  4. @RestController
  5. @RequiredArgsConstructor(onConstructor = @__(@Autowired))
  6. public class OversoldController {
  8.     private final OversoldService oversoldService;
  10.     @GetMapping("oversold")
  11.     public boolean oversold(@RequestParam String repertory, @RequestParam String userId) {
  12.         return oversoldService.oversold(repertory, userId);
  13.     }
  14. }

库存添加10个后执行的效果，这里使用了jmeter作为压测的工具，只有10个商品但是11个人秒杀成功了，商品数量-1，建议并发多测试几次才能看到效果，我是1000个线程并发。
image.png

image.png

2.使用redis的乐观锁解决

  1. /**
  2.  * @author 杨胖胖
  3.  */
  4. @Service
  5. @RequiredArgsConstructor(onConstructor = @__(@Autowired))
  6. @Slf4j
  7. public class OversoldServiceImpl implements OversoldService {
  9.     private final RedisTemplate<String, String> redisTemplate;
  11.     @Override
  12.     public boolean oversold(String repertory, String userId) {
  13.         // 拼接的用户id
  14.         String userIdKey = "userId:";
  15.         // 监视库存
  16.         redisTemplate.watch(repertory);
  17.         // 开启事务不然会报错
  18.         redisTemplate.setEnableTransactionSupport(true);
  19.         // 库存为null的时候，秒杀还没有开始
  20.         String repertoryNum = redisTemplate.opsForValue().get(repertory);
  21.         if (StringUtils.isEmpty(repertoryNum)) {
  22.             log.info("秒杀未开始");
  23.             return false;
  24.         }
  25.         // 判断用户是否重复秒杀
  26.         Boolean isOversold = redisTemplate.opsForSet().isMember(userIdKey, userId);
  27.         assert isOversold != null;
  28.         if (isOversold) {
  29.             log.info("已秒杀成功，不能重复秒杀");
  30.             return false;
  31.         }
  32.         // 商品数量少于1，秒杀结束
  33.         if (Integer.parseInt(repertoryNum) <= 0) {
  34.             log.info("秒杀已经结束了");
  35.             return false;
  36.         }
  37.         // 使用事务
  38.         redisTemplate.multi();
  39.         // 组队操作
  40.         redisTemplate.opsForValue().decrement(repertory);
  41.         redisTemplate.opsForSet().add(userIdKey, userId);
  42.         // 执行
  43.         List<Object> result = redisTemplate.exec();
  44.         if(result.size() == 0){
  45.             log.info("秒杀失败了");
  46.             return false;
  47.         }
  48.         log.info("秒杀成功了");
  49.         return true;
  50.     }
  51. }

2.1 乐观锁引发的库存问题

库存500，并发数1000个就可以导致这个问题，我的电脑上面是这样。
image.png

2.2 使用lua脚本解决库存问题

  1. /**
  2.  * @author 杨胖胖
  3.  */
  4. @Service
  5. @RequiredArgsConstructor(onConstructor = @__(@Autowired))
  6. @Slf4j
  7. public class OversoldServiceImpl implements OversoldService {
  9.     private final RedisTemplate<String, String> redisTemplate;
  11.     @Override
  12.     public boolean oversold(String repertory, String userId) {
  13.         Long skillResult = skill(repertory, userId);
  14.         if (skillResult == 0) {
  15.             log.info("已抢空！！");
  16.             return true;
  17.         } else if (skillResult == 1) {
  18.             log.info("抢购成功！！！！");
  19.             return true;
  20.         } else if (skillResult == 2) {
  21.             log.info("该用户已抢过！！");
  22.             return true;
  23.         } else {
  24.             log.info("抢购异常！！");
  25.             return true;
  26.         }
  27.     }
  29.     public Long skill(String repertory, String userId) {
  30.         String secKillScript = "local userid=KEYS[1];\r\n" +
  31.                 "local prodid=KEYS[2];\r\n" +
  32.                 "local qtkey=prodid;\r\n" +
  33.                 "local usersKey='userid';\r\n" +
  34.                 "local userExists=redis.call(\"sismember\",usersKey,userid);\r\n" +
  35.                 "if tonumber(userExists)==1 then \r\n" +
  36.                 "   return 2;\r\n" +
  37.                 "end\r\n" +
  38.                 "local num= redis.call(\"get\" ,qtkey);\r\n" +
  39.                 "if tonumber(num)<=0 then \r\n" +
  40.                 "   return 0;\r\n" +
  41.                 "else \r\n" +
  42.                 "   redis.call(\"decr\",qtkey);\r\n" +
  43.                 "   redis.call(\"sadd\",usersKey,userid);\r\n" +
  44.                 "end\r\n" +
  45.                 "return 1";
  46.         List<String> keys = new ArrayList<>();
  47.         keys.add(userId);
  48.         keys.add(repertory);
  49.         DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>(secKillScript, Long.class);
  50.         return redisTemplate.execute(redisScript, keys, userId, repertory);
  51.     }
  52. }

同样是500的库存，1000的线程数，执行后库存为0，购买成功人数500，完美解决！！！

3.最后献上我的jmeter脚本

image.png

image.png

5.Redis配置代码

  1. import org.springframework.context.annotation.Bean;
  2. import org.springframework.context.annotation.Configuration;
  3. import org.springframework.data.redis.connection.RedisConnectionFactory;
  4. import org.springframework.data.redis.core.RedisTemplate;
  5. import org.springframework.data.redis.serializer.JdkSerializationRedisSerializer;
  6. import org.springframework.data.redis.serializer.RedisSerializer;
  7. import org.springframework.data.redis.serializer.StringRedisSerializer;
  9. import java.util.Map;
  11. /**
  12.  * @author 杨胖胖
  13.  */
  14. @Configuration
  15. public class RedisConfig {
  16.     @Bean(name = "redisTemplate")
  17.     public RedisTemplate<String, Object> getRedisTemplate(RedisConnectionFactory factory) {
  18.         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
  19.         redisTemplate.setConnectionFactory(factory);
  20.         // key的序列化类型
  21.         redisTemplate.setKeySerializer(new StringRedisSerializer());
  22.         // value的序列化类型
  23.         redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
  24.         return redisTemplate;
  25.     }
  27.     @Bean(name = "redisTemplateMap")
  28.     public RedisTemplate<String, Map<String, String>> getRedisMapTemplate(RedisConnectionFactory factory) {
  29.         RedisTemplate<String, Map<String, String>> redisTemplate = new RedisTemplate<>();
  30.         redisTemplate.setConnectionFactory(factory);
  31.         // key的序列化类型
  32.         redisTemplate.setKeySerializer(RedisSerializer.string());
  33.         // value的序列化类型
  34.         redisTemplate.setValueSerializer(RedisSerializer.string());
  35.         redisTemplate.setHashValueSerializer(RedisSerializer.string());
  36.         redisTemplate.setHashKeySerializer(RedisSerializer.string());
  37.         return redisTemplate;
  38.     }
  39. }