springboot+shiro-redis+maven

1.所用的依赖配置

org.springframework.bootspring-boot-starterorg.springframework.bootspring-boot-starter-testtestorg.springframework.bootspring-boot-starter-tomcatprovidedorg.mybatis.spring.bootmybatis-spring-boot-starter2.1.0mysqlmysql-connector-javaorg.springframework.bootspring-boot-starter-testtestorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-data-redisorg.springframework.bootspring-boot-starter-cacheorg.crazycakeshiro-redis3.2.3org.apache.shiroshiro-core1.4.1org.apache.shiroshiro-spring1.4.1

src/main/java**/*.xmlsrc/main/resources
2.application.yml配置> #主配置文件 server:   port: 8084
> 
> #配置文件入口 spring:   profiles:
>     active: dev
>     #active: prod
> #mybatis: type-aliases-package: com.example.redisdemo.entity
> > application-dev.yml配置
#开发环境
> 
> #JDBC配置 spring:   #默认数据源   datasource:
>     #type: com.alibaba.druid.pool.DruidDataSource
>     url: "jdbc:mysql://xxx:3306/test?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true&autoReconnect=true&serverTimezone=GMT%2B8"
>     username: xxx
>     password: xxx
>     driverClassName: com.mysql.cj.jdbc.Driver
>     initialSize: 20  #初始化大小
>     minIdle: 5  #空闲连接池的大小
>     maxActive: 50 #最大激活数量
> 
>   #Redis数据库   redis:
>     host: 127.0.0.1
>     port: 6379
>     password:
>     database: 2
>     timeout: 10000
>     jedis:
>       pool:
>         max-idle: 10
>         min-idle: 0
>         max-active: 20
>         max-wait: -1

3.Redis基本配置

     //取redis连接配置@Value("${spring.redis.host}")private String host;@Value("${spring.redis.port}")private int port;@Value("${spring.redis.database}")private int database;@Value("${spring.redis.password}")private String password;@Value("${spring.redis.timeout}")private int timeout;@Value("${spring.redis.jedis.pool.max-idle}")private int max_idle;@Value("${spring.redis.jedis.pool.min-idle}")private int min_idle;@Value("${spring.redis.jedis.pool.max-active}")private int max_active;@Value("${spring.redis.jedis.pool.max-wait}")private int max_wait;
/********************************** Redis配置 ***********************************/
/*** 配置shiro redisManager* 使用的是shiro-redis开源插件** @return*/
@Bean
public RedisManager redisManager() {RedisManager redisManager = new RedisManager();GenericObjectPoolConfig genericObjectPoolConfig = new GenericObjectPoolConfig();genericObjectPoolConfig.setMaxIdle(max_idle);genericObjectPoolConfig.setMinIdle(min_idle);genericObjectPoolConfig.setMaxTotal(max_active);genericObjectPoolConfig.setMaxWaitMillis(max_wait);JedisPool jedisPool = new JedisPool(genericObjectPoolConfig,host,port,timeout,null,database);redisManager.setJedisPool(jedisPool);// redisManager.setPassword(password);return redisManager;
}/*** cacheManager 缓存 redis实现* 使用的是shiro-redis开源插件** @return*/
@Bean
public RedisCacheManager cacheManager1() {RedisCacheManager redisCacheManager = new RedisCacheManager();redisCacheManager.setRedisManager(redisManager());return redisCacheManager;
}/*** Session Manager* 使用的是shiro-redis开源插件*/
@Bean
public DefaultWebSessionManager sessionManager() {DefaultWebSessionManager sessionManager = new DefaultWebSessionManager();sessionManager.setSessionDAO(redisSessionDAO());return sessionManager;
}/*** RedisSessionDAO shiro sessionDao层的实现 通过redis* 使用的是shiro-redis开源插件*/
@Bean
public RedisSessionDAO redisSessionDAO() {RedisSessionDAO redisSessionDAO = new RedisSessionDAO();redisSessionDAO.setRedisManager(redisManager());return redisSessionDAO;
}

