일부 데이터 분석을 처리 할 수있는 GCE 서버 설정이 있습니다. 나는 twisted을 사용하여 ws을 통해 그것과 통신 할 수있다. 나는이 서버의 유일한 클라이언트이다. 이 클라이언트의 연결을 처리하기 때문에 내가 시스템을 정지하기 위해 노력하고있어 및 클라이언트가 연결되어 spawn_multiprocessing_hierarchy()
reactor.ru
ws 프로토콜을 통해 내 서버에 지속적으로 연결해야하는 일련의 클라이언트가 있습니다. 여러 가지 이유로 인해 때때로 연결이 끊어집니다. 이것은 받아 들일 만하지만, 내 고객이 다시 연결되기를 바랍니다. 현재 임시 해결 방법은 부모 프로세스가 클라이언트를 시작하도록하고 클라이언트가 연결 끊기를 감지하면 종료합니다 (클라이언트는 중요한 데이터를 처리하지 않으며
을 함수를 호출 있지만이 문제 만 경험 : ws 교환 처음 몇 메시지를 통해 서버에 그들은 제대로 connectTCP. 다음과 같이 약 1 분, 그들은 정의 def execute(self, message, callback=None):
print(">>>", message, flush=True)
reactor.callFromThread(se
I가 나의 봄 부팅 응용 프로그램에서 다음과 같은 구성 : 나는 그것을 실행할 때 CPU 사용량이 100 %에 도달 @Configuration
@EnableAsync
@Slf4j
public class AsyncConfig {
private static final int BUFFER = 1024;
@Bean
public A
observer publish-subscribe 패턴을 구현하는 .NET 라이브러리의 클래스 이름은 무엇입니까? 나는 이 reactor pattern으로 구현되었고 observer and reactor pattern 사이에 차이가 있음을 이해합니다. 답을 선택한 후 업데이트 : 이 문제는 닫을 3 표를 받았다. 나는이 질문에 대한 답이 없기 때문에 그 이유
Java에서 CompletableFuture를 사용할 때 문제가 있습니다. 서버에서 응답을받을 때 채워지는 2 개의 선택 요청이 있습니다. if(hasException) {
selectFuture.completeExceptionally(new ClientException(errorCode));
} else {
System.out.prin
Spring 어플리케이션에서 반응기로 보낸 메시지가 손실 된 것 같습니다. 나는 이것이 메시지를 생성하기 시작한 Spring 컨테이너의 라이프 사이클 시간 때문이라고 생각한다. 나의 특별한 경우에는 시작할 때 약간의 초기화를 수행하는 스프링 빈 (Spring Bean)이있다. 이 초기화의 일부는 원자로로 보내지는 메시지를 생성하는 것과 관련이 있습니다. 스
작은 반응기 샘플을 here에서 바꾸려고했는데 약간의 행동으로 혼란 스럽습니다. 이 같은 그래서 처음 엔 코드 : EmitterProcessor<String> stream = EmitterProcessor.<String>create().connect();
Flux<String> flux = stream
.doOnNext(s -> Sys
Reactor Pattern을 적용한 Java NIO를 사용하는 간단한 서버 클라이언트 애플리케이션을 작성하고 있습니다. 내 이해에 Reactor 클래스는 Events (예 : OP_ACCEPT, OP_READ, OP_WRITE)을 수집해야합니다. 상대적인 EventHandler은 특정 작업을 담당하므로 처리기가 별도의 스레드에서 비동기 적으로 실행되어야한