如何解决如何在一个事务中将内容存储到数据库并将消息发布到总线?
我阅读了很多关于微服务或有界上下文之间的事件驱动消息传递以共享状态或对事件做出反应的博客和书籍。大多数示例实现了类似以下代码段的命令处理程序。这实际上是《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 举报,一经查实,本站将立刻删除。