了解Micronaut2

Question

寻求帮助，以了解什么是正确的模式与Micronaut2。默认情况下，所有控制器方法现在都运行在NIO Eventloop线程上。文档警告不要在此线程上进行任何阻塞调用，而是将其卸载到线程池（使用@executeon或RxJava SubscribeOn）作为阻塞调用的示例，文档讨论了DB调用或JPA调用。

我有一个场景，需要调用多个微服务--因此涉及多个IO调用。我通过定义接口等为它使用声明性客户端，文档说，所有HttpClient调用都是在NIO EventLoop上完成的。但是当这些Http调用阻塞时，直到它们得到响应，我有点困惑--我需要将它们卸载到一个单独的IO池吗？HttpClient使用的NIO Eventloop线程在执行并得到http响应之前不会阻塞吗？我一直在使用客户端接口的常用返回类型。然后我需要从它们返回一个RxJava类型吗？可能是我想多了--但当我们必须从控制器方法调用其他微服务时，我确实很困惑什么是正确的模式？有什么帮助-谢谢。

Answer 1

文档提供了一个声明式http客户端的示例。

@Client("/pets") 
public interface PetClient extends PetOperations { 

    @Override
    Single<Pet> save(String name, int age); 
}

请注意save方法的返回类型是single，它是非阻塞的反应类型。

如果使用阻塞类型声明客户端中的方法,则调用将阻塞,这不是您想要的：

@Client("/pets") 
public interface PetClient extends PetOperations { 

    @Override
    Pet save(String name, int age); //blocking call
}

您应该使用非阻塞类型；在我链接的部分的末尾，有一个与@client兼容的响应类型列表。