如何在一个事务中将内容存储到数据库并将消息发布到总线？

编程问答 2022-05-01

问题描述

我阅读了很多关于微服务或有界上下文之间的事件驱动消息传递以共享状态或对事件做出反应的博客和书籍。大多数示例实现了类似以下代码段的命令处理程序。这实际上是《Patterns,Principles,and Practices of Domain-Driven Design》一书中的一个简化片段。

public void Handle(PlaceOrder message)
{
    var orderId = Database.SaveOrder(
        message.ProductIds,message.UserId,message.ShippingTypeId
    );
    // what if something goes wrong here?
    var orderCreatedEvent = new OrderCreated
    {
        OrderId = orderId,UserId = message.UserId,ProductIds = message.ProductIds,ShippingTypeId = message.ShippingTypeId,TimeStamp = DateTime.Now,Amount = CalculateCostOf(message.ProductIds)
    };
    Bus.Publish(orderCreatedEvent);
}

该片段似乎不完整，因为在不发送消息的情况下存储订单可能会成功。我知道我可以使用 transaction outbox pattern，这会增加在表中存储消息的额外成本，并让工作人员定期检查表并发送错过的消息。另一种方法是使用事件溯源，但这似乎只是为了解决可靠消息传递的问题。所以我想知道是否有替代方案，例如在总线和数据库上一起工作的事务？或者 Database.SaveOrder() 应该以某种方式是幂等的，以便我可以始终重复整个过程？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

c#c#idempotentmessagingmessagingservicebusservicebustransactions