Spring 어플리케이션에서 반응기로 보낸 메시지가 손실 된 것 같습니다. 나는 이것이 메시지를 생성하기 시작한 Spring 컨테이너의 라이프 사이클 시간 때문이라고 생각한다. 나의 특별한 경우에는 시작할 때 약간의 초기화를 수행하는 스프링 빈 (Spring Bean)이있다. 이 초기화의 일부는 원자로로 보내지는 메시지를 생성하는 것과 관련이 있습니다. 스
이 질문은 Reactive Spring Controller에서 데이터를 스트리밍하는 방법에 대해 묻는 this one과 관련이 있습니다. 로젠 (Rossen)은 서버가 보낸 이벤트로 스트리밍 된 결과를 보내려면 text/event-stream을 사용해야한다고 지적 했으므로 지금까지는 좋았습니다. 나는이 같은 서비스가 있습니다 @GetMapping(value
Reactor 2.0.0.M1을 사용 중이며 Stream을 필터링하려고합니다. 부울 연산의 결과에 따라 하나 또는 다른 스트림을 계속 사용하려고합니다. 이 기능은 otherwise() 기능으로는 가능하지만 사용법은 명확하지 않습니다. stream.filter(o -> o.isValid());
o.isValid() 사실입니다 경우를 처리하기 위해, 나의
다음 프로젝트에 Akka 또는 Reactor를 사용해야하는지 여부를 알아 내려고합니다. 가장 중요한 질문 중 하나는 미래의 선택 틀이 리모팅을 제공하는지 여부입니다. 내가 보았 듯이, Akka는 이것을 우리가 가지고있는 방식으로 제공합니다. GitHub 위키에서 불행히도 TCP 서버/클라이언트 섹션은 비어 있으며 아직 그것에 대한 다른 정보를 찾을 수 없습
시동은 스프링 반응기를 가동하기위한 전제 조건입니까? 일반 웹 응용 프로그램 환경에서 스프링 리액터를 사용하려고합니다. 원자로 구성이 생성 된 것을 볼 수 있습니다. 소비자가 등록됩니다. 알림이 호출됩니다. 이벤트는 해고되지 않습니다. 무엇을 어떻게 점검 할 것인가? 구성 @Configuration
@EnableReactor
public
새 프로젝트 (Java 기반)를 시작하는 중입니다. 모듈 형, 분산 및 복원력있는 아키텍처로 구축해야합니다. 따라서 비즈니스 프로세스간에 상호 통신이 가능하고 상호 운용 가능하지만 독립적이어야합니다. 나는 시대에 자신의 차이 외에 2 개 개의 다른 의견 표현이,이 프레임 워크에서 지금 당장 찾고 있어요 : Akka (http://akka.io) 반응기 (h
Project Reactor로 실행되는 백그라운드 작업이 있는데, @PreAuthorize를 통과하기 위해 인증 된 사용자와 함께 실행해야하는 관련 작업이 있습니다. 주석이 달린 메소드. 나는이 같은 일을 해요 : Authentication authentication = authenticationManager.authenticate(new UsernameP