发表于: 2020-06-28 23:49:46

1 1630


今天完成的事情


springboot+redis


<!--    redis依赖   -->
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-data-redis</artifactId>
       </dependency>



yml里的redis设置


# Redis数据库索引(默认为0
spring.redis.database: 0
# Redis服务器地址
spring.redis.host: localhost
# Redis服务器连接端口
spring.redis.port: 6379
# Redis服务器连接密码(默认为空)
spring.redis.password: 123456
#连接池最大连接数(使用负值表示没有限制)
spring.redis.pool.max-active: 8
# 连接池最大阻塞等待时间(使用负值表示没有限制)
spring.redis.pool.max-wait: -1
# 连接池中的最大空闲连接
spring.redis.pool.max-idle: 8
# 连接池中的最小空闲连接
spring.redis.pool.min-idle: 0
# 连接超时时间(毫秒)
spring.redis.timeout: 300



Redis自己的 Config配置文件


package com.ptteng.springbootone.Redis;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.cache.annotation.CachingConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.*;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;


@Configuration
@EnableCaching //开启注解
public class RedisConfig extends CachingConfigurerSupport {

   
   @Bean
   public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {

       RedisTemplate<String, Object> template = new RedisTemplate<>();
       // 配置连接工厂
       template.setConnectionFactory(factory);

       //使用Jackson2JsonRedisSerializer来序列化和反序列化redisvalue值(默认使用JDK的序列化方式)
       Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);

       ObjectMapper om = new ObjectMapper();
       // 指定要序列化的域,field,getset,以及修饰符范围,ANY是都有包括privatepublic
       om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
       // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如String,Integer等会跑出异常
       om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
       jacksonSeial.setObjectMapper(om);

       // 值采用json序列化
       template.setValueSerializer(jacksonSeial);
       //使用StringRedisSerializer来序列化和反序列化rediskey
       template.setKeySerializer(new StringRedisSerializer());

       // 设置hash key value序列化模式
       template.setHashKeySerializer(new StringRedisSerializer());
       template.setHashValueSerializer(jacksonSeial);
       template.afterPropertiesSet();

       return template;
   }

   /**
    * hash类型的数据操作
    *
    * @param redisTemplate
    * @return
    */
   @Bean
   public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {
       return redisTemplate.opsForHash();
   }

   /**
    * redis字符串类型数据操作
    *
    * @param redisTemplate
    * @return
    */
   @Bean
   public ValueOperations<String, Object> valueOperations(RedisTemplate<String, Object> redisTemplate) {
       return redisTemplate.opsForValue();
   }

   /**
    * 对链表类型的数据操作
    *
    * @param redisTemplate
    * @return
    */
   @Bean
   public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {
       return redisTemplate.opsForList();
   }

   /**
    * 对无序集合类型的数据操作
    *
    * @param redisTemplate
    * @return
    */
   @Bean
   public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {
       return redisTemplate.opsForSet();
   }

   /**
    * 对有序集合类型的数据操作
    *
    * @param redisTemplate
    * @return
    */
   @Bean
   public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
       return redisTemplate.opsForZSet();
   }

}


redis的工具类

RedisUtil.class

package com.ptteng.springbootone.Redis;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;


@Component
public class RedisUtil {

   @Autowired
   private RedisTemplate<String, Object> redisTemplate;

   public RedisUtil(RedisTemplate<String, Object> redisTemplate) {
       this.redisTemplate = redisTemplate;
   }

   /**
    * 指定缓存失效时间
    * @param key
    * @param time 时间()
    * @return
    */
   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 获取过期时间
    * @param key 键 不能为null
    * @return 时间() 返回0代表为永久有效
    */
   public long getExpire(String key){
       return redisTemplate.getExpire(key,TimeUnit.SECONDS);
   }

