Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.
Info

RestAPI는 단순하고 작성하기 쉽습니다.

하지만 미들웨어 고성능통신 또는 미들웨어 분산 마이크로 서비스 구축시

RestAPI 로만은 분명 성능적한계,구현적 한계가 있습니다.

우리의 목표는 다양한 메시지 모델처리를 위해 n개의 서비스를 뛰우는것이 아닌

1개의 서비스로으로도 가능하고 , 필요하면 확장하는 전략을 선택할것입니다.

그것을 위해 앞으로 활용이될 메시지 전송모델 몇개를 간략하게 소개합니다.


RestFul

 일반적으로 웹서비스에 많이 사용하는 Rest방식입니다. 어떠한 웹브라우져또는 외부 고객에게

...

단순하게 초당 천개의 메시지를 전송하는 시나리오에서, 다수의 커넥션을 맺는데 모든 리소스를 다 사용할것입니다.


Rest vs Websocket 수행시간

 

Rest의 수행속도가 메시지가 증가함에 따라, 기울기가 급격해지는 성능저하를

...

일반적으로 API호출당 중앙DB SP를 꼭 한번 호출해야하는 경우이고

커넥션 비용보다 SP호출 비용이 더 크다고하면 이 부분은 프로토콜 변경문제로

해결할수가 없으며 추후 설명하게될 영속성있는 액터를통해 부분 해결가능합니다. 

단순하게 노드당 초당 1000개의 메시지를 처리해야되는 어떠한 내부기능이

필요하다고 했을때, Rest는 적당하지 않다는 의미입니다.


Server/Client VS PeerToPeer

Client/Sever방식은 Client가 중앙관리를 해주는 서버에 항상 연결을 유지하여 중앙 서버의 통제를받습니다.

...

메시지 처리 모델이며 AKKA의 목표는 이 사용을 단순화하는데 있습니다.

PUB/SUB

In this rails tutorial, publish-subscribe design pattern is laid out in this diagram.

아주 직관적이고 간단한 메시지전송 모델이기떄문에 여러 통신가능한 라이브러리 혹은 툴킷에서 많이 도입되었습니다.

...

Info

PUB/SUB 모델은 심플하기때문에, 직접 구현도 가능합니다.

아래는 TopicEventBus 라는 객체를 자바모델 참고하여 실제로 작성하고 사용해본 샘플입니다. (이개념을 쉽게 설명하기위해 직접 개발)



다양한 언어의 시청자가 존재하는 다국어 방송 메시지 모듈

Code Block
languagec#
themeEmacs
linenumberstrue
//Create Act Act System for Testing
ActorSystem system = TopicEventBus.inItSystem("TestTopic"); //ActorSystem Init
 
//Create user
TopicEventBus.CreateActor("A");
TopicEventBus.CreateActor("B");
TopicEventBus.CreateActor("C");
 
//A user wants to receive News A in English
TopicEventBus.Subscribe("A", "newsA", "en").Wait();
 
//User B wants to receive news A in Korean
TopicEventBus.Subscribe("B", "newsA", "kr").Wait();
 
//Users of c want to receive News B in English
TopicEventBus.Subscribe("C", "newsB", "en").Wait();
 
 
//Server real-time messages (server sprays news regardless of user)
TopicEventBus.Publish("newsA", "Hi...here news A", "en");
TopicEventBus.Publish("newsA", "여기에 새로운 뉴스가 있습니다.", "kr");
TopicEventBus.Publish("newsB", "Hi...here news B", "en");

Result:
create actor name:A
create actor name:B
create actor name:C
Subscribe actor name:A to newsA
Subscribe actor name:B to newsA
A FirstSet LangCode en from newsA
B FirstSet LangCode kr from newsA
Subscribe actor name:C to newsB
C FirstSet LangCode en from newsB
Publish Topic:newsA msg:Hi...here news A
Publish Topic:newsA msg:여기에 새로운 뉴스가 있습니다.
A가 뉴스를 받음 Hi...here news A from newsA
Publish Topic:newsB msg:Hi...here news B
C가 뉴스를 받음 Hi...here news B from newsB
B가 뉴스를 받음 여기에 새로운 뉴스가 있습니다. from newsA


저장소위치

http://git.webnori.com/projects/AKKA/repos/topiceventbus/browse


메시지 처리및 전송 최종목표

Info

우리의 최종목표는 응답이 좋은 메시지의 목표는 출발한 메시지 type상관없이 ( rest / websocket ) 출발하여

미들웨어에서 가장 효율적인 처리를 위해 어떠한 라우터및 클러스터 방식을 선택할것이며 ( client to server ,peertopeer , pubsub)

최종 중앙 Db의 호출을 최소화 하여 응답을 할것입니다.

...