AI 助理
备案控制台
开发者社区 数据库 文章 正文

oatuth2.0 + JWT 案例

2023-07-27 62
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介： 上一节，我们讲述了Oauth2.0 配合security的使用，配合redis去存token，或者配合Jwt去存token。这篇文章，我们主要来系统的串起来讲一下，从宏观的层面来讲述一下单点登录，并且来实现一个demo。

上一节，我们讲述了Oauth2.0 配合security的使用，配合redis去存token，或者配合Jwt去存token。这篇文章，我们主要来系统的串起来讲一下，从宏观的层面来讲述一下单点登录，并且来实现一个demo。

首先，我们来借助一个真实的案例来切入：

相信大家都登录过码云吧：（https: //gitee.com/）

image-20210225134304440

在登录选项里我们选择使用三方账号进行登录（QQ）

然后他就会跳转到下面这个地址：

https://graph.qq.com/oauth2.0/show?which=Login&display=pc&client_id=101284669&redirect_uri=https%3A%2F%2Fgitee.com%2Fauth%2Fqq_connect%2Fcallback&response_type=code&state=89f4057a9c58e68c18eada439aa52d9400b71e8efdf7201e

image-20210225150507938

这个地址有没有很熟悉？

路径里面的几个参数是不是很熟悉？client_id,redirect_uri,response_type

上面一节课我们了解了这几个概念： 认证服务器，客户端。这里我们进行对号入座：

认证服务器：就是上面的跳转地址（QQ的认证服务器）

客户端：码云

上面的认证就是授权码模式进行认证，登陆QQ后，QQ的认证服务器通过你的认证，返回授权码和回调地址(redirect_uri)：码云拿到授权码进行令牌（token）的获取

image-20210225150815009

通过检查调用的接口情况，发现码云根据上面的callback接口获取到code，然后在接口内部去调用QQ的获取token的接口（默认的是 /ooauth/token）的接口。这样的话进行就能够拿到token了，拿到token后可以进行重定向到login页面，请求QQ那边的获取用户基本信息的接口（资源）来获取QQ的基本信息（昵称，用户名）来回填到码云的登录表单中。

这样我们就基本了解什么是单点登录了。

下面我们写一个demo：

1. 新建一个服务（就好比QQ的认证服务）

依赖：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.0.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.starzyn</groupId>
    <artifactId>sso</artifactId>
    <version>0.0.1</version>
    <name>sso</name>
    <description>sso</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-security</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-oauth2</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>io.jsonwebtoken</groupId>
            <artifactId>jjwt</artifactId>
            <version>0.9.1</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
            <version>2.2.3.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>io.github.openfeign</groupId>
            <artifactId>feign-okhttp</artifactId>
            <version>10.10.1</version>
        </dependency>
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.3.2</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>io.swagger</groupId>
            <artifactId>swagger-annotations</artifactId>
            <version>1.6.2</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba.cloud</groupId>
            <artifactId>spring-cloud-alibaba-nacos-discovery</artifactId>
            <version>2.2.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>4.5.7</version>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

配置文件：

server:
  port: 9989
spring:
  datasource:
    url: jdbc:mysql://your-server:23306/sso?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
    username: root
    password: tiger
    driver-class-name: com.mysql.cj.jdbc.Driver
  cloud:
    nacos:
      discovery:
        server-addr: http://39.102.83.104:8848
feign:
  okhttp:
    enabled: true

用户实体类：

package com.starzyn.sso.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime;
import java.io.Serializable;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;

/**
 * <p>
 * 后台用户表
 * </p>
 *
 * @author starzyn
 * @since 2021-02-23
 */
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
@TableName("ums_admin")
@ApiModel(value="UmsAdmin对象", description="后台用户表")
public class UmsAdmin implements Serializable {

    private static final long serialVersionUID = 1L;

    @TableId(value = "id", type = IdType.AUTO)
    private Long id;

    private String username;

    private String password;

    @ApiModelProperty(value = "头像")
    private String icon;

    @ApiModelProperty(value = "邮箱")
    private String email;

    @ApiModelProperty(value = "昵称")
    private String nickName;

    @ApiModelProperty(value = "备注信息")
    private String note;

    @ApiModelProperty(value = "创建时间")
    private LocalDateTime createTime;

    @ApiModelProperty(value = "最后登录时间")
    private LocalDateTime loginTime;

    @ApiModelProperty(value = "帐号启用状态：0->禁用；1->启用")
    private Integer status;


}

security认证使用的用户类：

package com.starzyn.sso.entity;

