Flux에서 항목을 계산하는 방법, 개수가 X보다 크면 오류를 반환하고, 그렇지 않으면 파이프라인으로 계속 진행합니다.

Flux에서 항목을 계산하는 방법, 개수가 X보다 크면 오류를 반환하고, 그렇지 않으면 파이프라인으로 계속 진행합니다. 물어보다

1. 질문(문제점):

저는 Spring의 Project Reactor를 처음 접했고 어떻게 해야 할지 잘 모르겠습니다.

파이프라인에서 레코드를 반환하는 파이프라인이 있습니다. 문제 없다.

그러나 나는 그 레코드를 세고 다른 일과 같은 일을 하고 싶습니다. 리턴된 레코드가 > X이고 오류이면 그냥 계속하십시오.

Count가 를 반환한다는 사실을 알고 Mono<Long>나면 그 후에 레코드가 손실될 것입니다. 어떻게 해야 합니까?

생각 중이 야:

어떻게든 flatMap이 플랫맵 내에서 무언가를 사용하고 수행하십시오. 어떻게 든 reduceFlux에 도움이 될 수있는 방법이 있음을 알았습니다.

요점은 어떻게 진행해야 할지 모르겠습니다.

2. 해결방안:

나는 또한 Spring Reactor 및 반응 프로그래밍에 익숙하지 않지만 결국 시도했고 이것은 플럭스 요소 번호의 Long 값을 반환하는 데 효과적이었습니다.

fluxObject.count().block().longValue()

이 경우 에도 사용할 수 있습니다 shortValue().

61938744