我有以下設置：HTTP 請求到達 REST 端點，我在我的應用程序服務中收到它。應用程序服務將請求映射到命令 C1 并將其轉發到使用commandGateway.sendAndWait(new C1(restPostBody));.從 repo 加載聚合，應用新命令并生成新事件并保存到存儲。此時，我需要豐富此事件并將其用作 REST 調用的響應。到目前為止，我可以看到以下選項：使用視圖投影儀，并投影新事件以創建可以在 REST 調用中作為響應轉發的視圖模型。我在這里我需要使用queryGateway.subscriptionQuery(...并sqr.updates().blockFirst()等待投影儀處理事件，然后創建響應。另外，我想這應該是同步的，因為如果系統在將事件存儲到數據庫和將投影存儲到數據庫之間失敗，投影可能會不同步？在從聚合發布事件后使用一些事件豐富器并向其添加所需的屬性并添加對 REST 調用的響應。這類似于 Projection，但在這種情況下，我不會將其保存到 DB，因為我需要數據的唯一時間是在發出命令時對 REST 端點的響應。這絕對應該是同步的，因為如果出現故障，我會失去響應。在異步的情況下 - 我需要讓 Aggregate 處理重復事件，并且仍然向事件豐富器發出事件但不存儲到數據庫。這似乎使事情變得復雜了很多。是否有與此相關的最佳實踐？
1 回答
LEATH
TA貢獻1936條經驗 獲得超7個贊
所以，@ bojanv55，你試圖欺騙你的應用程序是一個同步設置，而 Axon 框架的命令事件查詢方法強制你走另一條路。
理想情況下，您的前端應該符合這種情況。因此，如果您到達發布命令的端點，那么您就會大火而忘記。更新查詢模型的事件將在發生時作為更新推送到前端。所以很快，接受它是異步的事實應該最終會讓一切感覺更加無縫。
然而，說起來容易做起來難；你問這個問題當然是有原因的。我個人喜歡使用訂閱查詢（您也指向它）來欺騙操作以實現同步。
我認為 Frans 的這個存儲庫很好地展示了如何使用 Axon Framework 做到這一點。
他所做的是處理 REST 操作并首先為您知道很快會更新的內容發送訂閱查詢。其次，命令被調度到聚合，聚合做出發布事件的決定，事件更新查詢模型。然后，查詢模型更新構成向您的訂閱查詢發出的更新，允許您僅在查詢模型實際調整后才返回結果。
最后，我總是建議我的第一個建議是接受您所處的異步情況。其次，我認為我剛剛分享的訂閱查詢解決方案也可以解決您遇到的問題。
希望這可以幫助你！
添加回答
舉報
0/150
提交
取消