SpringSecurity+JWT实现微信用户名密码等多种登录方式

鉴权框架的实现都是两大步认证和授权,我们分别来说说思路和具体的代码实现

认证

SpringSecurity的认证是通过一系列的过滤链实现的,先上原理图

b10d65b23050724292697720dfa6f58.png

其中认证分为两步:登录和验证

登录

注:(这里只有关键代码,全部的代码在文章末尾会上git链接)

我们这里不用springsecurity自带的登录接口实现,

先自定义controller,然后再serviceimpl中调用过滤链。

package com.wwj.service.impl;

import com.wwj.constant.SecurityConstants;
import com.wwj.domain.AjaxResult;
import com.wwj.domain.LoginUser;
import com.wwj.domain.SysUser;
import com.wwj.domain.WXAuthenticationToken;
import com.wwj.service.LoginService;
import com.wwj.utils.JwtUtils;
import com.wwj.utils.RedisCache;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.security.authentication.AuthenticationManager;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
import org.springframework.security.core.Authentication;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Service;

import java.util.HashMap;

/**
 * 登陆接口实现类
 */
@Service
public class LoginServiceImpl implements LoginService {

    @Autowired
    @Qualifier("myAuthenticationManager")
    AuthenticationManager authenticationManager;

    @Autowired
    RedisCache redisCache;

    /**
     * 用户名密码登陆
     * @param sysUser
     * @return
     */
    @Override
    public AjaxResult login(SysUser sysUser) {
        //选则security带的token(继承Authentication)需要赋值用户名密码
        //选用不同的token,会通过循环找到token对应的provider,利用provider进行验证
        UsernamePasswordAuthenticationToken usernamePasswordAuthenticationToken = new UsernamePasswordAuthenticationToken(sysUser.getUserName(),sysUser.getPassword());
        String token = this.authenticate(usernamePasswordAuthenticationToken);
        return AjaxResult.success("登录成功",token);
    }

    /**
     * 微信登陆(利用id登陆)
     * @param sysUser
     * @return
     */
    @Override
    public AjaxResult wxLogin(SysUser sysUser) {
        //选则自定义的微信token(继承Authentication)只赋值openid即可
        //选用不同的token,会通过循环找到token对应的provider,利用provider进行验证
        WXAuthenticationToken wxAuthenticationToken = new WXAuthenticationToken(sysUser.getOpenId());
        String token = this.authenticate(wxAuthenticationToken);
        return AjaxResult.success("登录成功",token);
    }

    /**
     * 退出接口
     * @return
     */
    @Override
    public AjaxResult loginOut() {
        //获取SecurityContextHolder的用户id
        Authentication authentication = SecurityContextHolder.getContext().getAuthentication();
        LoginUser loginUser = (LoginUser) authentication.getPrincipal();

        //删除redis值
        redisCache.deleteObject("login:"+loginUser.getSysUser().getUserId());
        return AjaxResult.success("退出成功");
    }

    /**
     * AuthenticationManager调用proverManager去寻找合适的验证方式去选择不同的proverder
     * return token
      */
    private String authenticate(Authentication authentication){
        Authentication authenticate = authenticationManager.authenticate(authentication);
        //认证通过,使用userID生成token,再将token返回前端
        LoginUser loginUser = (LoginUser)authenticate.getPrincipal();
        SysUser sysUser1 = loginUser.getSysUser();
        //若果认证没通过给出提示
        if(sysUser1 == null){
            throw new RuntimeException("登录失败");
        }
        HashMap<String, Object> claims = new HashMap<>();
        claims.put(SecurityConstants.DETAILS_USER_ID,sysUser1.getUserId());
        String token = JwtUtils.createToken(claims);

        //完整的用户信息存入redis userId作为key
        redisCache.setCacheObject("login:"+sysUser1.getUserId(),loginUser);

        return token;
    }
}

主要方法Authentication authenticate = authenticationManager.authenticate(authentication);

通过配置authenticationManager调用providerManger再通过循环具体根据传入的token类型选择合适的provider进行用户名密码的验证处理

package com.wwj.config;