import cn.hutool.crypto.digest.BCrypt;
import org.springframework.security.core.GrantedAuthority;
import org.springframework.security.core.authority.SimpleGrantedAuthority;
import org.springframework.security.core.userdetails.UserDetails;

import java.util.*;

import static cn.hutool.crypto.digest.BCrypt.hashpw;

/**
 * @author starzyn
 * @className:SecurityUser
 * @date : 2021/2/23
 * @description:
 */
public class SecurityUser implements UserDetails {
    private Long id;
    private String username;
    private String password;
    private Collection<SimpleGrantedAuthority> authorities;
    private boolean enabled;

    public SecurityUser(){}

    public SecurityUser(UmsAdmin admin){
        this.id = admin.getId();
        this.username = admin.getUsername();
        this.password = admin.getPassword();
        this.authorities = new HashSet<>();
        Arrays.stream(admin.getNote().split(",")).forEach(role -> this.authorities.add(new SimpleGrantedAuthority(role)));
        this.enabled = Objects.equals(1, admin.getStatus()) ? true : false;
    }

//    public static void main(String[] args) {
//        System.out.println(BCrypt.hashpw("123456"));
//
//    }
    @Override
    public Collection<? extends GrantedAuthority> getAuthorities() {
        return this.authorities;
    }

    @Override
    public String getPassword() {
        return password;
    }

    @Override
    public String getUsername() {
        return username;
    }

    @Override
    public boolean isAccountNonExpired() {
        return true;
    }

    @Override
    public boolean isAccountNonLocked() {
        return true;
    }

    @Override
    public boolean isCredentialsNonExpired() {
        return true;
    }

    @Override
    public boolean isEnabled() {
        return enabled;
    }
}

用户信息的业务层：

package com.starzyn.sso.api.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.starzyn.sso.entity.SecurityUser;
import com.starzyn.sso.entity.UmsAdmin;
import com.starzyn.sso.mapper.UmsAdminMapper;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.Collections;
import java.util.List;
import java.util.Objects;
import java.util.Optional;

/**
 * @author starzyn
 * @className:UserService
 * @date : 2021/2/23
 * @description:
 */
@Service
public class UserServiceImpl implements UserDetailsService {
    @Autowired
    private UmsAdminMapper umsAdminMapper;

    @Override
    public UserDetails loadUserByUsername(String username) {
        List<UmsAdmin> users = umsAdminMapper.selectList(new QueryWrapper<UmsAdmin>().eq("username", username));
        if (CollectionUtils.isEmpty(users)) {
            throw new UsernameNotFoundException("用户名不存在");
        }
        return new SecurityUser(users.get(0));
    }
}

认证服务配置：

package com.starzyn.sso.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.authentication.AuthenticationManager;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.oauth2.config.annotation.configurers.ClientDetailsServiceConfigurer;
import org.springframework.security.oauth2.config.annotation.web.configuration.AuthorizationServerConfigurerAdapter;
import org.springframework.security.oauth2.config.annotation.web.configuration.EnableAuthorizationServer;
import org.springframework.security.oauth2.config.annotation.web.configurers.AuthorizationServerEndpointsConfigurer;
import org.springframework.security.oauth2.config.annotation.web.configurers.AuthorizationServerSecurityConfigurer;
import org.springframework.security.oauth2.provider.token.AccessTokenConverter;
import org.springframework.security.oauth2.provider.token.TokenStore;

/**
 * @author starzyn
 * @className:AuthServer
 * @date : 2021/2/23
 * @description:
 */
@Configuration
@EnableAuthorizationServer
public class AuthServer extends AuthorizationServerConfigurerAdapter {
    @Autowired
    private AuthenticationManager authenticationManager;

    @Autowired
    private PasswordEncoder passwordEncoder;

    @Autowired
    private UserDetailsService userServiceImpl;

    @Autowired
    @Qualifier("jwtTokenStore")
    private TokenStore tokenStore;

    @Autowired
    private AccessTokenConverter jwtAccessTokenConverter;

    @Override
    public void configure(ClientDetailsServiceConfigurer clients) throws Exception {
        clients.inMemory()
                .withClient("portal")
                .authorizedGrantTypes("authorization_code", "password", "refresh_token")
                .redirectUris("http://localhost:8080/callback")
                .secret(passwordEncoder.encode("admin"))
                .scopes("all");
    }

    @Override
    public void configure(AuthorizationServerEndpointsConfigurer endpoints) throws Exception {
        endpoints.authenticationManager(authenticationManager)
                .userDetailsService(userServiceImpl)
                .tokenStore(tokenStore)
                .accessTokenConverter(jwtAccessTokenConverter);
    }

