springboot+redis+mybatis体会布隆过滤器

2024-08-31 06:28

本文主要是介绍springboot+redis+mybatis体会布隆过滤器,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.建立数据库表和对应实体类

CREATE TABLE `user` (`id` int(11) NOT NULL AUTO_INCREMENT,`uname` varchar(50) DEFAULT NULL,`usex` varchar(20) DEFAULT NULL,`uage` int(11) DEFAULT NULL,PRIMARY KEY (`id`) USING BTREE
) ENGINE=InnoDB AUTO_INCREMENT=1319 DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC;
public class User {private String id;private String uname;private String usex;private String uage;public String getUname() {return uname;}public void setUname(String uname) {this.uname = uname;}public String getUsex() {return usex;}public void setUsex(String usex) {this.usex = usex;}public String getUage() {return uage;}public void setUage(String uage) {this.uage = uage;}public String getId() {return id;}public void setId(String id) {this.id = id;}
}

2.编写Controller,新增用户和获取用户

@Controller
public class BloomController {@Autowiredprivate BloomService bloomService;@RequestMapping(value = "/addUser")@ResponseBodypublic void addUser(){for(int i=0;i<100;i++){User user = new User();user.setUsex(i + "");user.setUname("user:" + i);user.setUage("26");bloomService.addUser(user);}}@RequestMapping(value = "/getUser")@ResponseBodypublic User getUser(HttpServletRequest request){String userId = request.getParameter("userId");User user = bloomService.getUser(userId);return  user;}}

3.编写servie,实现具体的业务逻辑

