Spring-WebFlux：从Mono中提取对象，不带块（）

Question

我是新的Spring WebFlux。我正在编写一个简单的api，它调用另一个api，并返回响应。我遇到的问题是我的api接受不同于外部api的请求类型。我必须将传入的请求转换为外部api。我使用Mono来接收对我的api的请求，但在没有block（）的情况下转换为另一个对象时遇到了麻烦。

输入

@Configuration
@EnableWebFlux
public class RouterConfig implements WebFluxConfigurer{

    @Bean
    public RouterFunction<ServerResponse> routes(UserHandler handler){
        
        return RouterFunctions
                .route(POST("/rest/create"),
                        handler::createUser);
    }
    
} 

@Component
public class UserHandler {

    private UserService service;

    public UserHandler(UserService service) {
    this.service = service;
    }

      
    public Mono<ServerResponse> saveUser(ServerRequest request) 
    {
    
        Mono<User> user = request.bodyToMono(User.class)
    
        /* currently I am using block to get User object */
    
         User user1 = user.block()
    
        /* convert user to person */
       
           Person p =getPersonFromUser(user);
    
       
    
        
    }

 class User
    {
      private String name;
      private String id;
      private String email;
       private String phone;    
    
    
    }



 class Person
    {
      private String email;
      /* Combination of id and name */
      private String accountNumber;
      private String phone;
    
    }

有没有一种方法可以把单声道转换成Person对象而不阻塞？

Answer 1

如果您愿意用Mono-Lambda处理Person p，那么您可以尝试

public Mono<ServerResponse> saveUser(ServerRequest request) 
{
    // Mono<User> user = request.bodyToMono(User.class)
    request.bodyToMono(User.class)

    // Convert a Mono<User> to a Mono<Person>    
    .map((User user1) -> getPersonFromUser(user))

    .map((Person p) -> {
        // Code that either returns ServerResponse object or an intermediary object
    })
    // Additional code as needed

因为request.bodytomono（User.class）返回一个用户的Mono，所以可以调用该Mono的map方法。map方法接受一个lambda类型函数，该函数接受一种类型的参数并返回一个不同类型的对象。

发出的第一个地图调用：

.map((User user1) -> getPersonFromUser(user))

.map((User user1) -> getPersonFromUser(user))

.flatMap((User user1) -> getPersonFromUser(user))

如果您对map vs flatmap感兴趣，可以查看这个StackOverFlow问题