project-reactor

1열

2답변

RxJava 또는 Reactive Stream에서 content based routing을 수행하는 관용적 인 방법을 알고 있습니까? 지도 필터와 변환과 같은 표준 연산자를 사용하여 반응 메시지 처리 파이프 라인을 만드는 방법을 알 수 있습니다. 하지만 연산자를 사용하여 가능한 여러 파이프 라인을 전환하는 관용어를 볼 수 없습니다. 하나의 초기 입력 개체

0열

1답변

기준에 따라 이벤트를 분할하고 순서대로 처리하십시오.

다음과 같은 문제가 있습니다. partitionId 속성 (예 : 0-10)이있는 이벤트 목록이 있으면 수신 이벤트를 paritionId에 따라 분할해야합니다. 동일한 partitionId를 가진 이벤트는 수신 된 순서로 처리됩니다. 다소 균등하게 분배되면 병렬로 처리되는 10 개의 이벤트 (각 파티션에 대한 이벤트)가 발생합니다. 단일 스레드 디스패처를

1열

1답변

내장형 tomcat reactor가있는 stomp-chat 웹 소켓 error-type reactor.tuple.Tuple을 찾지 못했습니다.

Embedded Tomcat 서버에서 Spring을 사용하여 웹 소켓 구독이 제대로 작동하는 데 문제가 있습니다. 나는 다음과 같은 오류 받기 stomp-chat application 실행 : org.springframework.messaging.MessageHandlingException: Expression evaluation failed: @chatR

4열

1답변

봄 - 핫 출판 - 샘플 프로젝트가 여기에 있습니다 이벤트 스트림

에 MessageListener를 해소하기 위해 EmitterProcessor 사용 방법 : https://github.com/codependent/spring5-playground 나는 반응성에 JMS 대기열에서받은 메시지를 해소하고 싶습니다 메시지를 이벤트 스트림으로 게시하는 컨트롤러. 메시지를 수신하지 않고 구독자가없는 경우 나중에 서브 밴드가 전송

0열

1답변

어떻게하면 reactor-netty가 SSL을 사용하도록 구성 할 수 있습니까?

저는 Spring의 Project Reactor (https://projectreactor.io/)에 익숙해 지려고 노력하고 있으며 SSL을 통해 다른 서비스로 REST를 호출하기 위해 작은 애플리케이션을 만들었습니다. org.springframework.web.client.reactive.WebClient에서 SSL을 통한 요청을 구성 할 수있는 방법을

0열

1답변

반응기로 정적 컨텐츠 제공

원자로 서비스가 상태 정보와 함께 일부 정적 HTML을 노출하게하고 싶습니다. projectreactor.io가에 대한 반응 - 그물코를 사용하고 하나의 독립형 파일 제공을 위해 완벽하게 작동합니다 : html로 참조로, 다른 파일을 HttpServer http = HttpServer.create("0.0.0.0", 8100); http.directory

1열

1답변

다른 JVM 용 Spring-Reactor를 사용한 비동기 이벤트 구동 프로그래밍

EventBus를 사용하는 프로젝트 리액터를 사용하는 Spring 이벤트 기반 프로그래밍을 잘 알고 있습니다. 모든 구성 요소 (소비자 및 제작자)가 동일한 JVM에있는 경우 이벤트를 교환 할 수 있으며이 모델은 정상적으로 작동합니다. 다른 JVM에있는 경우이 Spring Event Driven 방식을 사용하여 구성 요소 간 통신이 가능합니까?

0열

1답변

Reactor 응답 또는 오류를 돌려주는 Eventbus 예제

먼저, 먼저 비동기 처리 도메인에 처음 들어 왔습니다. 현재 진행중인 프로젝트에서는 비동기 처리를 위해 프로젝트 원자로, 특히 Eventbus와 함께 스프링 부트를 사용합니다. eventbus의 사용 우리 시스템이보다 확장 성이 좋을 것 같아요. 지금까지 EventBus 소비자는 뭔가를 반환하지 않는 일부 처리를 할 때 EventBus의 사용이 상당히 제한

0열

1답변

Reactor의 Flux 직렬화

Reactor Flux를 직렬화 할 수 있습니다. 예를 들어 나의 플럭스는 어떤 상태에 있으며 현재 일부 이벤트를 처리 중입니다. 갑자기 서비스가 종료됩니다. Flux의 현재 상태는 데이터베이스 또는 파일에 저장됩니다. 그리고 나서 응용 프로그램을 재시작하면 해당 파일/테이블에서 모든 Flux를 가져 와서 마지막 상태에서 처리를 다시 시작하기 위해 구독합니

2열

1답변

원자로 취소 방법 구독 신청

나는 Reactor Project를 알아 내려고하고 구독을 취소 할 방법을 찾고 있습니다. 예를 들어 Flux를 구독하면 onCancel 신호를 보낼 때 사용할 수있는 Cancellation 개체에 대한 참조를 얻을 수 있지만 구독을 한 후에야 해당 컬렉션을 Collection에 보관해야합니다. Cancellation 개체를 가져 오는 더 좋은 방법이 있습