文章
文章用户商城文档资讯沸点导航
!
也想出现在这里？ 联系我们吧
广告区块

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

个人简介：

> ?个人主页：赵四司机
> ?学习方向：JAVA后端开发
> ?种一棵树最好的时间是十年前，其次是现在！
> ⏰往期文章：SpringBoot项目整合微信支付
> ?喜欢的话麻烦点点关注喔，你们的支持是我的最大动力。

前言：

最近在做一个基于SpringCloud+Springboot+Docker的新闻头条微服务项目，现在项目开发进入了尾声，我打算通过写文章的形式进行梳理一遍，并且会将梳理过程中发现的Bug进行修复，有需要改进的地方我也会继续做出改进。这一系列的文章我将会放入微服务项目专栏中，这个项目适合刚接触微服务的人作为练手项目，假如你对这个项目感兴趣你可以订阅我的专栏进行查看，需要资料可以私信我，当然要是能给我点个小小的关注就更好了，你们的支持是我最大的动力。

一：需求分析

现在无论什么应用都少不了登录验证环节，而登录环节又少不了安全与校验，一是要防止用户信息被盗取，而是要防止用户利用漏洞进行暴力登录。所以针对这两个方面我选用的方案是采用MD5加盐进行加密并采用JWT进行验证的方案。当然用户还可以选择以游客身份进行访问，但是只有在登录的情况下才能对文章进行点赞、关注及收藏等动作。

二：表结构分析

1.数据库结构

由于App端关于用户相关信息比较多，所以单独创建了一个数据库(headlines_user)进行管理，主要包括如下几张表：

表名称 说明
ap_user APP用户信息表
ap_user_fan APP用户粉丝信息表
ap_user_follow APP用户关注信息表
ap_user_realname APP实名认证信息表

关于用户登录用到的是ap_user表 ，表的结构如下：

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

2.实体类

  1. package com.my.model.user.pojos;
  2.  
  3. import com.baomidou.mybatisplus.annotation.IdType;
  4. import com.baomidou.mybatisplus.annotation.TableField;
  5. import com.baomidou.mybatisplus.annotation.TableId;
  6. import com.baomidou.mybatisplus.annotation.TableName;
  7. import lombok.Data;
  8.  
  9. import java.io.Serializable;
  10. import java.util.Date;
  11.  
  12. /**
  13.  * 
  14.  * APP用户信息表
  15.  * 
  16.  *
  17.  * @author itheima
  18.  */
  19. @Data
  20. @TableName("ap_user")
  21. public class ApUser implements Serializable {
  22.  
  23.     private static final long serialVersionUID = 1L;
  24.  
  25.     /**
  26.      * 主键
  27.      */
  28.     @TableId(value = "id", type = IdType.AUTO)
  29.     private Integer id;
  30.  
  31.     /**
  32.      * 密码、通信等加密盐
  33.      */
  34.     @TableField("salt")
  35.     private String salt;
  36.  
  37.     /**
  38.      * 用户名
  39.      */
  40.     @TableField("name")
  41.     private String name;
  42.  
  43.     /**
  44.      * 密码,md5加密
  45.      */
  46.     @TableField("password")
  47.     private String password;
  48.  
  49.     /**
  50.      * 手机号
  51.      */
  52.     @TableField("phone")
  53.     private String phone;
  54.  
  55.     /**
  56.      * 头像
  57.      */
  58.     @TableField("image")
  59.     private String image;
  60.  
  61.     /**
  62.      * 0 男
  63.      * 1 女
  64.      * 2 未知
  65.      */
  66.     @TableField("sex")
  67.     private Boolean sex;
  68.  
  69.     /**
  70.      * 0 未
  71.      * 1 是
  72.      */
  73.     @TableField("is_certification")
  74.     private Boolean certification;
  75.  
  76.     /**
  77.      * 是否身份认证
  78.      */
  79.     @TableField("is_identity_authentication")
  80.     private Boolean identityAuthentication;
  81.  
  82.     /**
  83.      * 0正常
  84.      * 1锁定
  85.      */
  86.     @TableField("status")
  87.     private Boolean status;
  88.  
  89.     /**
  90.      * 0 普通用户
  91.      * 1 自媒体人
  92.      * 2 大V
  93.      */
  94.     @TableField("flag")
  95.     private Short flag;
  96.  
  97.     /**
  98.      * 注册时间
  99.      */
  100.     @TableField("created_time")
  101.     private Date createdTime;
  102.  
  103. }

