|
此版本仍在开发中，目前尚不稳定。如需最新稳定版本，请使用 Spring AMQP 4.0.2！ |
RabbitMQ REST API
当管理插件启用时，RabbitMQ 服务器会暴露一个 REST API，用于监控和配置代理服务器。API 的 Java 绑定 现已提供。com.rabbitmq.http.client.Client 是一个标准、即时且因此为阻塞式的 API。它基于 Spring Web 模块及其 RestTemplate 实现。另一方面，com.rabbitmq.http.client.ReactorNettyClient 是一个响应式、非阻塞的实现，基于 Reactor Netty 项目。
此外，管理 REST API 可与任何 HTTP 客户端一起使用。下一个示例展示了如何使用 WebClient 获取队列信息：
public Map<String, Object> queueInfo(String queueName) throws URISyntaxException {
WebClient client = createClient("admin", "admin");
URI uri = queueUri(queueName);
return client.get()
.uri(uri)
.accept(MediaType.APPLICATION_JSON)
.retrieve()
.bodyToMono(new ParameterizedTypeReference<Map<String, Object>>() {
})
.block(Duration.ofSeconds(10));
}
private URI queueUri(String queue) throws URISyntaxException {
URI uri = new URI("http://localhost:15672/api/")
.resolve("/api/queues/" + UriUtils.encodePathSegment("/", StandardCharsets.UTF_8) + "/" + queue);
return uri;
}
private WebClient createClient(String adminUser, String adminPassword) {
return WebClient.builder()
.filter(ExchangeFilterFunctions.basicAuthentication(adminUser, adminPassword))
.build();
}