在学习中介者模式时,我遇到了大众运输。虽然我对理论有足够的理解(我希望),但我很难找到支持以下场景的代码示例/文档:
假设有CustomerService(A)和NotificationService(B)。
在A上引发的一些事件将被它自己独占使用,而A引发的一些事件也将被B使用
在第一个场景中,假设引发了一个CustomerUpgradedEvent,这将在第一个服务中内部处理。这就是我所说的域事件和NewCustomerCreatedEvent,它也将由NotificationService(发送电子邮件等)处理,我称之为集成事件。
这就是我的问题。我应该配置MassTransit使用rabbitMq(或任何其他内存不足的总线)的第一种事件?这似乎是一个矫枉过正,并可能引入延迟/不必要的问题(如果连接到队列死亡?我知道MassTransit有措施来减轻这一点,但仍然)
我可以同时使用内存和rabbitmq配置MT,并进行目标调度吗?
1条答案
按热度按时间polhcujo1#
MassTransit的Mediator可以与基于运输的公共汽车一起使用。
使用
IScopedMediator
或IMediator
将立即发送消息,而通过IPublishEndpoint
或ISendEndpointProvider
生成的消息将通过RabbitMQ(或任何配置的传输)发送。