三：思路分析

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

首先用户的任何请求都会经过网关，这时候网关就会进行拦截认证，假如用户现在的请求时登录，那这时候可以直接放行让用户去登录，否则的话就会检验用户请求头中是否包含有效的token信息，假如包含则直接放行，否则进行拦截并让用户重新登录。

而用户登录时候首先会根据用户账号到数据库中查询该用户信息，然后将用户输入的密码与数据库中获得的Salt进行合并加密并与数据库中的密码（已加盐加密）进行比对，如果比对失败则提示相关信息，比对成功则判断用户状态，只有未被锁定方可继续操作。用户账号状态正常的话才能根据用户id生成token并保存然后放行。

四：代码实现

1.网关配置

（1）引入依赖

在tbug-headlines-gateway模块引入以下依赖

  1. dependencies>
  2.     dependency>
  3.         groupId>org.springframework.cloudgroupId>
  4.         artifactId>spring-cloud-starter-gatewayartifactId>
  5.     dependency>
  6.     dependency>
  7.         groupId>com.alibaba.cloudgroupId>
  8.         artifactId>spring-cloud-starter-alibaba-nacos-discoveryartifactId>
  9.     dependency>
  10.      dependency>
  11.             groupId>com.alibaba.cloudgroupId>
  12.             artifactId>spring-cloud-starter-alibaba-nacos-configartifactId>
  13.         dependency>
  14.     dependency>
  15.         groupId>io.jsonwebtokengroupId>
  16.         artifactId>jjwtartifactId>
  17.     dependency>
  18. dependencies>

（2）搭建工程

在tbug-headlines-gateway模块下创建工程tbug-headlines-app-gateway，整体架构如下：

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

（3）Nacos配置

在nacos的配置中心创建dataid为headlines-app-gateway的yml配置

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

  1. spring:
  2.   cloud:
  3.     gateway:
  4.       globalcors:
  5.         add-to-simple-url-handler-mapping: true
  6.         corsConfigurations:
  7.           '[/**]':
  8.             allowedHeaders: "*"
  9.             allowedOrigins: "*"
  10.             allowedMethods:
  11.               - GET
  12.               - POST
  13.               - DELETE
  14.               - PUT
  15.               - OPTION
  16.       routes:
  17.         # 用户微服务
  18.         - id: user
  19.           uri: lb://headlines-user
  20.           predicates:
  21.             - Path=/user/**
  22.           filters:
  23.             - StripPrefix= 1

（3）配置文件

application.yml

  1. server:
  2.   port: 51601
  3. spring:
  4.   application:
  5.     name: headlines-app-gateway
  6.   cloud:
  7.     nacos:
  8.       discovery:
  9.         server-addr: 49.234.52.192:8848
  10.       config:
  11.         server-addr: 49.234.52.192:8848
  12.         file-extension: yml

该配置主要是配置你前面安装的nacos注册中心。

（5）相关代码

认证过滤器：

  1. package com.my.app.gateway.filter;
  2.  
  3.  
  4. import com.my.app.gateway.util.AppJwtUtil;
  5. import io.jsonwebtoken.Claims;
  6. import lombok.extern.slf4j.Slf4j;
  7. import org.apache.commons.lang.StringUtils;
  8. import org.springframework.cloud.gateway.filter.GatewayFilterChain;
  9. import org.springframework.cloud.gateway.filter.GlobalFilter;
  10. import org.springframework.core.Ordered;
  11. import org.springframework.http.HttpStatus;
  12. import org.springframework.http.server.reactive.ServerHttpRequest;
  13. import org.springframework.http.server.reactive.ServerHttpResponse;
  14. import org.springframework.stereotype.Component;
  15. import org.springframework.web.server.ServerWebExchange;
  16. import reactor.core.publisher.Mono;
  17.  
  18. @Component
  19. @Slf4j
  20. public class AuthorizeFilter implements Ordered, GlobalFilter {
  21.     @Override
  22.     public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
  23.         //1.获取request和response对象
  24.         ServerHttpRequest request = exchange.getRequest();
  25.         ServerHttpResponse response = exchange.getResponse();
  26.  
  27.         //2.判断是否是登录
  28.         if(request.getURI().getPath().contains("/login")){
  29.             //放行
  30.             return chain.filter(exchange);
  31.         }
  32.  
  33.  
  34.         //3.获取token
  35.         String token = request.getHeaders().getFirst("token");
  36.  
  37.         //4.判断token是否存在
  38.         if(StringUtils.isBlank(token)){
  39.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  40.             return response.setComplete();
  41.         }
  42.  
  43.         //5.判断token是否有效
  44.         try {
  45.             Claims claimsBody = AppJwtUtil.getClaimsBody(token);
  46.             //是否是过期
  47.             int result = AppJwtUtil.verifyToken(claimsBody);
  48.             if(result == 1 || result  == 2){
  49.                 response.setStatusCode(HttpStatus.UNAUTHORIZED);
  50.                 return response.setComplete();
  51.             }
  52.             //获取token解析后的用户信息
  53.             Object userId = claimsBody.get("id");
  54.             //在header中添加新的信息
  55.             ServerHttpRequest serverHttpRequest = request.mutate().headers(httpHeaders -> {
  56.                         httpHeaders.add("userId",userId + "");
  57.                     }
  58.             ).build();
  59.  
  60.             //重置header
  61.             exchange.mutate().request(serverHttpRequest).build();
  62.         }catch (Exception e){
  63.             e.printStackTrace();
  64.             response.setStatusCode(HttpStatus.UNAUTHORIZED);
  65.             return response.setComplete();
  66.         }
  67.  
  68.         //6.放行
  69.         return chain.filter(exchange);
  70.     }
  71.  
  72.     /**
  73.      * 优先级设置  值越小  优先级越高
  74.      * @return
  75.      */
  76.     @Override
  77.     public int getOrder() {
  78.         return 0;
  79.     }
  80. }

