在Spring Cloud微服务架构中想要实现手机验证码认证授权，并在后端调用中标识用户信息，可以通过如下的方式来实现，第一步，就是如何获取手机验证码的逻辑处理，可以调用相关的短信服务接口来完成短信发送操作，第二步、用户收到了手机验证码之后，对用户手机验证码操作进行验证并且获取到Token值用来完成用户身份鉴权操作。下面我们就来详细的介绍一下如何实现手机验证码验证用户信息。

手机号验证码认证服务

如下所示，通过下面的代码来实现验证码的获取以及手机验证码的验证

@RestController
@RequestMapping("/api/verification")
public class VerificationController {

    @PostMapping("/send")
    public ResponseEntity<Void> sendVerificationCode(@RequestParam String phoneNumber) {
        // 生成并发送验证码逻辑
        // sendSms(phoneNumber, generatedCode);
        return ResponseEntity.ok().build();
    }

    @PostMapping("/verify")
    public ResponseEntity<Void> verifyCode(@RequestParam String phoneNumber, @RequestParam String code) {
        // 验证验证码逻辑
        // boolean isValid = validateCode(phoneNumber, code);
        if (isValid) {
            return ResponseEntity.ok().build();
        } else {
            return ResponseEntity.status(HttpStatus.UNAUTHORIZED).build();
        }
    }
}

在上述代码中，缺少了Token的认证以及获取返回，下面我们就来看看通过JWT技术来生成用户认证的Token操作。

首先需要创建一个TokenService用来完成Token的生成以及验证工作。如下所示。

@Service
public class TokenService {

    private String secretKey = "your-secret-key";

    public String generateToken(String phoneNumber) {
        return Jwts.builder()
                .setSubject(phoneNumber)
                .setIssuedAt(new Date())
                .setExpiration(new Date(System.currentTimeMillis() + 3600000)) // 1 hour
                .signWith(SignatureAlgorithm.HS512, secretKey)
                .compact();
    }

    public Claims getClaimsFromToken(String token) {
        return Jwts.parser()
                .setSigningKey(secretKey)
                .parseClaimsJws(token)
                .getBody();
    }

    public String getPhoneNumberFromToken(String token) {
        return getClaimsFromToken(token).getSubject();
    }
}

一旦用户通过了验证码验证，可以为其生成一个 JWT（JSON Web Token）来标识用户身份。JWT 可以在后续的 API 调用中用于用户身份验证。按照这个思路我们来优化用户认证操作。

@RestController
@RequestMapping("/api/verification")
public class VerificationController {

    @Autowired
    private TokenService tokenService;

    @PostMapping("/verify")
    public ResponseEntity<String> verifyCode(@RequestParam String phoneNumber, @RequestParam String code) {
        // 验证验证码逻辑
        boolean isValid = validateCode(phoneNumber, code); // 实现验证码验证逻辑
        if (isValid) {
            String token = tokenService.generateToken(phoneNumber);
            return ResponseEntity.ok(token); // 返回 Token 给客户端
        } else {
            return ResponseEntity.status(HttpStatus.UNAUTHORIZED).build();
        }
    }

    private boolean validateCode(String phoneNumber, String code) {
        // 实现验证码验证逻辑
        return true;
    }
}

用户身份验证与授权

在微服务架构中，通常使用一个网关服务（如 Spring Cloud Gateway）来进行全局的身份验证。可以配置网关服务来拦截请求，并验证 JWT。如下所示

spring:
  cloud:
    gateway:
      routes:
        - id: user_service
          uri: lb://USER-SERVICE
          predicates:
            - Path=/api/users/**
          filters:
            - AddRequestHeader=Authorization, Bearer {token}

在网关过滤器中，我们可以自定义Token验证的规则，如下所示。

@Component
public class JwtAuthenticationFilter extends GatewayFilterAdapter {

    @Autowired
    private TokenService tokenService;

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        ServerHttpRequest request = exchange.getRequest();
        String token = request.getHeaders().getFirst(HttpHeaders.AUTHORIZATION);

        if (token != null && token.startsWith("Bearer ")) {
            token = token.substring(7);
            try {
                String phoneNumber = tokenService.getPhoneNumberFromToken(token);
                // Attach user information to the request context
                exchange.getAttributes().put("phoneNumber", phoneNumber);
            } catch (Exception e) {
                // Handle token validation failure
                return Mono.error(new RuntimeException("Invalid Token"));
            }
        }

        return chain.filter(exchange);
    }
}

在上述代码中，我们将解析出的 phoneNumber 存储在 exchange.getAttributes() 中。这些属性将在整个请求处理链中保持可用。

验证通过之后，接下来我们就可以在调用的微服务中通过上下文请求来获取到用户信息，进行其他的操作了。

微服务中的用户信息获取

在微服务中，可以通过访问 ServerWebExchange 的属性来获取存储的信息，如下所示。

@RestController
@RequestMapping("/api/users")
public class UserController {

    @GetMapping("/me")
    public ResponseEntity<User> getUserInfo(ServerWebExchange exchange) {
        // 从上下文中获取用户信息
        String phoneNumber = exchange.getRequest().getHeaders().getFirst("phoneNumber");
        // 根据 phoneNumber 查询用户信息
        User user = userService.getUserByPhoneNumber(phoneNumber);
        return ResponseEntity.ok(user);
    }
}

除了在 Spring Cloud Gateway 中使用 ServerWebExchange，还可以使用一些工具来实现全局请求上下文。例如，Spring Boot 提供的 RequestContextHolder 可以在服务中获取当前请求的上下文。这对于在 Spring MVC 控制器中传递请求信息非常有用。

使用RequestContextHolder

import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.RequestAttributes;

public class SomeService {

    public void someMethod() {
        RequestAttributes attributes = RequestContextHolder.getRequestAttributes();
        String phoneNumber = (String) attributes.getAttribute("phoneNumber", RequestAttributes.SCOPE_REQUEST);
        // 使用 phoneNumber
    }
}

总结

通过上述的步骤，就可以实现用户通过手机验证码认证后，在微服务架构中有效地进行用户身份验证和授权。