springboot中redis的缓存穿透问题实现

@Service
public class NewsService {
  @Autowired
  private NewsDAO newsDAO;

  //springboot自动初始化，不需要我们进行配置，直接注入到代码中使用
  @Autowired
  private RedisTemplate<Object,Object> redisTemplate;

  public /*synchronized*/ List<News> getLatestNews(int userId,int offset,int limit){

    //设置序列化方式，防止乱码
    redisTemplate.setKeySerializer(new StringRedisSerializer());

    //第一步：查询缓存
    News news= (News) redisTemplate.opsForValue().get("newsKey");
    //判断是否存在缓存
    if(null == news){//查询数据库
        news = newsDAO.selectByUserIdAndOffset(userId,offset,limit).get(0);
        //
        redisTemplate.opsForValue().set("newsKey",news);

        System.out.println("进入数据库。。。。。。。。");
      
    }else{
      System.out.println("进入缓存。。。。。。。。。");
    }
    return newsDAO.selectByUserIdAndOffset(userId,offset,limit);

  }
}

@Controller
public class HomeController {
  @Autowired
  UserService userService;

  @Autowired
  NewsService newsService;

  //遇到的坑，如果不加method，页面启动不起来。
  @RequestMapping(value = "/home",method = {RequestMethod.GET, RequestMethod.POST})
  @ResponseBody
  public String index(Model model){
    //这边是可以读出数据来的

    //线程池------缓存穿透问题的复现
    ExecutorService executorService = Executors.newFixedThreadPool(8*2);

    for(int i = 0;i < 50000;i++){
      executorService.submit(new Runnable() {
        @Override
        public void run() {
          List<News> newsList = newsService.getLatestNews(0,0,10);
        }
      });
    }

    List<News> newsList = newsService.getLatestNews(0,0,10);
    News news=newsList.get(0);
    return news.getImage();
  }
}

@Service
public class NewsService {
  @Autowired
  private NewsDAO newsDAO;

  //springboot自动初始化，不需要我们进行配置，直接注入到代码中使用
  @Autowired
  private RedisTemplate<Object,Object> redisTemplate;

  //第一种方式：方法加锁
  public synchronized List<News> getLatestNews(int userId,int offset,int limit){

    //设置序列化方式，防止乱码
    redisTemplate.setKeySerializer(new StringRedisSerializer());

    //第一步：查询缓存
    News news= (News) redisTemplate.opsForValue().get("newsKey");
    //判断是否存在缓存
    if(null == news){
//查询数据库
        news = newsDAO.selectByUserIdAndOffset(userId,offset,limit).get(0);
        //
        redisTemplate.opsForValue().set("newsKey",news);

        System.out.println("进入数据库。。。。。。。。");

    }else{
      System.out.println("进入缓存。。。。。。。。。");
    }


    return newsDAO.selectByUserIdAndOffset(userId,offset,limit);

  }
}

@Service
public class NewsService {
  @Autowired
  private NewsDAO newsDAO;

  //springboot自动初始化，不需要我们进行配置，直接注入到代码中使用
  @Autowired
  private RedisTemplate<Object,Object> redisTemplate;

  //第一种方式：方法加锁
  public /*synchronized*/ List<News> getLatestNews(int userId,int offset,int limit){

    //设置序列化方式，防止乱码
    redisTemplate.setKeySerializer(new StringRedisSerializer());

    //第一步：查询缓存
    News news= (News) redisTemplate.opsForValue().get("newsKey");
    //判断是否存在缓存
    if(null == news){

      //第二种方式：双重检测锁
      synchronized (this){
        //查询数据库
        news = newsDAO.selectByUserIdAndOffset(userId,offset,limit).get(0);
        //
        redisTemplate.opsForValue().set("newsKey",news);

        System.out.println("进入数据库。。。。。。。。");
      }

    }else{
      System.out.println("进入缓存。。。。。。。。。");
    }


    return newsDAO.selectByUserIdAndOffset(userId,offset,limit);

  }
}