CQRSLite 和 MassTransit 集成

Question

我目前正在使用CQRSLite 框架并且很好奇如何将MassTransit 用作总线实现。

我目前遇到的问题是，如何在 MassTransit 端正确注册消费者，以便将消息（命令和事件）路由到这样的处理程序

public class InventoryCommandHandlers : ICommandHandler<CreateInventoryItem>
{
    public void Handle(CreateInventoryItem message)
    {
        // do some job...
    }
}

public class InventoryListView : IEventHandler<InventoryItemCreated>
{
    public void Handle(InventoryItemCreated message)
    {
        // do some job...
    }
}

Answer 1

你总是可以实现两个接口：

public class InventoryCommandHandlers : 
    ICommandHandler<CreateInventoryItem>,
    IConsumer<CreateInventoryItem>
{
    public void Handle(CreateInventoryItem message)
    {
        // do some job...
    }

    public Task Consume(CreateInventoryItem message)
    {
        Handle(message);
        return Task.FromResult(true);
    }
}

public class InventoryListView : 
     IEventHandler<InventoryItemCreated>,
     IConsumer<InventoryItemCreated>
{
    public void Handle(InventoryItemCreated message)
    {
        // do some job...
    }

    public Task Consume(InventoryItemCreated message)
    {
        Handle(message);
        return Task.FromResult(true);
    }
}

然而 CQRSLite 似乎是为进程内使用而设计的，在分布式上下文中使用它并没有真正看到任何好处。

我强烈建议您查看原始的 m-r 存储库并实现您自己的基础库，只需 1/2 天，您就会更好地了解它的工作原理。

您还可以查看AggregateSource 和Projac 以获得一些灵感，甚至可以使用它们，这些都是很好的例子。