Quarkus Rest客户端限制/速率限制

Question

我正在使用quarkus.rest客户端调用外部API，并希望将这些调用的频率限制在每秒50次，这样我就不会淹没外部服务。在没有侧车方法的情况下（通过代码），推荐的实现方法是什么？

Answer 1

您可以使用< code > @ Bulkhead micro profile注释，并为方法的执行设置最大并发线程限制。但是，这只适用于应用程序的一个实例。

日食微配置文件文档

从上面的留档复制的示例：

@Bulkhead(5) // maximum 5 concurrent requests allowed
public Connection serviceA() {
   Connection conn = null;
   counterForInvokingServiceA++;
   conn = connectionService();
   return conn;
}

// maximum 5 concurrent requests allowed, maximum 8 requests allowed in the waiting queue
@Asynchronous
@Bulkhead(value = 5, waitingTaskQueue = 8)
public Future<Connection> serviceA() {
   Connection conn = null;
   counterForInvokingServiceA++;
   conn = connectionService();
   return CompletableFuture.completedFuture(conn);
}

您甚至可以在部署中设置值，这样就可以在不进行新构建的情况下更改此参数。

要使用@Bulkhead，必须将容错添加到项目中

<dependency>
    <groupId>io.quarkus</groupId>
    <artifactId>quarkus-smallrye-fault-tolerance</artifactId>
</dependency>