akka-stream

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를 사용하는 응용 프로그램을 작성하고 있습니다. 정기적으로 서비스를 쿼리하고 쿼리 (파일 다운로드 등)에 대한 응답으로 잠재적으로 다른 작업을 수행합니다. 인증 토큰은 일정 시간 후에 시간이 초과되므로 새로 고쳐야합니다. 인증 토큰은 어떻게 처리해야합니까? 그래

0열

1답변

Alpakka - 메시지 처리시 콜백

각 메시지가 JMS로 성공적으로 전송되거나 실패 할 경우 콜백을 수행하는 방법은 무엇입니까? val jmsSink = JmsSink.textSink( JmsSinkSettings(connectionFactory).withQueue("My_Queue") ) Source(Stream.from(1)) .map(_.toString) .

2열

1답변

Akka http-client는 서버의 모든 데이터 스트림을 사용할 수 없습니다.

이 스트림을 소비하는 간단한 akka 스트림 나머지 엔드 포인트 및 클라이언트를 작성하려고합니다. 하지만 서버와 클라이언트를 실행하려고하면 클라이언트는 스트림의 일부만을 소비 할 수 있습니다. 실행 중에 예외가 표시되지 않습니다. import akka.NotUsed import akka.actor.ActorSystem import akka.http.sc

0열

2답변

Akka-http : localhost의 websocket에 연결

localhost의 websocket을 통해 일부 서버에 연결하려고합니다. 내가 JS에서 그것을하려고 할 때 ws = new WebSocket('ws://localhost:8137'); 그것은 성공한다. 그러나 akka-http 및 akka-streams을 사용하면 "연결에 실패했습니다"라는 오류가 발생합니다. object Transmitter {

1열

1답변

Akka Streams Alpakka jms의 KickSwitch

alpakka를 사용하여 여러 jmsSource (다른 대기열에 대해)를 시작하는 시나리오가 있습니다. 또한 어느 시점에서든 대기열을 분리해야합니다. 그래서 아래와 같이 jms akka 스트림에 KillSwitch를 추가했습니다. - .. 등등. 응용 프로그램을 시작한 후에 모든 대기열이 연결되어 정상적으로 작동합니다. 그러나 stop 메소드를 사용하여 큐

1열

2답변

여러 싱크

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

1열

1답변

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

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