是否可以處理來自單個參與者的多種訊息型別。
例如,假設有一個叫做TradingStrategy交易股票的演員。它接收從另一個 Actor 輸入的定價資料。當它決定進行交易時,它會向另一個 Actor(稱為它OrderActor)發送訊息以進行交易。但是TradingStrategyActor 有興趣知道下訂單是成功還是被拒絕等......因為它可能會根據下訂單操作的結果改變其策略。在這個例子中,似乎TradingStrategy需要處理定價更新和訂單更新的訊息。這可以用 Akka 打字嗎?有沒有辦法處理這種情況?
這是一個代碼示例:
IEXData是資料訊息。
def apply(orderActor: ActorRef[OrderCommand]): Behavior[IEXData] = Behaviors.setup { context =>
new SimpleTradingStrategy(context, brokerActor)
}
}
class SimpleTradingStrategy(
context: ActorContext[IEXData],
orderActor: ActorRef[OrderCommand],
ticker: Ticker = "spy"
) extends AbstractBehavior[IEXData](context) {
uj5u.com熱心網友回復:
TradingStrategy的協議必須包含指示訂單更新的訊息。參與者TradingStrategy可以注冊一個訊息配接器,它將訂單參與者發送的訊息轉換為TradingStrategy的協議:TradingStrategy可以將訊息配接器回傳的“虛擬”呈現ActorRef給訂單參與者,而訂單參與者不知道它是 a TradingStrategy。
轉載請註明出處,本文鏈接:https://www.uj5u.com/ruanti/453090.html
