SpringCloud：Gateway之鉴权

转x33g5p2x  于2021-11-03 转载在 Spring  
字(6.9k)|赞(0)|评价(0)|浏览(650)

一、JWT 实现微服务鉴权

JWT一般用于实现单点登录。单点登录：如腾讯下的游戏有很多，包括lol，飞车等，在qq游戏对战平台上登录一次，然后这些不同的平台都可以直接登陆进去了，这就是单点登录的使用场景。JWT就是实现单点登录的一种技术，其他的还有oath2等。

1 什么是微服务鉴权

我们之前已经搭建过了网关，使用网关在网关系统中比较适合进行权限校验。

那么我们可以采用JWT的方式来实现鉴权校验。

2.代码实现

思路分析

  1. 1. 用户进入网关开始登陆，网关过滤器进行判断，如果是登录，则路由到后台管理微服务进行登录
  2. 2. 用户登录成功，后台管理微服务签发JWT TOKEN信息返回给用户
  3. 3. 用户再次进入网关开始访问，网关过滤器接收用户携带的TOKEN 
  4. 4. 网关过滤器解析TOKEN ，判断是否有权限，如果有，则放行，如果没有则返回未认证错误
签发token

（1）创建类： JwtUtil

  1. package com.mye.nacosprovider.jwt;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import io.jsonwebtoken.Claims;
  5. import io.jsonwebtoken.JwtBuilder;
  6. import io.jsonwebtoken.Jwts;
  7. import io.jsonwebtoken.SignatureAlgorithm;
  8. import org.springframework.stereotype.Component;
  9.  
  10. import javax.crypto.SecretKey;
  11. import javax.crypto.spec.SecretKeySpec;
  12. import java.util.Base64;
  13. import java.util.Date;
  15. import java.util.*;
  17. @Component
  18. public class JwtUtil {
  19.  
  20.     //加密 解密时的密钥 用来生成key
  21.     public static final String JWT_KEY = "IT1995";
  22.     
  23.     /** * 生成加密后的秘钥 secretKey * @return */
  24.     public static SecretKey generalKey() {
  25.         byte[] encodedKey = Base64.getDecoder().decode(JwtUtil.JWT_KEY);
  26.         SecretKey key = new SecretKeySpec(encodedKey, 0, encodedKey.length, "AES");
  27.         return key;
  28.     }
  30.  
  31.     public static String createJWT(String id, String subject, long ttlMillis){
  32.  
  33.         SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256; //指定签名的时候使用的签名算法，也就是header那部分，jjwt已经将这部分内容封装好了。
  34.         long nowMillis = System.currentTimeMillis();//生成JWT的时间
  35.         Date now = new Date(nowMillis);
  36.         SecretKey key = generalKey();//生成签名的时候使用的秘钥secret,这个方法本地封装了的，一般可以从本地配置文件中读取，切记这个秘钥不能外露哦。它就是你服务端的私钥，在任何场景都不应该流露出去。一旦客户端得知这个secret, 那就意味着客户端是可以自我签发jwt了。
  37.         JwtBuilder builder = Jwts.builder() //这里其实就是new一个JwtBuilder，设置jwt的body
  38. // .setClaims(claims) //如果有私有声明，一定要先设置这个自己创建的私有的声明，这个是给builder的claim赋值，一旦写在标准的声明赋值之后，就是覆盖了那些标准的声明的
  39.                 .setId(id)                    //设置jti(JWT ID)：是JWT的唯一标识，根据业务需要，这个可以设置为一个不重复的值，主要用来作为一次性token,从而回避重放攻击。
  40.                 .setIssuedAt(now)            //iat: jwt的签发时间
  41.                 .setSubject(subject)        //sub(Subject)：代表这个JWT的主体，即它的所有人，这个是一个json格式的字符串，可以存放什么userid，roldid之类的，作为什么用户的唯一标志。
  42.                 .signWith(signatureAlgorithm, key);//设置签名使用的签名算法和签名使用的秘钥
  43.         if (ttlMillis >= 0) {
  44.             long expMillis = nowMillis + ttlMillis;
  45.             Date exp = new Date(expMillis);
  46.             builder.setExpiration(exp);        //设置过期时间
  47.         }
  48.         return builder.compact();            //就开始压缩为xxxxxxxxxxxxxx.xxxxxxxxxxxxxxx.xxxxxxxxxxxxx这样的jwt
  49.     }
  50.  
  51.     public static Claims parseJWT(String jwt){
  53.         SecretKey key = generalKey();  //签名秘钥，和生成的签名的秘钥一模一样
  54.         Claims claims = Jwts.parser()  //得到DefaultJwtParser
  55.                 .setSigningKey(key)         //设置签名的秘钥
  56.                 .parseClaimsJws(jwt).getBody();//设置需要解析的jwt
  57.         return claims;
  58.     }
  59.  
  60.     public static void main(String[] args){
  61.  
  62.         Map<String, Object> user = new HashMap<>();
  63.         user.put("username", "it1995");
  64.         user.put("password", "123456");
  65.         String jwt = createJWT(UUID.randomUUID().toString(), JSON.toJSONString(user), 3600 * 24);
  66.  
  67.         System.out.println("加密后：" + jwt);
  68.  
  69.         //解密
  70.         Claims claims = parseJWT(jwt);
  71.         System.out.println("解密后：" + claims.getSubject());
  72.     }
  73. }

