akka

1열

1답변

Akka에서 메시지가 액터 풀로 보내지면 'self'는 액터 인스턴스 또는 전체 풀에 대한 참조를 보유합니까?

Actor가 해당 메시지를 받으면 self에게 메시지를 보내는 Actor 풀에 메시지를 보내는 경우의 동작은 무엇입니까? 이 경우 self에게 메시지를 보내거나 메시지를 보낸 특정 액터 인스턴스로 메시지를 보내려고합니까? 이 시나리오의 의사 코드는 항상 가리키는 다음 ... val system: ActorSystem = ActorSystem() val

1열

2답변

범위를 벗어난 액터에 액세스하는 액터

저는 Akka 라이브러리를 사용하고 있습니다. 여러 액터가 객체에서 함수를 호출하면 어떻게됩니까? 다른 액터가 객체에 액세스하는 것을 차단합니까? 내가 이것을 묻는 이유는 akka 배우와 함께 JBCrypt를 사용하기 때문입니다. 그리고 우리는 여러 문자열을 동시에 암호화 할 수 있기 때문에 JBcrypt.hash (...)를 호출하는 각 액터가 있습니다.

0열

1답변

은 괜찮 내가있는 3 노드 클러스터를 가지고있는 파편 또는 proxyShard

를 호스팅하지 않는 종자 노드를 만드는 것입니다 1 S1 - 씨 노드 2 S2 - S1가있는 샤드 SRD를 (호스팅하는 노드 S1 단지 actorsystem을 만들고 여기 구성에서 시드 노드)로 S1을 가지고 S2 (호스팅 샤드의 프록시 샤드 호스트, 아무것도 을하는 노드 - 3 S3 구성에서 시드 노드)로서 클러스터를 시작할 때 (S1 먼저, S2와 S3

0열

1답변

일부 초기 표시로 대기열 제공

일부 초기 지연 후 10 초라고 말하면로드 요청에서 전송 된 문자열을 대기열에 넣으 려합니다. 짧은 간격 지연 (1 초)으로 다음 요청을하면 모든 것이 정상적으로 작동하지만 스크립트 에서처럼 계속 실행하면 지연이 없습니다. 다음은 샘플 코드입니다. def load(randomStr :String) = Action { implicit request =>

0열

1답변

Akka 스트림이 외부 세계에서 무한한 스트림의 현재 가치를 값을 집계 결코 완전한 정의에 의해 무한 스트림의 현재 값을 얻을 수있는 가장 좋은 방법은 무엇

Source.repeat(1) .scan(0)(_+_) .to(Sink.ignore) 전에서 조회하고자하는 Akka HTTP는 현재 카운터 값입니다. 동적 스트림을 사용해야합니까? broadcastHub와 Akka http에서 GET 요청에 대한 무한 스트림을 구독합니까?

1열

1답변

어떻게 <a href="https://doc.akka.io/docs/akka-http/current/scala/http/client-side/host-level.html" rel="nofollow noreferrer">host-level API with a queue</a>을 사용하고 Source.Queue 배압

를 사용합니다. private val (queueSource, connectionPool) = Source.queue[(HttpRequest, Promise[HttpResponse])](queueSize, OverflowStrategy.backpressure).async .viaMat(poolFlow)(Keep.both) .toMat(

3열

1답변

Akka Distributed Pub/Sub 백 프레셔

저는 Akka Distributed Pub/Sub를 사용하고 있으며 발행인과 가입자가 하나입니다. 내 발행인은 구독자보다 훨씬 빠릅니다. 특정 시점 이후에 게시자의 속도를 늦출 수있는 방법이 있습니까? 게시자 코드 : public class Publisher extends AbstractActor { private ActorRef mediator;

0열

1답변

클라이언트 응용 프로그램에 대해 akka-streams 및 akka-http를 사용하여 인증을 처리하는 방법

인증 된 웹 서비스 (인증 토큰 반환)에 연결해야하는 Akka Streams 및 Akka Http를 사용하는 응용 프로그램을 작성하고 있습니다. 정기적으로 서비스를 쿼리하고 쿼리 (파일 다운로드 등)에 대한 응답으로 잠재적으로 다른 작업을 수행합니다. 인증 토큰은 일정 시간 후에 시간이 초과되므로 새로 고쳐야합니다. 인증 토큰은 어떻게 처리해야합니까? 그래

1열

2답변

akka의 TestKit에서 스칼라를 사용하여 태그를 지정하는 방법은 무엇입니까?

특정 시나리오에서 특정 테스트를 실행하기 위해 태그를 지정하고 싶습니다. (예를 들어, slow 만 빌드하는 동안 실행, 아직 반면 개발해야한다고.) 스칼라에서 을 ScalaTest의 FlatSpec를 사용하여 나는 taggedAs 및 scalatest의 Tag을 사용할 수 있습니다 알고 있습니다. 그러나 액터 테스트에서 같은 것을 달성하는 방법을 모르겠습

0열

2답변

IntelliJ Mac OS에서 오른쪽 화살표 (예 : ⇒, not =>)를 입력하는 방법은 무엇입니까?

스칼라 패턴 매칭에 사용되는 일반적인 기호는 오른쪽 화살표, ⇒ 또는 =>입니다. 그래서 내 질문은 ⇒ 오른쪽 화살표를보고 깔끔하게 입력하는 바로 가기가 무엇입니까? Mac OS에서 IntelliJ를 사용합니다. 아래이 기호를 사용 https://doc.akka.io/docs/akka/current/guide/tutorial_1.html package co