3
내 스칼라 응용 프로그램에서 메시지 버스를 구현하려고합니다. 특징은 다음과 같습니다액터의 스칼라 메시지 버스 구현?
- 능력이 1에 가입 .. 메시지의 N 유형
- 메시지
- 느슨한 결합 (노드에만 버스에 대한 참조를 보유) 페이로드를 가질 수있다
- 경량 (NO 완전히 날려 버린 엔터프라이즈 메시지 대기열 등)
나는 모든 노드와 버스 자체를 표준 스칼라 액터로 구현할 계획입니다. 예를 들어 나는이 같은 특성 Subscriber
를 정의하려면 : 이상적으로 이미 유형 M
에 대한 구독을 등록해야이 특성에 혼합
trait Subscriber[M <: Message[_]] {
this: Actor =>
def notify(message: M)
}
.
이 아이디어는 의미가 있습니까? 메시지 버스를 실현하는 더 좋은 방법이 있습니까?
나는 네가 "네가 배우의 사용법으로 버스 같은 시스템을 실현할 수있다"고 대답했다. 나는 아마도 내 자신의 구현을 할 것이지만 Akka가 제공 할 수있는 것을 조사하는 데 시간을 투자 할 것입니다. 고맙습니다! – aeisele