Page History
...
Code Block | ||||
---|---|---|---|---|
| ||||
package com.psmon.cachedb; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.ApplicationContext; import com.psmon.cachedb.extension.SpringExtension; import akka.actor.ActorRef; import akka.actor.ActorSystem; import akka.event.Logging; import akka.event.LoggingAdapter; @SpringBootApplication public class CachedbApplication { public static void main(String[] args) { ApplicationContext context = SpringApplication.run(CachedbApplication.class, args); ActorSystem system = context.getBean(ActorSystem.class); final LoggingAdapter log = Logging.getLogger(system, "Application"); log.info("Starting up"); SpringExtension ext = context.getBean(SpringExtension.class); ActorRef testActor = system.actorOf(ext.props("testActor")); testActor.tell("ready spring boot",null); } } |
Info | |||||||
---|---|---|---|---|---|---|---|
이건 보너스코드다. 100개의 메시지가 한꺼번에 들어왔다고 가정해보자.... API가 되었건, DB가 되었건 ...보통 동시간에 100개의 요청이 히트가 되어 불안정을 요소한다고 하면 초당 개수 처리제한 및 특정개수가 넘을시 무시조건등 을 기존설계된 액터에 연결을 시킬수가 있다. AkkaStrem의 밸브조절기능은 아주 유용하며 액터와 상호연동이 쉽게 가능해집니다. |
주요코드
스프링 Context를 가지고 올수 있는곳 어느곳이나 AKKA사용을 위한 ActorSystem을 획득할수 있습니다.
...