JWT工具类：

  1. package com.my.app.gateway.util;
  2.  
  3. import io.jsonwebtoken.*;
  4.  
  5. import javax.crypto.SecretKey;
  6. import javax.crypto.spec.SecretKeySpec;
  7. import java.util.*;
  8.  
  9. public class AppJwtUtil {
  10.  
  11.     // TOKEN的有效期一天（S）
  12.     private static final int TOKEN_TIME_OUT = 3_600;
  13.     // 加密KEY
  14.     private static final String TOKEN_ENCRY_KEY = "MDk4ZjZiY2Q0NjIxZDM3M2NhZGU0ZTgzMjYyN2I0ZjY";
  15.     // 最小刷新间隔(S)
  16.     private static final int REFRESH_TIME = 300;
  17.  
  18.     // 生产ID
  19.     public static String getToken(Long id){
  20.         Map claimMaps = new HashMap();
  21.         claimMaps.put("id",id);
  22.         long currentTime = System.currentTimeMillis();
  23.         return Jwts.builder()
  24.                 .setId(UUID.randomUUID().toString())
  25.                 .setIssuedAt(new Date(currentTime))  //签发时间
  26.                 .setSubject("system")  //说明
  27.                 .setIssuer("heima") //签发者信息
  28.                 .setAudience("app")  //接收用户
  29.                 .compressWith(CompressionCodecs.GZIP)  //数据压缩方式
  30.                 .signWith(SignatureAlgorithm.HS512, generalKey()) //加密方式
  31.                 .setExpiration(new Date(currentTime + TOKEN_TIME_OUT * 1000))  //过期时间戳
  32.                 .addClaims(claimMaps) //cla信息
  33.                 .compact();
  34.     }
  35.  
  36.     /**
  37.      * 获取token中的claims信息
  38.      *
  39.      * @param token
  40.      * @return
  41.      */
  42.     private static Jws getJws(String token) {
  43.             return Jwts.parser()
  44.                     .setSigningKey(generalKey())
  45.                     .parseClaimsJws(token);
  46.     }
  47.  
  48.     /**
  49.      * 获取payload body信息
  50.      *
  51.      * @param token
  52.      * @return
  53.      */
  54.     public static Claims getClaimsBody(String token) {
  55.         try {
  56.             return getJws(token).getBody();
  57.         }catch (ExpiredJwtException e){
  58.             return null;
  59.         }
  60.     }
  61.  
  62.     /**
  63.      * 获取hearder body信息
  64.      *
  65.      * @param token
  66.      * @return
  67.      */
  68.     public static JwsHeader getHeaderBody(String token) {
  69.         return getJws(token).getHeader();
  70.     }
  71.  
  72.     /**
  73.      * 是否过期
  74.      *
  75.      * @param claims
  76.      * @return -1：有效，0：有效，1：过期，2：过期
  77.      */
  78.     public static int verifyToken(Claims claims) {
  79.         if(claims==null){
  80.             return 1;
  81.         }
  82.         try {
  83.             claims.getExpiration()
  84.                     .before(new Date());
  85.             // 需要自动刷新TOKEN
  86.             if((claims.getExpiration().getTime()-System.currentTimeMillis())>REFRESH_TIME*1000){
  87.                 return -1;
  88.             }else {
  89.                 return 0;
  90.             }
  91.         } catch (ExpiredJwtException ex) {
  92.             return 1;
  93.         }catch (Exception e){
  94.             return 2;
  95.         }
  96.     }
  97.  
  98.     /**
  99.      * 由字符串生成加密key
  100.      *
  101.      * @return
  102.      */
  103.     public static SecretKey generalKey() {
  104.         byte[] encodedKey = Base64.getEncoder().encode(TOKEN_ENCRY_KEY.getBytes());
  105.         SecretKey key = new SecretKeySpec(encodedKey, 0, encodedKey.length, "AES");
  106.         return key;
  107.     }
  108.  
  109.     public static void main(String[] args) {
  110.        /* Map map = new HashMap();
  111.         map.put("id","11");*/
  112.         System.out.println(AppJwtUtil.getToken(1102L));
  113.         Jws jws = AppJwtUtil.getJws("eyJhbGciOiJIUzUxMiIsInppcCI6IkdaSVAifQ.H4sIAAAAAAAAADWLQQqEMAwA_5KzhURNt_qb1KZYQSi0wi6Lf9942NsMw3zh6AVW2DYmDGl2WabkZgreCaM6VXzhFBfJMcMARTqsxIG9Z888QLui3e3Tup5Pb81013KKmVzJTGo11nf9n8v4nMUaEY73DzTabjmDAAAA.4SuqQ42IGqCgBai6qd4RaVpVxTlZIWC826QA9kLvt9d-yVUw82gU47HDaSfOzgAcloZedYNNpUcd18Ne8vvjQA");
  114.         Claims claims = jws.getBody();
  115.         System.out.println(claims.get("id"));
  116.  
  117.     }
  118.  
  119. }