import com.wwj.filter.JwtAuthenticationTokenFilter;
import com.wwj.provider.WXProvider;
import com.wwj.service.impl.UserNameDetailServiceImpl;
import com.wwj.service.impl.UserOpenIdDetailServiceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.authentication.AuthenticationManager;
import org.springframework.security.authentication.ProviderManager;
import org.springframework.security.authentication.dao.DaoAuthenticationProvider;
import org.springframework.security.config.annotation.method.configuration.EnableGlobalMethodSecurity;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.security.config.http.SessionCreationPolicy;
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;

import java.util.Arrays;

@Configuration
@EnableGlobalMethodSecurity(prePostEnabled = true)
public class SecurityConfig extends WebSecurityConfigurerAdapter {

    @Autowired
    private UserNameDetailServiceImpl userNameDetailServiceImpl;

    @Autowired
    private UserOpenIdDetailServiceImpl userOpenIdDetailServiceImpl;

    @Autowired
    private JwtAuthenticationTokenFilter jwtAuthenticationTokenFilter;

    /**
     * 配置provider(DaoAuthenticationProvider) 用户名密码的一套
     * @return
     */
    @Bean
    public DaoAuthenticationProvider daoAuthenticationProvider(){
        DaoAuthenticationProvider daoAuthenticationProvider = new DaoAuthenticationProvider();
        daoAuthenticationProvider.setPasswordEncoder(passwordEncoder());
        daoAuthenticationProvider.setUserDetailsService(userNameDetailServiceImpl);
        return daoAuthenticationProvider;
    }

    /**
     * 配置provider(WXProvider) 微信的一套(根据openid直接登入系统)
     * @return
     */
    @Bean
    public WXProvider getWXProvider(){
        WXProvider wxProvider = new WXProvider();
        wxProvider.setUserOpenIdDetailsService(userOpenIdDetailServiceImpl);
        return wxProvider;
    }

    /**
     * 创建密码加密方式BCryptPasswordEncoder注入容器中
     * @return
     */
    @Bean
    public PasswordEncoder passwordEncoder(){
        return new BCryptPasswordEncoder();
    }

    /**
     * 定义认证管理器
     * @return
     * @throws Exception
     */
    @Override
    @Bean(name="myAuthenticationManager")
    public AuthenticationManager authenticationManagerBean() throws Exception {
        ProviderManager authenticationManager = new ProviderManager(Arrays.asList(daoAuthenticationProvider(),getWXProvider()));
        //不擦除认证密码,擦除会导致TokenBasedRememberMeServices因为找不到Credentials再调用UserDetailsService而抛出UsernameNotFoundException
        authenticationManager.setEraseCredentialsAfterAuthentication(false);
        return authenticationManager;
    }

    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http
                //关闭csrf
                .csrf().disable()
                //不通过session获取SecurityContext
                .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS)
                .and()
                .authorizeRequests()
                //登录接口允许匿名访问
                .antMatchers("/login/**").anonymous()
                .anyRequest().authenticated();

        http
                //添加token认证的过滤器到security的过滤链前
                .addFilterBefore(jwtAuthenticationTokenFilter, UsernamePasswordAuthenticationFilter.class);
    }

}

这里自定义了微信用的provider

package com.wwj.provider;

import com.wwj.domain.LoginUser;
import com.wwj.domain.WXAuthenticationToken;
import com.wwj.service.UserOpenIdDetailsService;
import lombok.Data;
import org.springframework.security.authentication.AuthenticationProvider;
import org.springframework.security.core.Authentication;
import org.springframework.security.core.AuthenticationException;

/**
 * 微信调用的provider
 */
@Data
public class WXProvider implements AuthenticationProvider {

    private UserOpenIdDetailsService userOpenIdDetailsService;

    /**
     * 取到authentication中的openId,根据openId查询信息,能查到信息表示登陆成功
     * @param authentication
     * @return
     * @throws AuthenticationException
     */
    @Override
    public Authentication authenticate(Authentication authentication) throws AuthenticationException {
        LoginUser loginUser = (LoginUser) userOpenIdDetailsService.loadUserByOpenId(authentication.getPrincipal().toString());
        if(loginUser == null){
            throw new RuntimeException("登陆失败");
        }
        WXAuthenticationToken wxAuthenticationToken = new WXAuthenticationToken(loginUser);
        return wxAuthenticationToken;
    }

    /**
     * 配置当前Provider对应的wxAuthenticationToken
     * @param authentication
     * @return
     */
    @Override
    public boolean supports(Class<?> authentication) {
        return (WXAuthenticationToken.class.isAssignableFrom(authentication));
    }
}

