akka

0열

1답변

폐쇄는 scala.concurrent.Future에 대한 루프에서 두 번째로 다음과 같은 <code>Future</code>을 만드는 두 번째를 호출

나는 두 가지 방법이 문제가 발생하고있어, 처음 예상대로 작동하지 : public class WorkersCoordinator { private static Logger LOGGER = LoggerFactory.getLogger(WorkersCoordinator.class); private final Timeout timeou

0열

1답변

Akka : getContext(). 대 응답 전송을위한 부모 대 getSender()

내 프로젝트에서 병렬 처리를 도입하고 내 응용 프로그램의 성능을 향상시키기 위해 Akka를 사용하기 시작했습니다. 이 점에 관해서는 GetSender() 메서드와 현재 액터의 부모 인 액터에게 다시 메시지를 보내야 할 때 getContext.parent() 메서드를 사용하는 것과 관련된 질문이 있습니다. 현재 처리되고있는 메세지 질문 내 프로그램의 컨텍스트

1열

2답변

여러 싱크

나는이 두 싱크와 같은 스트림을 가지고 있지만, 하나는 한 번에 사용됩니다 Source.fromElements(1, 2, 3) .via(flow) .runWith(sink1) 또는 Source.fromElements(1, 2, 3) .via(flow) .runWith(sink2) 그것은 구성 할 수 있습니다 우리가 사용하는 싱크 ,하지만 두

0열

1답변

AbstractLoggingActor는 File Appender에 쓰지 않지만 Java Akka의 콘솔에 글을 쓰고 있습니다.

AbstractLoggingActor를 확장하여 액터를 구현했습니다. 하지만 어쨌든 akka 로그는 콘솔에만 기록되고 로그 파일에는 기록되지 않으므로 오류가 발생하지 않습니다. 실제 akka 버전과 동일한 버전의 akka-slf4j를 사용하여 akka에서 다양한 구성을 시도했지만 도움이되지 않았습니다. 나는 처음에 사용했던 원래의 POM Configs를 붙

1열

1답변

Slick Streaming 데이터 변환 및 Akka Http를 사용한 청크 응답 전송

목표는 데이터베이스에서 데이터를 스트리밍하고이 데이터 청크에서 일부 계산을 수행 한 다음 (이 계산은 일부 사례 클래스의 미래를 반환 함)이 데이터를 청크 응답으로 전송하는 것입니다. 사용자에게 현재 데이터를 스트리밍하고 계산을 수행하지 않고 응답을 보낼 수 있습니다. 그러나이 계산을 수행하고 결과를 스트리밍 할 수 없습니다. 이것은 구현 한 경로입니다.

0열

2답변

Reactive와 Resilient의 차이점은 무엇입니까?

나는 Reactive와 Resilient의 차이점을 찾고 있습니다. 나는 몇 가지 기사를 읽었지만 그것들은 나에게 다소 분명하지만 외교적 설명과의 많은 혼란을 만든다. 나는 이 탄력 의미가 동일한 서비스의 인스턴스의 수가 증가하면 요청의 수가 증가 할 때이다 이해 무엇. 마찬가지로, 요청이 적 으면 줄어들 수도 있습니다. 따라서 인스턴스 수가 증가 또는 감

0열

1답변

원격 액터 만들기 프로그래밍 방식으로 작동하지 않습니다

프로그래밍 방식으로 원격 akka 액터를 만듭니다. package remoting.programatic.demo import akka.actor.{ActorSystem, Props} import com.typesafe.config.ConfigFactory import remoting.config.demo.RemoteActor object Remo

0열

1답변

문맥을 모방하는 방법 (ActorContext)?

나는 Ak34 배우를 테스트하기 위해 TestKit을 사용하고 있습니다. getActorRef 메서드를 가진 클래스 데모가 있는데,이 메서드는 문자열을 입력 받아 ActorRef를 반환합니다. class Demo @Inject()(a: A. b: B, context: ActorContext) { def getActorRef(id: String):

0열

3답변

2 바이트 구분 기호로 akka ByteString을 분할하는 방법

나는 내 자신의 WebSocket 프로토콜을 만들고 텍스트 키/값 헤더 부분을 가지며 2 개의 연속 된 개행과 2 진 꼬리가 끝나는 것으로 생각합니다. 밝혀졌습니다. ByteString을 두 줄로 나누는 것은 정말 지루합니다. 하나는 내장 된 .split 메소드가 없습니다. 그리고 이진 지문을 찾는 데는 .indexOf이 없습니다. 무엇을 사용 하시겠습니까

0열

1답변

는 Akka 다른 유형

내가 가지고있는 서로 다른 유형의 3 scala.concurrent.Future과 akka.dispatch.Futures.sequence 내부 통지를 받았습니다하기 위해 그들을 구성 할 필요가의 미래를 구성 선언 된 Iterable<Future<Object>>가 Iterable<Future<Object>> futureIterable = new ArrayLi