反应式规划如何进行决策

Question

我不熟悉反应式编程。为了得到我的手，我试图建立一个简单的RESTAPI，但与请求验证和数据库操作。

以下是我想做的步骤。

• 验证传入请求参数
• 验证后保持继续链并从数据库获取
  • 如果用户不存在于db返回一些错误响应
  • 如果用户存在，返回带有用户名的成功响应

  注意：请求和响应由类（UserRequest和UserResponse）表示。DB=使用无功驱动程序的Mongo。

  我已经完成了验证工作，但现在我不知道如何继续以及反应式编程的正确方法是什么。

  @Component
  public class UserController {
  
      @Autowired
      private UserRepository userRepository; // repo has find by id method which returns Mono<User>
  
      public Mono<ServerResponse> handleUserRequest(ServerRequest serverRequest) {
  
          Mono<UserRequest> request = validateRequest(serverRequest);
          
          // what should i do here like now i would like to fetch user from db
  
          return ServerResponse.ok().body("Welcome", String.class);
          // how would i return "Welcome <username>";
      }
  
      private Mono<UserRequest> validateRequest(ServerRequest request) {
  
          Mono<UserRequest> userRequest = Mono.just(new UserRequest());
  
          Mono<UserRequest> validateUser = userRequest
                  .map(req -> { //validate id
                      Optional<String> userid = request.queryParam("userid");
  
                      if (user.isPresent() && ObjectId.isValid(userid.get())) {
                          return req.setUserid(userid.get());
                      }
  
                      throw new RequestEntityValidationException("Invalid user");
                  });
  
  
          return validateUser;
      }
  }
  

  还有没有类似的并排教程，在命令式和反应式中分别显示一般代码片段。

Answer 1

使用功能性反应HTTPendpoint时没有内置方式，但您可以尝试https://github.com/making/yavi

您可以对Spring Webflux HTTP控制器使用有效的

Answer 2

反应式规划的主要思想是始终处理流链。根据db数据获取，您可以使用userRepository获取数据。findUserById（id）或类似于此。因此，您将收到单声道

为了处理这种情况，我建议使用以下代码：

public Mono<ServerResponse> handleUserRequest(ServerRequest serverRequest) {
    return validateRequest(serverRequest)
            .flatMap(userRequest -> userRepository.findUserById(userRequest.getUserId())
                    .switchIfEmpty(Mono.error(new RuntimeException("Not found")))
            )
            .flatMap(user -> ServerResponse.ok().body("Welcome " + user.getUsername(), String.class));
}

您可以调整您的validateRequest方法以更具功能性（无需isPresent检查）：

private Mono<UserRequest> validateRequest(ServerRequest request) {
    return Mono.just(request)
            .map(req -> request.queryParam("userId")
                    .map(UserRequest::new)
                    .orElseThrow(() -> new RuntimeException("Invalid user"))
            );
}