小编Lok*_*a S的帖子

默认情况下,spring web flux使用netty,它是单线程事件循环.如何配置spring boot以便为每个核心创建一个线程.

谢谢,

LOKESH

我正在尝试创建应该返回 201 响应的框架。当向 API 发出请求时，我想立即发回响应并在后台处理请求。

Flux.fromIterable(request.getApiRequests()).log().flatMap(item -> {

        WebClient.RequestHeadersSpec apiCallSpec = WebClient.create(request.getBasePath())
                .method(item.getHttpMethod()).uri(item.getPath()).accept(MediaType.valueOf(item.getAccept()))
                .contentType(MediaType.valueOf(item.getContentType())).body(BodyInserters.fromObject(item.getPayload()));

        return apiCallSpec.retrieve().bodyToMono(String.class);
    }).subscribe();

    return Mono.just("Created");

我希望通量部分发生在后台，但截至目前，一旦整个通量被流式传输，API 就会等待并响应。

有什么办法可以一直运行一个角色吗？我在开始任何部署之前创建锁定文件以防止并行部署。如果发生任何失败/成功，我想删除锁定文件。

- { role: lock-deployment, tags: always }
- { role: fetch-artifactory, tags: always }
- { role: unlock-deployment, tags: always }

我想运行解锁部署角色，无论失败/成功。