    @Override
    public void configure(AuthorizationServerSecurityConfigurer security) throws Exception {
        security.allowFormAuthenticationForClients();//这个地方需要注意一下，如果不进行配置，就会抱401的问题，通过跟源码发现，如果不配置，他就会使用你前面进行认证的那个 Authentication对象，这样的话就会需要加头，进行认证，用postman进行请求就是可以的，但是使用restTemplate 请求就会抱401
    }
}

security的配置：

package com.starzyn.sso.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.authentication.AuthenticationManager;
import org.springframework.security.config.annotation.web.builders.HttpSecurity;
import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
import org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder;
import org.springframework.security.crypto.factory.PasswordEncoderFactories;
import org.springframework.security.crypto.password.PasswordEncoder;
import org.springframework.security.oauth2.config.annotation.web.configuration.EnableResourceServer;

/**
 * @author starzyn
 * @className:SpringSecurityConfig
 * @date : 2021/2/23
 * @description:
 */
@Configuration
@EnableWebSecurity
public class SpringSecurityConfig extends WebSecurityConfigurerAdapter  {
    @Bean
    @Override
    public AuthenticationManager authenticationManagerBean() throws Exception {
        return super.authenticationManagerBean();
    }

    @Bean
    public PasswordEncoder passwordEncoder() {
        return new BCryptPasswordEncoder();
    }

    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http.authorizeRequests()
            .antMatchers("/oauth/**", "/rsa/publicKey", "/v2/api-docs", "/callback")
            .permitAll()
            .anyRequest()
            .authenticated()
            .and()
            .formLogin()
            .permitAll();
    }
}

Jwt的配置

package com.starzyn.sso.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.security.oauth2.provider.token.TokenStore;
import org.springframework.security.oauth2.provider.token.store.JwtAccessTokenConverter;
import org.springframework.security.oauth2.provider.token.store.JwtTokenStore;

@Configuration
public class JwtTokenStoreConfig {

    @Bean
    public TokenStore jwtTokenStore() {
        return new JwtTokenStore(jwtAccessTokenConverter());
    }

    @Bean
    public JwtAccessTokenConverter jwtAccessTokenConverter() {
        JwtAccessTokenConverter jwtAccessTokenConverter = new JwtAccessTokenConverter();
        jwtAccessTokenConverter.setSigningKey("starzyn");
        return jwtAccessTokenConverter;
    }

}

2. 新建一个客户端（就好比码云）

新起一个服务（端口8080）

测试接口：

package com.starzyn.client1.api.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.ResponseEntity;
import org.springframework.util.Base64Utils;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class UserController {
    @Autowired
    private RestTemplate restTemplate;

    @GetMapping("callback")
    public String getToken(@RequestParam(required = false) String code) {
        MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
        params.add("grant_type", "authorization_code");
        params.add("code", code);
        params.add("client_id", "portal");
        params.add("client_secret", "admin");
        params.add("redirect_uri", "http://localhost:8080/callback");
//        HttpHeaders httpHeaders = new HttpHeaders();
//        httpHeaders.add("Content-type", "application/x-www-form-urlencoded");
//        httpHeaders.add("Authorization", "Basic " + Base64Utils.encodeToString("portal:admin".getBytes()));
//        HttpEntity<MultiValueMap> entity = new HttpEntity<>(httpHeaders, params);
        ResponseEntity<String> resp = restTemplate.postForEntity("http://localhost:9989/oauth/token", params, String.class);
        return resp.getBody();
    }

}

3. 测试

启动两个服务，访问 http: //localhost:9989/oauth/authorize?response_type=code&client_id=portal&redirect_uri=http: //localhost:8080/callback&scope=all

image-20210225164541854

这个页面就是类比跳转到QQ的认证服务，进行QQ的登陆

输入用户名和密码之后

image-20210225164644581

这就好比QQ对码云的授权

点击Authorize之后跳转到 http: //localhost:8080/callback?code=1MWurK

image-20210225164759282

这就是码云拿到了QQ认证服务给的token

整个流程走下来，token拿到了，其他的就是去资源服务器上去访问资源了（请求QQ的获取用户的接口）

整个流程走下来，就是一个根据授权码模式来进行单点登录的方式了。

