액터가 akka에 생성되지 않은 경우 다른 액터에게 메시지를 전달하는 방법

Question

액터를 사용하여 websocket을 통해 클라이언트에 메시지를 보냅니다. 따라서 연결된 각 클라이언트는 자체 액터를 얻습니다. 비즈니스 논리는 단순히 actorSystem.actorSelection(s"/user/connections/UserQueues-${userId}") ! Message(content)입니다. 특정 유형의 메시지의 경우 클라이언트가 연결되어 있지 않은 경우 메시지를 유지하고 클라이언트가 연결될 때 메시지를 다시 전달해야합니다. 전달되지 않은 메시지를 기억할 메시지를 배우에게 라우팅하는 가장 좋은 방법은 무엇입니까? 이것은 사용자가 아직 연결되어 있지 않고 "/ user/connections/UserQueues - $ {userId}"경로의 액터가 계층 구조에없는 경우에 발생합니다.

Answer 1

websocket 액터를 제어한다면이 메시지를받는 ACK를 만들 수 있습니다. 그리고 ACK가 없으면 몇 번이고 다시 전송할 것입니다. Akka는 akka-persistence의 AtLeastOnceDelivery에서 이것을 지원하고 있습니다. 사용 방법은 AtLeastOnceDelivery example in docs입니다.

긴 이야기를 짧게, 당신은 deliver(destination, deliveryId => Msg(deliveryId, s))-!를 사용하여 전환 한 후이 메시지가 전달되었는지 확인하는 방법을 찾을 필요 (보낸 사람에게 다시 확인을 보낸 다음 그 안에 confirmDelivery 전화).

희망이 도움이됩니다.