2.微服务搭建

（1）搭建工程

在tbug-headlines-service下创建工程tbug-headlines-user

【Spring Cloud】新闻头条微服务项目：使用JWT+MD5+Salt进行登录验证

（2）配置信息

①application.yml

  1. server:
  2.   port: 51801
  3. spring:
  4.   application:
  5.     name: headlines-user
  6.   cloud:
  7.     nacos:
  8.       discovery:
  9.         server-addr: 49.234.52.192:8848
  10.       config:
  11.         server-addr: 49.234.52.192:8848
  12.         file-extension: yml

②Nacos配置

在Nacos中添加id为headlines-user的配置项，配置信息如下

  1. spring:
  2.   redis:
  3.     host: 49.234.52.192
  4.     password: 440983
  5.     port: 6379
  6.   datasource:
  7.     driver-class-name: com.mysql.jdbc.Driver
  8.     url: jdbc:mysql://localhost:3306/headlines_user?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC&useSSL=false
  9.     username: root
  10.     password: 440983
  11. # 设置Mapper接口所对应的XML文件位置，如果你在Mapper接口中有自定义方法，需要进行该配置
  12. mybatis-plus:
  13.   mapper-locations: classpath*:mapper/*.xml
  14.   # 设置别名包扫描路径，通过该属性可以给包中的类注册别名
  15.   type-aliases-package: com.my.model.user.pojos

（3）功能代码

Controller层：

  1. package com.my.user.controller.v1;
  2.  
  3. import com.my.model.common.dtos.ResponseResult;
  4. import com.my.model.user.dtos.LoginDto;
  5. import com.my.user.service.ApUserService;
  6. import io.swagger.annotations.Api;
  7. import io.swagger.annotations.ApiOperation;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.web.bind.annotation.PostMapping;
  10. import org.springframework.web.bind.annotation.RequestBody;
  11. import org.springframework.web.bind.annotation.RequestMapping;
  12. import org.springframework.web.bind.annotation.RestController;
  13.  
  14.  
  15. @RestController
  16. @RequestMapping("/api/v1/login")
  17. @Api(value = "app端用户登录",tags = "app端用户登录")
  18. public class ApUserLoginController {
  19.  
  20.     @Autowired
  21.     private ApUserService apUserService;
  22.  
  23.     @PostMapping("/login_auth")
  24.     @ApiOperation("用户登录")
  25.     public ResponseResult login(@RequestBody LoginDto dto){
  26.         return apUserService.login(dto);
  27.     }
  28. }

mapper层：

  1. package com.my.user.mapper;
  2.  
  3.  
  4. import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  5. import com.my.model.user.pojos.ApUser;
  6. import org.apache.ibatis.annotations.Mapper;
  7.  
  8. @Mapper
  9. public interface ApUserMapper extends BaseMapper {
  10. }

service层：

  1. package com.my.user.service;
  2.  
  3. import com.baomidou.mybatisplus.extension.service.IService;
  4. import com.my.model.admin.dtos.UserAuditDto;
  5. import com.my.model.common.dtos.ResponseResult;
  6. import com.my.model.user.dtos.LoginDto;
  7. import com.my.model.user.pojos.ApUser;
  8.  
  9. public interface ApUserService extends IService {
  10.     /**
  11.      * app端登录功能
  12.      * @param dto
  13.      * @return
  14.      */
  15.     ResponseResult login(LoginDto dto);
  16. }
  1. package com.my.user.service.impl;
  2.  
  3. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  4. import com.baomidou.mybatisplus.core.metadata.IPage;
  5. import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.my.model.admin.dtos.UserAuditDto;
  8. import com.my.model.common.dtos.ResponseResult;
  9. import com.my.model.common.enums.AppHttpCodeEnum;
  10. import com.my.model.user.dtos.LoginDto;
  11. import com.my.model.user.pojos.ApUser;
  12. import com.my.user.mapper.ApUserMapper;
  13. import com.my.user.service.ApUserService;
  14. import com.my.utils.common.AppJwtUtil;
  15. import lombok.extern.slf4j.Slf4j;
  16. import org.springframework.stereotype.Service;
  17. import org.springframework.transaction.annotation.Transactional;
  18. import org.springframework.util.DigestUtils;
  19.  
  20. import java.nio.charset.StandardCharsets;
  21. import java.util.HashMap;
  22. import java.util.Map;
  23.  
  24.  
  25. @Service
  26. @Transactional
  27. @Slf4j
  28. public class ApUserServiceImpl extends ServiceImpl implements ApUserService {
  29.     /**
  30.      * app端登录功能
  31.      * @param dto
  32.      * @return
  33.      */
  34.     @Override
  35.     public ResponseResult login(LoginDto dto) {
  36.         //1.正常登录 用户名和密码
  37.         if(!dto.getPhone().isEmpty() && !dto.getPassword().isEmpty()){
  38.             //1.1根据用户名获取用户信息
  39.             LambdaQueryWrapper lqw = new LambdaQueryWrapper();
  40.             lqw.eq(ApUser::getPhone,dto.getPhone());
  41.             ApUser user = this.getOne(lqw);
  42.  
  43.             //1.2没有该用户信息
  44.             if(user == null) {
  45.                 return ResponseResult.errorResult(AppHttpCodeEnum.DATA_NOT_EXIST,"用户信息不存在");
  46.             }
  47.  
  48.             //1.3比对用户密码
  49.             String password = user.getPassword();
  50.             String salt = user.getSalt();
  51.             String loginPassword = DigestUtils.md5DigestAsHex((dto.getPassword() + salt).getBytes(StandardCharsets.UTF_8));
  52.             if(!loginPassword.equals(password)) {
  53.                 //密码不正确
  54.                 return ResponseResult.errorResult(AppHttpCodeEnum.LOGIN_PASSWORD_ERROR,"密码错误");
  55.             }
  56.  
  57.             //1.4查看用户状态
  58.             if(user.getStatus()) {
  59.                 //用户被锁定
  60.                 return ResponseResult.errorResult(AppHttpCodeEnum.NO_OPERATOR_AUTH,"用户已被锁定");
  61.             }
  62.  
  63.             //1.5设置token
  64.             String token = AppJwtUtil.getToken(user.getId().longValue());
  65.             Map map = new HashMap();
  66.             map.put("token",token);
  67.             map.put("user",user);
  68.             return ResponseResult.okResult(map);
  69.         }else {
  70.             //2.游客登录
  71.             Map map = new HashMap();
  72.             map.put("token",AppJwtUtil.getToken(0L));
  73.             return ResponseResult.okResult(map);
  74.         }
  75.     }
  76.  
  77.  
  78. }

下篇预告：App端文章的加载

版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/weixin_45750572/article/details/126136810
声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。
0 条回复 A文章作者 M管理员
    暂无讨论，说说你的看法吧
❯
个人中心
购物车
优惠劵
有新私信 私信列表
搜索

  • 扫码打开当前页

返回顶部