Akka Actor Throttle

Akka Actor Throttle

Akka가 2.5 버전이 되면서 TimerBasedThrottler은 더 이상 사용되지 않고, Stream의 Throttle를 기능을 이용하여 구현을 할수 있다.

Source Code

import java.util.concurrent.TimeUnit;
import scala.concurrent.duration.FiniteDuration;
import akka.NotUsed;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.stream.ActorMaterializer;
import akka.stream.Materializer;
import akka.stream.OverflowStrategy;
import akka.stream.ThrottleMode;
import akka.stream.javadsl.Sink;
import akka.stream.javadsl.Source;
 
final ActorSystem system = null; // TODO 실제 ActorSystem 
final ActorRef target = null; // TODO 타겟 ActorRef 
final Materializer materializer = ActorMaterializer.create(system);
 
final ActorRef throttler =
  Source.actorRef(1000, OverflowStrategy.dropNew())
    .throttle(100,  FiniteDuration.create(1, TimeUnit.SECONDS), 10, ThrottleMode.shaping())
    .to(Sink.actorRef(target, NotUsed.getInstance()))
    .run(materializer);

활용 방법

• 데이터 Reader의 속도 제한
• 분당 API 호출 제한