文章标签：
云数据库 RDS MySQL 版
NoSQL
数据安全/隐私保护
Redis
安全
关键词：
jwt案例
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
1910801116781953
目录
相关文章
嘟嘟的程序员铲屎官
|
安全 Java 数据库
Spring Security详细讲解(JWT+SpringSecurity登入案例)
通过本篇博文,你可以详细了解Spring Security的相关概念与原理,并且掌握Spring Security的认证与授权,通过博文中的登入案例可以让自己定制去Spring Security认证授权方案。
嘟嘟的程序员铲屎官
1727 1
Spring Security详细讲解(JWT+SpringSecurity登入案例)
互联网小阿祥
|
存储 SQL 算法
【案例实战】分布式应用下登录检验解决方案（JWT）
【案例实战】分布式应用下登录检验解决方案（JWT）
互联网小阿祥
774 0
【案例实战】分布式应用下登录检验解决方案（JWT）
Kelvin3999
|
存储 JSON JavaScript
【项目实战】一、Spring boot整合JWT、Vue案例展示用户鉴权（下）
【项目实战】一、Spring boot整合JWT、Vue案例展示用户鉴权（下）
Kelvin3999
165 0
Kelvin3999
|
JavaScript 前端开发 Java
【项目实战】一、Spring boot整合JWT、Vue案例展示用户鉴权（中）
【项目实战】一、Spring boot整合JWT、Vue案例展示用户鉴权（中）
Kelvin3999
189 0
Kelvin3999
|
JavaScript Java Nacos
【项目实战】一、Spring boot整合JWT、Vue案例展示用户鉴权（上）
【项目实战】一、Spring boot整合JWT、Vue案例展示用户鉴权（上）
Kelvin3999
214 0
前端歌谣
jira学习案例26-用useHttp管理jwt和登录状态
jira学习案例26-用useHttp管理jwt和登录状态
前端歌谣
80 0
jira学习案例26-用useHttp管理jwt和登录状态
前端歌谣
jira学习案例22-jwt原理-auth-provider
jira学习案例22-jwt原理-auth-provider
前端歌谣
70 0
jira学习案例22-jwt原理-auth-provider
一位隐者
|
21天前
|
JSON 安全 Java
什么是JWT？如何使用Spring Boot Security实现它？
什么是JWT？如何使用Spring Boot Security实现它？
一位隐者
78 5
百色彭于晏
|
4月前
|
SQL Java 测试技术
在Spring boot中 使用JWT和过滤器实现登录认证
在Spring boot中 使用JWT和过滤器实现登录认证
百色彭于晏
271 0
我是快乐的嘟嘟
|
2月前
|
JSON 安全 算法
在 Spring Boot 中验证 JWT 的详细步骤与注意事项
【10月更文挑战第18天】
我是快乐的嘟嘟
199 61

热门文章

最新文章

  • 1
    如何在SpringBoot中集成JWT(JSON Web Token)鉴权
  • 2
    使用JWT简化http接口鉴权，告别烦人的加密、解密代码吧
  • 3
    JSON Web Token (JWT)，服务端信息传输安全解决方案。
  • 4
    微服务网关鉴权：gateway使用、网关限流使用、用户密码加密、JWT鉴权（二）
  • 5
    【Spring Boot 快速入门】十九、Spring Boot 集成JWT
  • 6
    自己写token类（无视jwt）
  • 7
    深度解析 Spring Security：身份验证、授权、OAuth2 和 JWT 身份验证的完整指南
  • 8
    Vue3 + Nest 实现权限管理系统 后端篇（二）：使用 JWT 实现注册与登录
  • 9
    使用黑名单完成，Jwt退出登录操作
  • 10
    SpringBoot整合JWT
  • 1
    SpringCloudAlibaba:4.3云原生网关higress的JWT 认证
    131
  • 2
    SpringBoot之JWT令牌校验
    211
  • 3
    切图仔做全栈：React&Nest.js社区平台(一)——基础架构与邮箱注册、JWT登录实现
    157
  • 4
    Serverless 应用引擎产品使用之阿里函数计算中要关掉http触发器的jwt认证才可以进行性能探测如何解决
    70
  • 5
    【专栏】四种REST API身份验证方法：基本认证、OAuth、JSON Web Token（JWT）和API密钥
    878
  • 6
    pyjwt，一个强大的 Python JWT解析校验库！
    181
  • 7
    node实战——后端koa结合jwt连接mysql实现权限登录（node后端就业储备知识）
    121
  • 8
    使用JWT的服务分布式部署之后报错：JWT Check Failure:
    118
  • 9
    微服务之Springboot整合Oauth2.0 + JWT
    188
  • 10
    ❤Nodejs 第九章（token身份认证和express-jwt的安装认识）
    121

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    DataWorks售前咨询