springboot整合redisson,spring boot整合redis

一、项目创建

1.1 创建项目

在想法中，文件-新建-项目春天初始值设定项名称为springboot-mysql-redis

1.2 目录结构

1.3 pom.xml配置文件

spring :数据源：驱动程序类名称： com。MySQL。CJ。JDBC。驱动URL : JDBC :我的SQL ://localhost :3306/mybatis？服务器时区=UTC用户名： root密码： 1234 redis :主机：本地主机端口： 6379服务器：端口： 8080 mybatis :映射器-位置：类路径：映射器/* XML类型-别名-包： com。xsbc。实体#开启驼峰命名配置：地图下划线到驼色：真

二、初始化数据库

如果存在博客，则删除数据库；创建数据库博客；用户博客；如果存在用户，则删除表；create table user(id int(11)not null，name varchar(255) DEFAULT ，age int(11) DEFAULT 0，PRIMARY KEY(id))ENGINE=INNODB DEFAULT CHARSET=utf8；插入到用户值(1,中小王,20);插入到用户值(2,中老李,23);

三、初始化代码

3.1 实体类entity

@ Data @ NoArgsConstructor @ AllArgsConstructorpublic class User { private int id；私有字符串名称；私人年龄；}

3.2 Mapper接口类

@ mapper公共接口用户映射器{ list user getAllUsers()；int updateUser(整数id)；}xml映射文件

　　？可扩展标记语言版本=1.0 编码=UTF八号？DOCTYPE Mapper PUBLIC -//mybatis。org//DTD Mapper 3.0//EN http://my batis。org/DTD/mybatis-3-Mapper。“DTD”映射器命名空间=“com。xsbc。制图师。用户映射器 select id= get all users result type= com。xsbc。实体。用户 select * from user/select！-用户类的编号参数是（同国际组织)国际组织类型，mysql默认是整数更新id=updateUser

　　AgeById" parameterType="java.lang.Integer"> update user set age=age+2 where id=#{id} </update></mapper>

3.3 Redis工具类

1）config包创建类

　　Redis常量类RedisConstant

public class RedisConstant { public static String ALL_USER_KEY="allUser";}

Redis配置类RedisConfig

