lagou 爪哇 3-4 spring cloud 问答笔记

server {
    listen       80;
    server_name  localhost;
    location /static/ {        
        root   /Users/ale/Desktop/abc/stage-3-module-4/code/static/;
        rewrite '^/static(.*)$' $1 break;
    }
    location /api/ {
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr; # 客户端的真实IP
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        proxy_pass http://127.0.0.1:9002/; # 网关地址
    }
}

127.0.0.1 edu.lagou.com

create database lagou_3_4;
-- 验证码存储表
DROP TABLE IF EXISTS `lagou_auth_code`;
CREATE TABLE `lagou_auth_code` (
 `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '⾃增主键',
 `email` varchar(64) DEFAULT NOT NULLCOMMENT '邮箱地址',
 `code` varchar(6) DEFAULT NOT NULLCOMMENT '验证码',
 `createtime` datetime DEFAULT NOT NULLCOMMENT '创建时间',
 `expiretime` datetime DEFAULT NOT NULLCOMMENT '过期时间',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
SET FOREIGN_KEY_CHECKS = 1;
-- 令牌存储表
DROP TABLE IF EXISTS `lagou_token`;
CREATE TABLE `lagou_token` (
 `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '⾃增主键',
 `email` varchar(64) NOT NULL COMMENT '邮箱地址',
 `token` varchar(255) NOT NULL COMMENT '令牌',
 PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- lagou_token 表中为 邮箱 字段添加 UNIQUE 索引
ALTER TABLE `lagou_3_4`.`lagou_token` 
ADD UNIQUE INDEX(`email`);
-- lagou_token 表中添加 password 字段
ALTER TABLE `lagou_3_4`.`lagou_token` 
ADD COLUMN `password` varchar(40) NOT NULL COMMENT '用户密码' AFTER `token`;
SET FOREIGN_KEY_CHECKS = 1;
INSERT INTO `lagou_3_4`.`lagou_auth_code`(`email`, `code`, `createtime`, `expiretime`) VALUES ('zhangsan@qq.com', '543363', '2020-12-19 18:36:39', '2020-12-19 18:36:42');

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-mail</artifactId>
        </dependency>

spring:
  application:
    name: lagou-service-email
  mail:
    # 发送邮件服务器
    host: smtp.qq.com
    username: acc8226@vip.qq.com
    # 可拥有多个授权码，所以无需记住该授权码，也不要告诉其他人
    password: YOUR-PASSWORD

public void sendSimpleMail(String toEmailAddress, String code) {
        final SimpleMailMessage simpleMailMessage = new SimpleMailMessage();
        simpleMailMessage.setTo(toEmailAddress);
        simpleMailMessage.setSubject("收到来自【lagou】发送的验证码");
        simpleMailMessage.setText(String.format(pattern, code));
        simpleMailMessage.setFrom(this.fromEmailAddress);
        this.javaMailSender.send(simpleMailMessage);
        log.info("邮件发送成功 address = {}, code = {}", toEmailAddress, code);
    }

/**
    * ⽣成验证码 并 发送到对应邮箱
    * 场景：注册页面点击"获取验证码"按钮触发
    *
    * @param email
    * @return 0成功 1失败 2该用户已注册,不能再次注册
    */
@GetMapping("create/{email}")
public int create(@PathVariable("email") final String email) {
    int resultCode;
    try {
        // 1. 判断该用户是否存在
        final boolean isEmailRegistered = this.userServiceFeignClient.isRegistered(email);
        if (isEmailRegistered) {
            resultCode = 2;
        } else {
            final String randomCode = RandomUtils.getSixRandomCode();
            // 2. 若不存在 则 调用 email 微服务，发送携带了验证码的邮件
            final boolean register = this.mailServiceFeignClient.send(email, randomCode);
            // 3. 顺便入库
            this.authCodeService.createAuthCode(email, randomCode);
            log.info("create # send result = {}, email = {}, randomCode = {}", register, email, randomCode);
            resultCode = 0;
        }
    } catch (Exception e) {
        resultCode = 1;
        log.error("create ⽣成验证码 失败", e);
    }
    return resultCode;
}

/**
     * 校验验证码是否正确(合法)，0合法, 1验证码前后校验不一致, 2超时, 3异常情况
     * 场景：被 user 微服务的注册功能调用
     *
     * @param email 传入的电子邮箱
     * @param code  传入的验证码，前端已做了非空校验，此处不再做校验
     * @return
     */
    @GetMapping("validate/{email}/{code}")
    public int validate(@PathVariable("email") String email, @PathVariable("code") String code)

2020-12-21 00:44:25.836 DEBUG 36852 --- [nio-8081-exec-1] c.l.edu.service.MailServiceFeignClient   : [MailServiceFeignClient#register] <--- ERROR SocketTimeoutException: Read timed out (2381ms)
2020-12-21 00:44:25.837 DEBUG 36852 --- [nio-8081-exec-1] c.l.edu.service.MailServiceFeignClient   : [MailServiceFeignClient#register] java.net.SocketTimeoutException: Read timed out

ribbon:
  # 适当调大 请求处理超时时间，避免之后 feign 进行重试
  ReadTimeout: 20000

/**
    * 注册接⼝
    *
    * @param email    E-mail
    * @param password 密码
    * @param code     验证码
    * @return 0合法, 1验证码前后校验不一致, 2超时, 3异常情况，4该用户已注册过了
    */
@GetMapping("register/{email}/{password}/{code}")
public int register(HttpServletResponse response,
                    @PathVariable("email") String email,
                    @PathVariable("password") String password,
                    @PathVariable("code") String code) {
    int validateResult;
    // 1. 如果没有注册才允许注册
    if (this.tokenService.isRegistered(email)) {
        validateResult = 4;
    } else {
        try {
            // 2. 调用 code 微服务-校验验证码的合法性： 0合法, 1密码前后校验不一致, 2超时, 3异常情况
            validateResult = this.authCodeServiceFeignClient.validate(email, code);
            log.info("验证码校验结果 = {}", validateResult);
            if (validateResult == 0) {
                // 3. 生成 token 并入库     【1. 入库】
                Token token = this.tokenService.register(email, password);
                // 4. token 写入 cookie 中 【2. 写入 cookie 并返回前端】
                saveTokenToResponse(response, token.getToken());
            }
        } catch (Exception e) {
            log.error("register method throw error:", e);
            validateResult = 3;
        }
    }
    // 5. 前端根据此不出错的标记去跳转到 welcome 页面
    return validateResult;
}

/**
    * 登录接⼝
    *
    * @param email 邮箱地址
    * @return 登录成功返回邮箱地址, 否则 原始密码已损坏 和 密码不一致为 ERROR 或 用户不存在为 EMPTY
    */
@GetMapping("login/{email}/{password}")
public String login(HttpServletResponse response, @PathVariable String email, @PathVariable String password) {
    log.info("login: email = {}, password = {}", email, password);
    final String returnMsg;
    final Optional<Token> findOne = this.tokenService.findOneItemByEmail(email);
    if (!findOne.isPresent()) {
        // 1. 用户不存在的情况：应提示用户去注册
        returnMsg = Response.EMPTY_MESSAGE;
    } else {
        // 2. 根据 email 知道对应的 用户信息
        Token token = findOne.get();
        String originPassword = token.getPassword();
        // 3. 用户的密码继续比对， 密码不一致的情况(包含了 原始密码已损坏 的情况）
        if (Strings.isBlank(originPassword) || !originPassword.equals(password)) {
            returnMsg = Response.ERROR_MESSAGE;
        } else {
            // 4. 刷新 token 并入库    【1. 入库】
            this.tokenService.login(token);
            // 5. 将 token 信息返回前端 【2. 写入 cookie 并返回前端】
            saveTokenToResponse(response, token.getToken());
            // 6. 前端根据此不出错的标记去跳转到 welcome 页面
            returnMsg = token.getEmail();
        }
    }
    log.info("login: returnMsg = {}", returnMsg);
    return returnMsg;
}

127.0.0.1 LagouCloudEurekaServerA
127.0.0.1 LagouCloudEurekaServerB

#eureka server服务端口
server:
  port: 8761
spring:
  application:
    # 应用名称，应用名称会在Eureka中作为服务名称
    name: lagou-cloud-eureka-server
    # eureka 客户端配置（和Server交互），Eureka Server 其实也是一个Client
eureka:
  client:
    service-url:
      # 配置客户端所交互的Eureka Server的地址（Eureka Server集群中每一个Server其实相对于其它Server来说都是Client）
      # 集群模式下，defaultZone应该指向其它 Eureka Server，如果有更多其它Server实例，逗号拼接即可
      defaultZone: http://LagouCloudEurekaServerB:8762/eureka
    # 集群模式下可以改成 true
    register-with-eureka: true
    # 集群模式下可以改成 true
    fetch-registry: true
  dashboard:
    # 默认已经为 true了
    enabled: true
  instance:
    # 当前eureka实例的主机名
    hostname: LagouCloudEurekaServerA

spring:
  application:
    name: lagou-cloud-gateway
  cloud:
    # gateway 网关从服务注册中心获取实例信息然后负载后路由
    gateway:
      routes: # 路由可以有多个
        # 我们自定义的路由 ID，保持唯一
        - id: service-code-router
          # 目标服务地址  自动投递微服务（部署多实例）动态路由：uri配置的应该是一个服务名称，而不应该是一个具体的服务实例的地址. http为写死地址，lb为从注册中心取地址
          uri: lb://lagou-service-code
          # 断言：路由条件，Predicate 接受一个输入参数，返回一个布尔值结果。该接口包含多种默 认方法来将 Predicate 组合成其他复杂的逻辑（比如：与，或，非）。
          predicates:
            - Path=/code/**
        - id: service-email-router
          uri: lb://lagou-service-email
          predicates:
            - Path=/email/**
        - id: service-user-router
          uri: lb://lagou-service-user
          predicates:
            - Path=/user/**

if (null != path) {
    // 排除 user 和 code 服务
    if (!path.startsWith("/user") && !path.startsWith("/code")) {
        Optional<String> tokenOptional = getTokenValue(request);
        // token is null
        if (!tokenOptional.isPresent()) {
            return write401Mono(response);
        }
        String token = tokenOptional.get();
        // token is blank
        if (Strings.isBlank(token)) {
            return write401Mono(response);
        }
        // 校验 token 是否合法, 这里只做基本校验。认为只要长度大于 30 就是后端仍可的合法 token
        if (token.length() < 30) {
            return write401Mono(response);
        }
    }
}
// 合法请求，放行，执行后续的过滤器
return chain.filter(exchange);

// 注册服务的路径
if (null != path && path.startsWith("/user/register/")) {
    // 由于使用了 nginx 转发，所以从特定请求头中拿出 实际 IP 地址
    String realIP = request.getHeaders().getFirst("X-Real-IP");
    if (!Strings.isBlank(realIP)) {
        IPRecordQueue ipRecordQueue = concurrentHashMap.get(realIP);
        if (ipRecordQueue == null) {
            ipRecordQueue = new IPRecordQueue(min, per);
            concurrentHashMap.put(realIP, ipRecordQueue);
        }
        boolean isOffer = ipRecordQueue.offer(LocalDateTime.now());
        if (!isOffer) {
            // 前端据此 UNAUTHORIZED 跳转到 login 页面
            response.setStatusCode(HttpStatus.SEE_OTHER);
            DataBuffer wrap = response.bufferFactory().wrap("您频繁进⾏注册，请求已被拒绝".getBytes());
            return response.writeWith(Mono.just(wrap));
        }
    }
}
// 合法请求，放行，执行后续的过滤器
return chain.filter(exchange);

spring:
# 数据库配置
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://YOUR-IP:3306/lagou_3_4?useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai
    username: root
    password: YOUR-PASSWORD
# 邮箱配置
  mail:
    ## 发送邮件服务器
    host: smtp.qq.com
    ## 发送邮件的邮箱地址
    username: acc8226@qq.com
    ## 客户端授权码，不是邮箱密码，这个在qq邮箱设置里面自动生成的
    password: YOUR-PASSWORD
# 防暴刷配置：限制单个客户端ip最新 X 分钟的请求注册接口不能超过 Y 次
myconfig:
  x: 1
  y: 1