2010-12-09 5 views
3

내 스칼라 응용 프로그램에서 메시지 버스를 구현하려고합니다. 특징은 다음과 같습니다액터의 스칼라 메시지 버스 구현?

  • 능력이 1에 가입 .. 메시지의 N 유형
  • 메시지
  • 느슨한 결합 (노드에만 버스에 대한 참조를 보유) 페이로드를 가질 수있다
  • 경량 (NO 완전히 날려 버린 엔터프라이즈 메시지 대기열 등)

나는 모든 노드와 버스 자체를 표준 스칼라 액터로 구현할 계획입니다. 예를 들어 나는이 같은 특성 Subscriber를 정의하려면 : 이상적으로 이미 유형 M에 대한 구독을 등록해야이 특성에 혼합

trait Subscriber[M <: Message[_]] { 
    this: Actor => 
    def notify(message: M) 
} 

.

이 아이디어는 의미가 있습니까? 메시지 버스를 실현하는 더 좋은 방법이 있습니까?

답변

4

면책 조항 : 나는 Akka의 PO입니다

안녕 Itti,

이 이미 Akka에 당신을 위해 수행되었습니다

, 액터 커널 : www.akka.io

문서 : http://doc.akkasource.org/routing-scala

펍/하위 : Akka Listeners 라우터 : Akka Routers 편의점 : Akka Routing

+0

나는 네가 "네가 배우의 사용법으로 버스 같은 시스템을 실현할 수있다"고 대답했다. 나는 아마도 내 자신의 구현을 할 것이지만 Akka가 제공 할 수있는 것을 조사하는 데 시간을 투자 할 것입니다. 고맙습니다! – aeisele

관련 문제