public interface BloomService {void addUser(User user);User getUser(String userId);List<String> getUserIds();
}
@Service
public class BloomServiceImpl implements BloomService {public static final String redisKey = "USER:";@Resourceprivate BloomDao bloomDao;@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate BloomCheckUtil bloomCheckUtil;@Overridepublic void addUser(User user) {int i = bloomDao.addUser(user);if(i>0){//mysql插入成功,将数据存入redisUser currentUser = bloomDao.getUser(user.getId());redisTemplate.opsForValue().set(redisKey+user.getId(), JSONObject.toJSONString(currentUser));}}@Overridepublic User getUser(String userId) {User user = null;//1.先从布隆过滤器中获取数据,若没有则直接返回if(!bloomCheckUtil.check(userId)){System.out.println("该用户id:" + userId +"不在合法用户内!!!!");return user;}//2.从redis中查找String rediskey = redisKey + userId;String jsonObj = Optional.ofNullable(redisTemplate.opsForValue().get(rediskey)).map(Object::toString).orElse(null);if(jsonObj == null){//3.redis中没有,查询数据库user = bloomDao.getUser(userId);if(user != null){//4.redis无mysql有,把查询出的数据写入到redis缓存redisTemplate.opsForValue().set(rediskey,JSONObject.toJSONString(user));}return user;}user =JSONObject.parseObject(jsonObj, User.class) ;return user;}@Overridepublic List<String> getUserIds() {return bloomDao.getUserIds();}
}

4.编写dao和mapper,实现数据库操作

public interface BloomDao {int addUser(@Param("user") User user);User getUser(@Param("id")String id);List<String> getUserIds();
}
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.cn.study.redis.dao.BloomDao"><insert id="addUser"  parameterType="com.cn.study.redis.pojo.User" useGeneratedKeys="true" keyProperty="id">insert into user(uname,usex,uage) values (#{user.uname},#{user.usex},#{user.uage})</insert><select id="getUser" resultType="com.cn.study.redis.pojo.User">select u.id ,u.uname ,u.usex ,u.uage  from user u where u.id = #{id}</select><select id="getUserIds" resultType="String">select id from user</select>
</mapper>

5.编写布隆过滤器和工具类

@Component
public class BloomFilter {public static final String key = "LEGITIMATE_USER";@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate BloomService bloomService;@PostConstructpublic void init(){//初始化布隆过滤器//1.从数据库查出user表中的所有id,计算hash值List<String> userIdList = bloomService.getUserIds();for(int i=0;i<userIdList.size();i++){//对每个userId计算hash值并取绝对值int hashValue = Math.abs(("USER:" + userIdList.get(i)).hashCode());//使用hash值对2的32次方取余,得到下标long index = (long)(hashValue % Math.pow(2,32));System.out.println("id为:" + userIdList.get(i)+"的用户产生的hash值为:" + hashValue +",下标为:" + index);//将redis中对应下标的bitmap的值更新成1redisTemplate.opsForValue().setBit(key,index,true);}}
}
@Component
public class BloomCheckUtil {private static final String key = "LEGITIMATE_USER";@Autowiredprivate RedisTemplate redisTemplate;public boolean check(String userId){boolean flag = false;int hashValue = Math.abs(("USER:" + userId).hashCode());long index = (long)(hashValue % Math.pow(2,32));flag = redisTemplate.opsForValue().getBit(key,index);return flag;}}

7.验证

由于第一次启动项目的时候,BloomFilter 类中的init方法会在一开始执行,此时我还并没有调用addUser方法添加用户,数据库中没有任何用户信息,所以第一次启动项目的时候,布隆过滤器中不会有任何的数据。
我们启动项目后,手动调用下addUser方法,新增100条用户数据。
然后重启项目,将用户信息加载到布隆过滤器中。
我们调用getUser方法尝试获取用户信息,当我们传了一个数据库不存在的用户id时,当请求到布隆过滤器,布隆过滤器发现没有此数据,则直接返回,不会再往下查redis和mysql
在这里插入图片描述

这篇关于springboot+redis+mybatis体会布隆过滤器的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1123137

相关文章

Spring Boot + MyBatis Plus 高效开发实战从入门到进阶优化(推荐)

《SpringBoot+MyBatisPlus高效开发实战从入门到进阶优化(推荐)》本文将详细介绍SpringBoot+MyBatisPlus的完整开发流程,并深入剖析分页查询、批量操作、动... 目录Spring Boot + MyBATis Plus 高效开发实战:从入门到进阶优化1. MyBatis

SpringCloud动态配置注解@RefreshScope与@Component的深度解析

《SpringCloud动态配置注解@RefreshScope与@Component的深度解析》在现代微服务架构中,动态配置管理是一个关键需求,本文将为大家介绍SpringCloud中相关的注解@Re... 目录引言1. @RefreshScope 的作用与原理1.1 什么是 @RefreshScope1.

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

MyBatis 动态 SQL 优化之标签的实战与技巧(常见用法)

《MyBatis动态SQL优化之标签的实战与技巧(常见用法)》本文通过详细的示例和实际应用场景,介绍了如何有效利用这些标签来优化MyBatis配置,提升开发效率,确保SQL的高效执行和安全性,感... 目录动态SQL详解一、动态SQL的核心概念1.1 什么是动态SQL?1.2 动态SQL的优点1.3 动态S

Spring Boot 配置文件之类型、加载顺序与最佳实践记录

《SpringBoot配置文件之类型、加载顺序与最佳实践记录》SpringBoot的配置文件是灵活且强大的工具,通过合理的配置管理,可以让应用开发和部署更加高效,无论是简单的属性配置,还是复杂... 目录Spring Boot 配置文件详解一、Spring Boot 配置文件类型1.1 applicatio

Java中StopWatch的使用示例详解

《Java中StopWatch的使用示例详解》stopWatch是org.springframework.util包下的一个工具类,使用它可直观的输出代码执行耗时,以及执行时间百分比,这篇文章主要介绍... 目录stopWatch 是org.springframework.util 包下的一个工具类,使用它

Java进行文件格式校验的方案详解

《Java进行文件格式校验的方案详解》这篇文章主要为大家详细介绍了Java中进行文件格式校验的相关方案,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、背景异常现象原因排查用户的无心之过二、解决方案Magandroidic Number判断主流检测库对比Tika的使用区分zip

Java实现时间与字符串互相转换详解

《Java实现时间与字符串互相转换详解》这篇文章主要为大家详细介绍了Java中实现时间与字符串互相转换的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录一、日期格式化为字符串(一)使用预定义格式(二)自定义格式二、字符串解析为日期(一)解析ISO格式字符串(二)解析自定义

Java使用Curator进行ZooKeeper操作的详细教程

《Java使用Curator进行ZooKeeper操作的详细教程》ApacheCurator是一个基于ZooKeeper的Java客户端库,它极大地简化了使用ZooKeeper的开发工作,在分布式系统... 目录1、简述2、核心功能2.1 CuratorFramework2.2 Recipes3、示例实践3

Springboot处理跨域的实现方式(附Demo)

《Springboot处理跨域的实现方式(附Demo)》:本文主要介绍Springboot处理跨域的实现方式(附Demo),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录Springboot处理跨域的方式1. 基本知识2. @CrossOrigin3. 全局跨域设置4.