(2)修改login方法,用户登录成功 则 签发TOKEN

  1. @PostMapping("/login")
  2.     public String login(@RequestBody User user){
  3.         //在redis中根据用户名查找密码
  4.         String password = redisTemplate.opsForValue().get(user.getUsername());
  5.         System.out.println(password);
  6.         boolean checkResult = BCrypt.checkpw(user.getPassword(), password);
  7.         if (checkResult){
  8.             Map<String, String> info = new HashMap<>();
  9.             info.put("username", user.getUsername());
  10.             String token = JwtUtil.createJWT(UUID.randomUUID().toString(), user.getUsername(), 3600L*1000);
  11.             info.put("token",token);
  12.             return JSONUtil.toJsonStr(info);
  13.         }else {
  14.             return "登录失败";
  15.         }
  16.     }

(3) 测试

网关过滤器验证token

（1）网关模块添加依赖

  1. <!--鉴权-->
  2. <dependency>
  3.     <groupId>io.jsonwebtoken</groupId>
  4.     <artifactId>jjwt</artifactId>
  5.     <version>0.9.0</version>
  6. </dependency>

（2）创建JWTUtil类

  1. package com.mye.nacosprovider.jwt;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import io.jsonwebtoken.Claims;
  5. import io.jsonwebtoken.JwtBuilder;
  6. import io.jsonwebtoken.Jwts;
  7. import io.jsonwebtoken.SignatureAlgorithm;
  8. import org.springframework.stereotype.Component;
  9.  
  10. import javax.crypto.SecretKey;
  11. import javax.crypto.spec.SecretKeySpec;
  12. import java.util.Base64;
  13. import java.util.Date;
  15. import java.util.*;
  17. @Component
  18. public class JwtUtil {
  19.  
  20.     //加密 解密时的密钥 用来生成key
  21.     public static final String JWT_KEY = "IT1995";
  22.     
  23.     /** * 生成加密后的秘钥 secretKey * @return */
  24.     public static SecretKey generalKey() {
  25.         byte[] encodedKey = Base64.getDecoder().decode(JwtUtil.JWT_KEY);
  26.         SecretKey key = new SecretKeySpec(encodedKey, 0, encodedKey.length, "AES");
  27.         return key;
  28.     }
  30.  
  31.     public static String createJWT(String id, String subject, long ttlMillis){
  32.  
  33.         SignatureAlgorithm signatureAlgorithm = SignatureAlgorithm.HS256; //指定签名的时候使用的签名算法，也就是header那部分，jjwt已经将这部分内容封装好了。
  34.         long nowMillis = System.currentTimeMillis();//生成JWT的时间
  35.         Date now = new Date(nowMillis);
  36.         SecretKey key = generalKey();//生成签名的时候使用的秘钥secret,这个方法本地封装了的，一般可以从本地配置文件中读取，切记这个秘钥不能外露哦。它就是你服务端的私钥，在任何场景都不应该流露出去。一旦客户端得知这个secret, 那就意味着客户端是可以自我签发jwt了。
  37.         JwtBuilder builder = Jwts.builder() //这里其实就是new一个JwtBuilder，设置jwt的body
  38. // .setClaims(claims) //如果有私有声明，一定要先设置这个自己创建的私有的声明，这个是给builder的claim赋值，一旦写在标准的声明赋值之后，就是覆盖了那些标准的声明的
  39.                 .setId(id)                    //设置jti(JWT ID)：是JWT的唯一标识，根据业务需要，这个可以设置为一个不重复的值，主要用来作为一次性token,从而回避重放攻击。
  40.                 .setIssuedAt(now)            //iat: jwt的签发时间
  41.                 .setSubject(subject)        //sub(Subject)：代表这个JWT的主体，即它的所有人，这个是一个json格式的字符串，可以存放什么userid，roldid之类的，作为什么用户的唯一标志。
  42.                 .signWith(signatureAlgorithm, key);//设置签名使用的签名算法和签名使用的秘钥
  43.         if (ttlMillis >= 0) {
  44.             long expMillis = nowMillis + ttlMillis;
  45.             Date exp = new Date(expMillis);
  46.             builder.setExpiration(exp);        //设置过期时间
  47.         }
  48.         return builder.compact();            //就开始压缩为xxxxxxxxxxxxxx.xxxxxxxxxxxxxxx.xxxxxxxxxxxxx这样的jwt
  49.     }
  50.  
  51.     public static Claims parseJWT(String jwt){
  53.         SecretKey key = generalKey();  //签名秘钥，和生成的签名的秘钥一模一样
  54.         Claims claims = Jwts.parser()  //得到DefaultJwtParser
  55.                 .setSigningKey(key)         //设置签名的秘钥
  56.                 .parseClaimsJws(jwt).getBody();//设置需要解析的jwt
  57.         return claims;
  58.     }
  59.  
  60.     public static void main(String[] args){
  61.  
  62.         Map<String, Object> user = new HashMap<>();
  63.         user.put("username", "it1995");
  64.         user.put("password", "123456");
  65.         String jwt = createJWT(UUID.randomUUID().toString(), JSON.toJSONString(user), 3600 * 24);
  66.  
  67.         System.out.println("加密后：" + jwt);
  68.  
  69.         //解密
  70.         Claims claims = parseJWT(jwt);
  71.         System.out.println("解密后：" + claims.getSubject());
  72.     }
  73. }

