spring – 如何使用WebClient限制请求/秒？

我正在使用WebClient对象将Http Post请求发送到服务器.
它正在快速发送大量请求(QueueChannel中有大约4000条消息).问题是……似乎服务器响应速度不够快……所以我得到了很多服务器错误500和connexion过早关闭.

有没有办法限制每秒的请求数量？或者限制它使用的线程数量？

编辑：

QueueChannel中的Message endpoint processe消息：

@MessageEndpoint
public class CustomServiceActivator {

    private static final Logger logger = LogManager.getLogger();

    @Autowired
    IHttpService httpService;

    @ServiceActivator(
            inputChannel = "outputFilterChannel",
            outputChannel = "outputHttpServiceChannel",
            poller = @Poller( fixedDelay = "1000" )
    )
    public void processMessage(Data data) {
        httpService.push(data);
        try {
            Thread.sleep(20);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

}

WebClient服务类：

@Service
public class HttpService implements IHttpService {

    private static final String URL = "http://www.blabla.com/log";

    private static final Logger logger = LogManager.getLogger();

    @Autowired
    WebClient webClient;

    @Override
    public void push(Data data) {
        String body = constructString(data);
        Mono<ResponseEntity<Response>> res = webClient.post()
                .uri(URL + getLogType(data))
                .contentLength(body.length())
                .contentType(MediaType.APPLICATION_JSON)
                .syncBody(body)
                .exchange()
                .flatMap(response -> response.toEntity(Response.class));

        res.subscribe(new Consumer<ResponseEntity<Response>>() { ... });
    }
}

解决方法:

问题Limiting rate of requests with Reactor提供了两个答复者(一个在评论中)

zipWith另一种作为速率限制器的通量

.zipWith(Flux.interval(Duration.of(1,ChronoUnit.SECONDS)))

只是推迟每个网络请求

使用delayElements函数

编辑：下面的答案对于阻止RestTemplate有效,但不太适合反应模式.

WebClient无法限制请求,但您可以使用合成轻松添加此功能.

您可以使用Guava /中的RateLimiter从外部限制客户端
(https://google.github.io/guava/releases/19.0/api/docs/index.html?com/google/common/util/concurrent/RateLimiter.html)

在本教程http://www.baeldung.com/guava-rate-limiter中,您将了解如何以阻止方式或超时使用速率限制器.

我会装饰所有需要在单独的类中受到限制的调用

>限制每秒的呼叫数
>使用WebClient执行实际的Web调用

标签：project-reactor,spring-webflux,spring
来源： https://codeday.me/bug/20191008/1871594.html