Page History
...
구현 단순화를 위해서 RestAPI로 전환할수도 있지만, 안정적으로 대량의 데이터를 고성능으로 전송하기에는 무리가 있습니다.
구현코드의 난이도를 올리지 않고 연결지향적이면서도 고성능통신을 할수 있는방법중 하나가
TCP 피어투피어방식을 사용하는 RemoteActor입니다.
구현코드는 간단해지고, 일반적인 일반적으로 재접속 처리 문제를 신경쓸필요가 없습니다. ( 연결복구기능이 기본 탑재되며, 필요하면 장애시 재전송룰 적용가능)
...
- A1,A3에 일어난일을 A2에게 모두보고하여 로그를 집합할수 있습니다.
- B1에서 일어난 일을 A2에게 보고하고 DB형님이 안바쁠때 변경사항을 알려줄수 있습니다.(A2만 DB제어를 한다고 가정하고 DB 호출량제어가능)
- 이미 존재하는 미들웨어에서 쌍반간 통신의 길을 뚫어줌으로, 관리요소추가(MQ시스템)없이 스스로 연락을 할수 있습니다.
- 라운드로빈/브로드캐스트등 특수한 라우티이용도가능하며, 클러스터화 전환도 용이합니다. ( 보너스 기능).
- 메시지기반으로 설계된 것은, RabbitMQ및 카프카와같은 외부 MQ 시스템과도 연동이 수월해집니다.
그럼 구현체가 얼마나 간단해졌는지 살펴보겠습니다.
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
public class TestActor extends UntypedActor {
private final LoggingAdapter log = Logging
.getLogger(getContext().system(), "TestActor");
@Override
public void onReceive(Object message) throws Exception {
if(message instanceof String) { //String뿐만 아니라 모든 Java객체 통신가능
log.info("Incommessage {}", message);
sender().tell("너의 메시지에 응답을함", ActorRef.noSender());
}else {
log.info("Unhandle Message {}", message);
}
}
}
//service1 이름으로 액터의 엔드포인트를 생성했습니다.
ActorRef testActor = system.actorOf(ext.props("testActor"),"service1"); //Service1이란 이름으로 TestActor를 생성함
|
...
- JAVA8-비동기처리 : https://doc.akka.io/docs/akka/2.5/futures.html#java-8-completionstage-and-completablefuture
- 리모트 액터 : https://doc.akka.io/docs/akka/2.5/remoting.html
- 고성능 직렬화 선택가능(설정없으면 기본으로 해줌) : https://doc.akka.io/docs/akka/2.5/serialization.html
...
| Note |
|---|
원격메시지에대한 안정적인 공급/소비 문제를 해결하기위한 좋은 툴로 Kafka가 등장하였고 범용적으로 사용되고 있습니다. 하지만 모든 실시간 메시지를 중앙에서 분산관리하느냐? 로컬적인 메시지를 자기들끼리 알아서 처리하게하느냐? 목적성에 따라 장단점이 있는부분입니다. 리모트 액터로 Kafka와 같은 역활을 모두 대체시키는것은 권장되지 않으며, 모든 실시간 메시지를 Kafka를 통해서 하는것도 올바른 설계방법이 아닙니다. 액터로 설계된것은 Kafka와도 완벽하게 상호연동이 되기때문에 목적성에 맞게 잘구분하여 사용할 필요가 있습니다. 아래와 같은 차이가 있으며, RemoteActor와 Kafka 전송 난이도는 큰차이가 없으며 이기종통신일때 Kafka가 이점이 있으며, 같은 기종 Java객체 전달할때 RemoteActor가 조금더 설계의 이점이 있습니다. 실시간 메시지전송기는 추상화정도및 내장화가 되었냐에 따라 3가지로 구분이 가능합니다.
|
...