（3）创建过滤器，用于token验证

  1. /** * 鉴权过滤器 验证token */
  2. @Component
  3. public class AuthorizeFilter implements GlobalFilter, Ordered {
  4.     private static final String AUTHORIZE_TOKEN = "token";
  6.     @Override
  7.     public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  8. 		//1. 获取请求
  9.         ServerHttpRequest request = exchange.getRequest();
  10.         //2. 则获取响应
  11.         ServerHttpResponse response = exchange.getResponse();
  12.         //3. 如果是登录请求则放行
  13.         if (request.getURI().getPath().contains("/admin/login")) {
  14.             return chain.filter(exchange);
  15.         }
  16.         //4. 获取请求头
  17.         HttpHeaders headers = request.getHeaders();
  18.         //5. 请求头中获取令牌
  19.         String token = headers.getFirst(AUTHORIZE_TOKEN);
  21.         //6. 判断请求头中是否有令牌
  22.         if (StringUtils.isEmpty(token)) {
  23.             //7. 响应中放入返回的状态吗, 没有权限访问
  24.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  25.             //8. 返回
  26.             return response.setComplete();
  27.         }
  29.         //9. 如果请求头中有令牌则解析令牌
  30.         try {
  31.             JwtUtil.parseJWT(token);
  32.         } catch (Exception e) {
  33.             e.printStackTrace();
  34.             //10. 解析jwt令牌出错, 说明令牌过期或者伪造等不合法情况出现
  35.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  36.             //11. 返回
  37.             return response.setComplete();
  38.         }
  39.         //12. 放行
  40.         return chain.filter(exchange);
  41.     }
  43.     @Override
  44.     public int getOrder() {
  45.         return 0;
  46.     }
  47. }

（4）测试：

首先进行登录测试

在进行鉴权测试

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_43296313/article/details/121126811

内容来源于网络，如有侵权，请联系作者删除！

JavaspringcloudGatewayspring cloud

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com