如何使用 JournaledGrain 进行事件溯源

Question

我是奥尔良女士的初学者。我想使用JournaledGrain 向其侦听器发送事件。这是我尝试过的。

public class MyJournaledGrain : JournaledGrain<State, Event>, IJournaledGrain
{
    public MyJournaledGrain()
    {

    }
    public void RaiseEvent()
    {
        Trace.WriteLine(" hi ");
        this.RaiseEvent(new Event());
        this.ConfirmEvents();
    }

    protected override void OnStateChanged()
    {
        // some thing ...
        base.OnStateChanged();
    }
    protected override void TransitionState(State state, Event @event)
    {
        base.TransitionState(state, @event);
    }
}

在 OnStateChanged 方法中，我可以得到引发的事件，但发送方和接收方在一个类中。我想要一些类似发布/订阅模式的东西。有可能通过奥尔良女士实现这一目标吗？谢谢

Answer 1

事件

溯源和发布/订阅是两个独立的东西：

• 事件溯源用于粒度的状态持久性
• 发布/订阅用于颗粒之间的消息传递

对于发布/订阅，你需要新奥尔良流：https://dotnet.github.io/orleans/Documentation/streaming/index.html