同时配置了微信用的service

package com.wwj.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.wwj.domain.LoginUser;
import com.wwj.domain.SysUser;
import com.wwj.mapper.UserMapper;
import com.wwj.service.UserOpenIdDetailsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * 根基openid获取用户信息
 */
@Service
public class UserOpenIdDetailServiceImpl implements UserOpenIdDetailsService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public UserDetails loadUserByOpenId(String openId) throws UsernameNotFoundException {
        //根据用户名在数据库中查询用户信息
        QueryWrapper<SysUser> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("open_id", openId);
        SysUser sysUser = userMapper.selectOne(queryWrapper);
        //TODO 先写死
        List<String> permissions = new ArrayList<>(Arrays.asList("admin","common"));

        //再封装成UserDetails实现类
        LoginUser loginUser = new LoginUser(sysUser,permissions);
        loginUser.setSysUser(sysUser);
        return loginUser;
    }
}

通过上面部分代码,我们来就有了两条登录验证的走法

1.用户名密码登录

LoginController >>> LoginServiceImpl >>>authenticationManager(UsernamePasswordAuthenticationToken) >>> ProviderManager>>>daoAuthenticationProvider>>>UserNameDetailServiceImpl

2.微信用openid登录

LoginController >>> LoginServiceImpl >>>authenticationManager(WXAuthenticationToken) >>> ProviderManager>>>WXProvider>>>UserOpenIdDetailServiceImpl

登录成功后会将userid变成token,同时将userid为key,用户的信息为value存入redis中

验证

然后每一次访问接口都需要携带token,解析token,取redis的用户详细信息,放到SpringSecurity的容器中

定义一条过滤链,配置在spring过滤链前

package com.wwj.filter;

import com.alibaba.fastjson.JSON;
import com.wwj.constant.SecurityConstants;
import com.wwj.domain.LoginUser;
import com.wwj.utils.JwtUtils;
import com.wwj.utils.RedisCache;
import io.jsonwebtoken.Claims;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
import org.springframework.security.core.context.SecurityContextHolder;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import org.springframework.web.filter.OncePerRequestFilter;

import javax.servlet.FilterChain;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

@Component
public class JwtAuthenticationTokenFilter extends OncePerRequestFilter {

    @Autowired
    private RedisCache redisCache;

    @Override
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
        //获取token
        String token = request.getHeader("token");
        if(!StringUtils.hasText(token)){
            //放行
            filterChain.doFilter(request,response);
            return;
        }

        //解析token
        Claims claims = JwtUtils.parseToken(token);
        String userId = claims.get(SecurityConstants.DETAILS_USER_ID).toString();

        //根据userId在redis中获取用户信息
        LoginUser loginUser = redisCache.getCacheObject("login:" + userId);

        if(loginUser == null){
            throw new RuntimeException("用户未登录");
        }

        //存入SecurityContex上下文
        //TODO 获取权限信息
        UsernamePasswordAuthenticationToken userToken = new UsernamePasswordAuthenticationToken(loginUser,null,loginUser.getAuthorities());
        SecurityContextHolder.getContext().setAuthentication(userToken);

        //放行
        filterChain.doFilter(request,response);
    }
}

授权

登录成功后,会在SpringSecurity的容器中取到用户的角色信息,根据接口所需要的的角色信息进行匹配,匹配成功后即可放行
实现授权主要有两种方式:

通过配置类进行配置(主要配置静态资源的放行)

通过注解方式实现对每个接口的授权认证

package com.wwj.controller;

import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;1

@RestController
public class HelloController {

    @GetMapping("hello")
    @PreAuthorize("hasAuthority('test')")
    public String hello(){
        return  "hello";
    }

    @GetMapping("hello1")
    @PreAuthorize("hasAuthority('admin')")
    public String hello1(){
        return  "hello1";
    }

    @GetMapping("hello2")
    public String hello2(){
        return  "hello2";
    }

}

好啦,springsecurity到这里就实现成功啦。以上的文档为简略说明思路,具体代码查看
https://gitee.com/c_wolun/security-demo.git

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,684评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,143评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,214评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,788评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,796评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,665评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,027评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,679评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,346评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,664评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,766评论 1 331
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,412评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,015评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,974评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,073评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,501评论 2 343

推荐阅读更多精彩内容