@Configurationpublic class RedisConfig { @Resource private RedisTemplate redisTemplate; @Bean public RedisTemplate redisTemplateInit(){ //序列化key的实例化对象 redisTemplate.setKeySerializer(new StringRedisSerializer()); //序列化value的实例化对象 redisTemplate.setValueSerializer( new GenericJackson2JsonRedisSerializer()); return redisTemplate; }}

2）util包下创建类

@Componentpublic class RedisUtil { @Resource private RedisTemplate<String,Object> redisTemplate; public void setRedisTemplate(RedisTemplate<String,Object> redisTemplate){ this.redisTemplate=redisTemplate; } // 指定缓存失效时间 public boolean expire(String key,long time) { try { if (time > 0) { redisTemplate.expire(key, time, TimeUnit.SECONDS); } return true; } catch (Exception e) { e.printStackTrace(); return false; } // 根据key获取过期时间 public long getExpire(String key){ return redisTemplate.getExpire(key,TimeUnit.SECONDS); // 判断key是否存在 public boolean hasKey(String key){ return redisTemplate.hasKey(key); }catch(Exception e){ // 删除缓存 @SuppressWarnings("unchecked") public void del(String... key){ if (key!=null&&key.length> 0){ if (key.length==1) { redisTemplate.delete(key[0]); }else{ redisTemplate.delete( (Collection<String>)CollectionUtils.arrayToList(key)); // 普通缓存获取 public Object get(String key){ return key==null?null:redisTemplate.opsForValue().get(key); // 普通缓存放入 public boolean set(String key,Object value){ redisTemplate.opsForValue().set(key,value); // 普通缓存放入并设置时间 public boolean set(String key,Object value,long time){ try{ if(time>0){ redisTemplate.opsForValue() .set(key,value,time,TimeUnit.SECONDS); set(key,value); // 递增 public long incr(String key,long delta){ if(delta<0){ throw new RuntimeException("递增因子必须大于0"); return redisTemplate.opsForValue().increment(key,delta); // 递减 public long decr(String key, long delta){ throw new RuntimeException("递减因子必须大于0"); return redisTemplate.opsForValue().increment(key,-delta); // HashGet public Object hget(String key,String item){ return redisTemplate.opsForHash().get(key,item); // 获取hashKey对应的所有键值 public Map<Object, Object> hmget(String key){ return redisTemplate.opsForHash().entries(key); // HashSet public boolean hmset(String key,Map<String, Object> map){ redisTemplate.opsForHash().putAll(key,map); // HashSet 并设置时间 public boolean hmset(String key,Map<String, Object> map,long time){ redisTemplate.opsForHash().putAll(key, map); if (time>0){ expire(key,time); // 向一张hash表中放入数据,如果不存在将创建 public boolean hset(String key,String item,Object value){ redisTemplate.opsForHash().put(key,item,value); public boolean hset(String key,String item,Object value,long time){ // 删除hash表中的值 public void hdel(String key,Object... item) { redisTemplate.opsForHash().delete(key,item); // 判断hash表中是否有该项的值 public boolean hHasKey(String key,String item) { return redisTemplate.opsForHash().hasKey(key,item); // hash递增 如果不存在,就会创建一个 并把新增后的值返回 public double hincr(String key,String item,double by) { return redisTemplate.opsForHash().increment(key,item,by); // hash递减 public double hdecr(String key,String item,double by) { return redisTemplate.opsForHash().increment(key,item,-by); // 根据key获取Set中的所有值 public Set<Object> sGet(String key) { return redisTemplate.opsForSet().members(key); return null; // 根据value从一个set中查询,是否存在 public boolean sHasKey(String key,Object value) { return redisTemplate.opsForSet().isMember(key,value); // 将数据放入set缓存 public long sSet(String key,Object... values) { return redisTemplate.opsForSet().add(key,values); return 0; // 将set数据放入缓存 public long sSetAndTime(String key,long time,Object... values){ Long count=redisTemplate.opsForSet().add(key,values); if (time> 0)expire(key, time); return count; // 获取set缓存的长度 public long sGetSetSize(String key){ return redisTemplate.opsForSet().size(key); // 移除值为value的 public long setRemove(String key,Object... values){ Long count=redisTemplate.opsForSet().remove(key,values); // 获取list缓存的内容 public List<Object> lGet(String key,long start,long end){ return redisTemplate.opsForList().range(key,start,end); // 获取list缓存的长度 public long lGetListSize(String key){ return redisTemplate.opsForList().size(key); // 通过索引 获取list中的值 public Object lGetIndex(String key,long index){ return redisTemplate.opsForList().index(key,index); // 将list放入缓存 public boolean lSet(String key, Object value){ redisTemplate.opsForList().rightPush(key,value); public boolean lSet(String key,Object value,long time){ if (time > 0) expire(key, time); public boolean lSet(String key, List<Object> value){ redisTemplate.opsForList().rightPushAll(key,value); public boolean lSet(String key,List<Object> value,long time){ if(time>0) expire(key, time); // 根据索引修改list中的某条数据 public boolean lUpdateIndex(String key,long index,Object value){ redisTemplate.opsForList().set(key,index,value); // 移除N个值为value public long lRemove(String key,long count,Object value){ Long remove=redisTemplate.opsForList().remove(key,count,value); return remove;}

3.4 Service层

1）UserService接口类

public interface UserService { public List<User> getAllUsers(); public void updateUserAge();}

2）接口实现类

@Service("userService")public class UserServiceImpl implements UserService { @Resource private UserMapper userMapper; @Autowired private RedisUtil redisUtil; @Override public List<User> getAllUsers() { List<User> users=(List<User>)redisUtil .get(RedisConstant.ALL_USER_KEY); if(CollectionUtils.isEmpty(users)){ users=userMapper.getAllUsers(); redisUtil.set(RedisConstant.ALL_USER_KEY,users); } return users; } @Transactional public void updateUserAge() { redisUtil.del(RedisConstant.ALL_USER_KEY); userMapper.updateUserAgeById(1); userMapper.updateUserAgeById(2);}

3.5 Controller层

@Controllerpublic class UserController { @Autowired private UserService userService; @RequestMapping("/getAll") @ResponseBody public List<User> getUsers(){ return userService.getAllUsers(); } @RequestMapping("/update") @ResponseBody public int updateUser(){ userService.updateUserAge(); return 1; }}

四、单元测试

4.1 Respository和Service层单元测试

@SpringBootTestclass SpringbootMysqlRedisApplicationTests { @Autowired private UserMapper userMapper; private UserService userService; @Test void testUserMapper(){ userMapper.updateUserAgeById(1); List<User> users=userMapper.getAllUsers(); for(User user:users){ System.out.println(user); } } void testUserService(){ userService.updateUserAge(); List<User> users=userService.getAllUsers();}

4.2 Controller层接口测试

　　到此这篇关于SpringBoot整合Mysql、Redis的文章就介绍到这了,更多相关SpringBoot整合Mysql、Redis内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT！

郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。

springboot整合redisson,spring boot整合redis_1

目录