   /**
    * 判断key是否存在
    * @param key
    * @return true 存在 false不存在
    */
   public boolean hasKey(String key){
       try {
           return redisTemplate.hasKey(key);
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 删除缓存
    * @param key 可以传一个值 或多个
    */
   @SuppressWarnings("unchecked")
   public void del(String ... key){
       if(key!=null&&key.length>0){
           if(key.length==1){
               redisTemplate.delete(key[0]);
           }else{
               redisTemplate.delete(CollectionUtils.arrayToList(key));
           }
       }
   }

   //============================String=============================
   /**
    * 普通缓存获取
    * @param key
    * @return
    */
   public Object get(String key){
       return key==null?null:redisTemplate.opsForValue().get(key);
   }

   /**
    * 普通缓存放入
    * @param key
    * @param value
    * @return true成功 false失败
    */
   public boolean set(String key,Object value) {
       try {
           redisTemplate.opsForValue().set(key, value);
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 普通缓存放入并设置时间
    * @param key
    * @param value
    * @param time 时间() time要大于0 如果time小于等于0 将设置无限期
    * @return true成功 false 失败
    */
   public boolean set(String key,Object value,long time){
       try {
           if(time>0){
               redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
           }else{
               set(key, value);
           }
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 递增
    * @param key
    * @param delta 要增加几(大于0)
    * @return
    */
   public long incr(String key, long delta){
       if(delta<0){
           throw new RuntimeException("递增因子必须大于0");
       }
       return redisTemplate.opsForValue().increment(key, delta);
   }

   /**
    * 递减
    * @param key
    * @param delta 要减少几(小于0)
    * @return
    */
   public long decr(String key, long delta){
       if(delta<0){
           throw new RuntimeException("递减因子必须大于0");
       }
       return redisTemplate.opsForValue().increment(key, -delta);
   }

   //================================Map=================================
   /**
    * HashGet
    * @param key 键 不能为null
    * @param item 项 不能为null
    * @return
    */
   public Object hget(String key,String item){
       return redisTemplate.opsForHash().get(key, item);
   }

   /**
    * 获取hashKey对应的所有键值
    * @param key
    * @return 对应的多个键值
    */
   public Map<Object,Object> hmget(String key){
       return redisTemplate.opsForHash().entries(key);
   }

   /**
    * HashSet
    * @param key
    * @param map 对应多个键值
    * @return true 成功 false 失败
    */
   public boolean hmset(String key, Map<String,Object> map){
       try {
           redisTemplate.opsForHash().putAll(key, map);
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * HashSet 并设置时间
    * @param key
    * @param map 对应多个键值
    * @param time 时间()
    * @return true成功 false失败
    */
   public boolean hmset(String key, Map<String,Object> map, long time){
       try {
           redisTemplate.opsForHash().putAll(key, map);
           if(time>0){
               expire(key, time);
           }
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 向一张hash表中放入数据,如果不存在将创建
    * @param key
    * @param item
    * @param value
    * @return true 成功 false失败
    */
   public boolean hset(String key,String item,Object value) {
       try {
           redisTemplate.opsForHash().put(key, item, value);
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 向一张hash表中放入数据,如果不存在将创建
    * @param key
    * @param item
    * @param value
    * @param time 时间()  注意:如果已存在的hash表有时间,这里将会替换原有的时间
    * @return true 成功 false失败
    */
   public boolean hset(String key,String item,Object value,long time) {
       try {
           redisTemplate.opsForHash().put(key, item, value);
           if(time>0){
               expire(key, time);
           }
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 删除hash表中的值
    * @param key 键 不能为null
    * @param item 项 可以使多个 不能为null
    */
   public void hdel(String key, Object... item){
       redisTemplate.opsForHash().delete(key,item);
   }

   /**
    * 判断hash表中是否有该项的值
    * @param key 键 不能为null
    * @param item 项 不能为null
    * @return true 存在 false不存在
    */
   public boolean hHasKey(String key, String item){
       return redisTemplate.opsForHash().hasKey(key, item);
   }

   /**
    * hash递增 如果不存在,就会创建一个 并把新增后的值返回
    * @param key
    * @param item
    * @param by 要增加几(大于0)
    * @return
    */
   public double hincr(String key, String item,double by){
       return redisTemplate.opsForHash().increment(key, item, by);
   }

   /**
    * hash递减
    * @param key
    * @param item
    * @param by 要减少记(小于0)
    * @return
    */
   public double hdecr(String key, String item,double by){
       return redisTemplate.opsForHash().increment(key, item,-by);
   }

   //============================set=============================
   /**
    * 根据key获取Set中的所有值
    * @param key
    * @return
    */
   public Set<Object> sGet(String key){
       try {
           return redisTemplate.opsForSet().members(key);
       } catch (Exception e) {
           e.printStackTrace();
           return null;
       }
   }

   /**
    * 根据value从一个set中查询,是否存在
    * @param key
    * @param value
    * @return true 存在 false不存在
    */
   public boolean sHasKey(String key,Object value){
       try {
           return redisTemplate.opsForSet().isMember(key, value);
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 将数据放入set缓存
    * @param key
    * @param values 值 可以是多个
    * @return 成功个数
    */
   public long sSet(String key, Object...values) {
       try {
           return redisTemplate.opsForSet().add(key, values);
       } catch (Exception e) {
           e.printStackTrace();
           return 0;
       }
   }

   /**
    * set数据放入缓存
    * @param key
    * @param time 时间()
    * @param values 值 可以是多个
    * @return 成功个数
    */
   public long sSetAndTime(String key,long time,Object...values) {
       try {
           Long count = redisTemplate.opsForSet().add(key, values);
           if(time>0) {
               expire(key, time);
           }
           return count;
       } catch (Exception e) {
           e.printStackTrace();
           return 0;
       }
   }

   /**
    * 获取set缓存的长度
    * @param key
    * @return
    */
   public long sGetSetSize(String key){
       try {
           return redisTemplate.opsForSet().size(key);
       } catch (Exception e) {
           e.printStackTrace();
           return 0;
       }
   }

   /**
    * 移除值为value
    * @param key
    * @param values 值 可以是多个
    * @return 移除的个数
    */
   public long setRemove(String key, Object ...values) {
       try {
           Long count = redisTemplate.opsForSet().remove(key, values);
           return count;
       } catch (Exception e) {
           e.printStackTrace();
           return 0;
       }
   }
   //===============================list=================================

   /**
    * 获取list缓存的内容
    * @param key
    * @param start 开始
    * @param end 结束  0 -1代表所有值
    * @return
    */
   public List<Object> lGet(String key, long start, long end){
       try {
           return redisTemplate.opsForList().range(key, start, end);
       } catch (Exception e) {
           e.printStackTrace();
           return null;
       }
   }

   /**
    * 获取list缓存的长度
    * @param key
    * @return
    */
   public long lGetListSize(String key){
       try {
           return redisTemplate.opsForList().size(key);
       } catch (Exception e) {
           e.printStackTrace();
           return 0;
       }
   }

   /**
    * 通过索引 获取list中的值
    * @param key
    * @param index 索引  index>=0时, 0 表头,1 第二个元素,依次类推;index<0时,-1,表尾,-2倒数第二个元素,依次类推
    * @return
    */
   public Object lGetIndex(String key,long index){
       try {
           return redisTemplate.opsForList().index(key, index);
       } catch (Exception e) {
           e.printStackTrace();
           return null;
       }
   }

   /**
    * list放入缓存
    * @param key
    * @param value
    * @return
    */
   public boolean lSet(String key, Object value) {
       try {
           redisTemplate.opsForList().rightPush(key, value);
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * list放入缓存
    * @param key
    * @param value
    * @param time 时间()
    * @return
    */
   public boolean lSet(String key, Object value, long time) {
       try {
           redisTemplate.opsForList().rightPush(key, value);
           if (time > 0) {
               expire(key, time);
           }
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * list放入缓存
    * @param key
    * @param value
    * @return
    */
   public boolean lSet(String key, List<Object> value) {
       try {
           redisTemplate.opsForList().rightPushAll(key, value);
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * list放入缓存
    * @param key
    * @param value
    * @param time 时间()
    * @return
    */
   public boolean lSet(String key, List<Object> value, long time) {
       try {
           redisTemplate.opsForList().rightPushAll(key, value);
           if (time > 0) {
               expire(key, time);
           }
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 根据索引修改list中的某条数据
    * @param key
    * @param index 索引
    * @param value
    * @return
    */
   public boolean lUpdateIndex(String key, long index,Object value) {
       try {
           redisTemplate.opsForList().set(key, index, value);
           return true;
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
   }

   /**
    * 移除N个值为value
    * @param key
    * @param count 移除多少个
    * @param value
    * @return 移除的个数
    */
   public long lRemove(String key,long count,Object value) {
       try {
           Long remove = redisTemplate.opsForList().remove(key, count, value);
           return remove;
       } catch (Exception e) {
           e.printStackTrace();
           return 0;
       }
   }

}


有自定义工具类的话,redis代码就简便了许多

因为我们已经自己封装好了方法和返回值

项目中直接使用即可。




springboot+security 认证


<!--    springboot-security所需依赖    -->
       
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-security</artifactId>
       </dependency>


无需其他配置文件    web的  jsp配置好就行

server.port: 8080

#要支持jsp,需要在application.properties中配置返回文件的路径以及类型

spring.mvc.view.prefix: /WEB-INF/jsp/
spring.mvc.view.suffix: .jsp


分层文件



controller文件


package com.example.springbootjsp.controller;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

@RestController
public class studentController {

   Logger logger= LoggerFactory.getLogger(getClass());

   @GetMapping({"/","/index"})
   public ModelAndView index(){
       ModelAndView mv = new ModelAndView("index");
       return mv;
   }
   
   @GetMapping("/toLogin")
   public ModelAndView logoin(){
       ModelAndView mv = new ModelAndView("login");
       return mv;

   }


   //根据传入url参数决定访问第几个页面

   
   @GetMapping("/level1/{id}")
   public ModelAndView vip1(@PathVariable("id")int id){
       logger.info("要访问的页面idlevel1"+id);
       ModelAndView mv = new ModelAndView("level1/"+id);
       return mv;

   }

   @GetMapping("/level2/{id}")
   public ModelAndView vip2(@PathVariable("id")int id){
       logger.info("要访问的页面idlevel2"+id);
       ModelAndView mv = new ModelAndView("level2/"+id);
       return mv;

   }

   @GetMapping("/level3/{id}")
   public ModelAndView vip3(@PathVariable("id")int id){
       logger.info("要访问的页面idlevel3"+id);
       ModelAndView mv = new ModelAndView("level3/"+id);
       return mv;
   }
}




security的config配置文件

@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {

   //授权功能

   @Override
   protected void configure(HttpSecurity http) throws Exception {

       //首页"/"   所有人可访问,功能页面只有有权限的人才能访问

       //配置页面的访问权限
       http.authorizeRequests()
               .antMatchers("/").permitAll()
               .antMatchers("level1/**").hasRole("vip1")
               .antMatchers("level2/**").hasRole("vip2")
               .antMatchers("level3/**").hasRole("vip3");

       //没有权限会默认到登陆页面  "login.jsp"
       http.formLogin();

       super.configure(http);

   }

   //认证功能
   //密码采用了编码:passwordEncoder

   //avip1权限  只能访问level1/**下的所有页面
   //bvip2权限  只能访问level2/**下的所有页面
   //cvip3权限  只能访问level3/**下的所有页面

   @Override
   public void configure(AuthenticationManagerBuilder auth) throws Exception {
       auth.inMemoryAuthentication().passwordEncoder(new BCryptPasswordEncoder())
               .withUser("a").password(new BCryptPasswordEncoder().encode("a")).roles("vip1")
               .and()
               .withUser("b").password(new BCryptPasswordEncoder().encode("b")).roles("vip2")
               .and()
               .withUser("c").password(new BCryptPasswordEncoder().encode("c")).roles("vip3");
                super.configure(auth);
   }
   }




运行





“/index”因为没有认证   报了未认证错误





"/"    首页不受限制




点击任一一个链接   都被拦截

跳到登录页面




但密码怎么输入都是失败..



明天计划的事情:


解决问题

整合shiro  和 duddo


返回列表 返回列表
评论

    分享到