在Mono<T>的subscribe方法中调用REST API,可以通过以下步骤实现:
下面是一个示例代码:
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
public class RestClient {
public static void main(String[] args) {
WebClient webClient = WebClient.create();
Mono<String> responseMono = webClient.get()
.uri("https://api.example.com/resource")
.retrieve()
.bodyToMono(String.class);
responseMono.subscribe(
response -> {
// 处理响应数据
System.out.println("Response: " + response);
},
error -> {
// 处理错误
System.err.println("Error: " + error.getMessage());
}
);
}
}
在上述示例中,我们使用WebClient创建了一个GET请求,并指定了REST API的URL。然后,我们使用retrieve方法获取响应,并使用bodyToMono方法将响应数据转换为Mono<String>类型。最后,我们在subscribe方法中处理响应数据和错误。
这是一个简单的示例,你可以根据具体需求进行更复杂的操作,例如添加请求头、发送POST请求、处理响应状态码等。
推荐的腾讯云相关产品:腾讯云云服务器(CVM)、腾讯云对象存储(COS)、腾讯云云函数(SCF)等。你可以通过访问腾讯云官方网站获取更多关于这些产品的详细信息和文档链接。
领取专属 10元无门槛券
手把手带您无忧上云