注意：
在SpringBoot项目中，将值存入Redis缓存中，会出现乱码的问题
原因：因为spring-data-redis里面对key和value都进行了序列化，将其变成byte[]数组后再调用对应的redis java client进行存储。就会导致存进redis的key发生改变。
解决方法：需要手动定义序列化如下
CacheConfig 自己重新写一个配置

> @Configuration 
> @EnableCaching //开启注解
>  public class CacheConfig extends CachingConfigurerSupport {
>     @Bean
>     public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
>         StringRedisTemplate template = new StringRedisTemplate(factory);
>         //定义key序列化方式
>         //定义value的序列化方式
>         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
>         ObjectMapper om = new ObjectMapper();
>         om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
>         om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
>         jackson2JsonRedisSerializer.setObjectMapper(om);
>         template.setValueSerializer(jackson2JsonRedisSerializer);
>         template.setHashValueSerializer(jackson2JsonRedisSerializer);
>         template.afterPropertiesSet();
>         return template;
>     } 
> }

4.controller配置

@Autowired
private UserService userService@RequestMapping("/findUserById")
@ResponseBody
public Map findUserById(int id){User user = userService.findUserById(id);Map result = new HashMap<>();result.put("uid",user.getUid());result.put("uname",user.getUsername());result.put("upassword",user.getPassword());return result;
}@RequestMapping("/hello")
@ResponseBody
public String hello(){System.out.println("UserController.hello()");return "ok";
}service配置@Autowired
private UserDao userDao;@Autowired
private RedisTemplate redisTemplate;//返回一个数组
public List queryAll(){return userDao.queryAll();
}/*** 获取用户策略：先从缓存中获取用户，没有则取数据表中 数据，再将数据写入缓存*/
public User findUserById(int id){String key = "user_"+id;ValueOperations operations = redisTemplate.opsForValue();boolean haskey = redisTemplate.hasKey(key);if (haskey){User user = operations.get(key);System.out.println("==============从缓存里面获取数据==============");System.out.println(user.getUsername());System.out.println("===========================================");return user;}else {User user = userDao.findUserById(id);System.out.println("==============从缓存里面获取数据==============");System.out.println(user.getUsername());System.out.println("===========================================");//把从数据表里面获取的数据写入缓存方便下次取出operations.set(key,user,5, TimeUnit.HOURS);return user;}
}/*** 更新用户策略：先更新数据表，成功之后，删除原来的缓存，再更新缓存*/
public int updateUser(User user){ValueOperations operations = redisTemplate.opsForValue();int result = userDao.updateUser(user);if (result != 0){String key = "user_" + user.getUid();boolean haskey = redisTemplate.hasKey(key);if (haskey){redisTemplate.delete(key);System.out.println("删除缓存中的key======>"+key);}//再将更新后的数据加入缓存User userNew = userDao.findUserById(user.getUid());if (userNew != null){operations.set(key,user,3,TimeUnit.HOURS);}}return result;
}/*** 删除用户策略：删除数据表中数据，然后删除缓存*/
public int deleteUserById(int id){int result = userDao.deleteUserById(id);String key = "user_" + id;if (result != 0){boolean haskey = redisTemplate.hasKey(key);if (haskey){redisTemplate.delete(key);System.out.println("删除了缓存中的key:"+key);}}return result;
}

UserDao.xml 与 Userdao 名字一定要相等 不然会出错
xml配置：

select * from user where uid = #{id}

springboot启动类的配置关键

> @EnableCaching 
> @MapperScan(basePackages = "com.example.redisdemo.dao")
> 这俩个注解必须有
> > dao层
>  @Repository public interface UserDao {
> 
>    List queryAll();
> 
>    @Select("select * from user where uid = #{id}")    User
> findUserById(@Param("id") int id);
> 
>    int updateUser(@Param("user") User user);
> 
>    int deleteUserById(int id);
}

实体类entity

> public class User implements Serializable {
> 
>     private static final long serialVersionUID = 1L;
> 
>     private Integer uid;
> 
>     private String username;
> 
>     private String password;
> 
> 
> 
> }

springboot-redis配置目录结构

访问路径：http://localhost:8084/findUserById?id=1
运行结果：
浏览器上：

后台：

redis展示结果:

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！