在 Go 中,处理分布式事务的方法有两种:协调器模式:使用协调器服务记录事务状态,决定提交或回滚事务。优点:简单易用,单点故障风险。Saga 模式:将事务分解成局部事务,在局部事务失败后执行逆向事务。优点:无单点故障,但实现更复杂。
如何使用 Go 框架处理分布式事务
分布式事务是需要同时更新多个数据的处理。在 Go 中,我们可以使用协调器模式或 saga 模式来处理分布式事务。
协调器模式
Saga 模式
实战案例
使用协调器模式创建订单
type OrderService interface { CreateOrder(order *Order) error } type OrderServiceImpl struct { coord Client } func (s *OrderServiceImpl) CreateOrder(order *Order) error { // 创建事务 tx, err := s.coord.Begin() if err != nil { return err } defer tx.Close() // 更新库存 err = orderDao.UpdateStock(tx, order.ProductID, order.Quantity) if err != nil { return err } // 创建订单 err = orderDao.CreateOrder(tx, order) if err != nil { return err } // 提交事务 if err = tx.Commit(); err != nil { return err } return nil }
使用 Saga 模式创建订单
type OrderService interface { CreateOrder(order *Order) error } type OrderServiceImpl struct { product svc.ProductService order svc.OrderService } func (s *OrderServiceImpl) CreateOrder(order *Order) error { // 分解事务为局部事务 txCreateOrder := func() error { return orderDao.CreateOrder(order) } txRollbackOrder := func() error { return orderDao.DeleteOrder(order.ID) } txReserveStock := func() error { return productDao.ReserveStock(order.ProductID, order.Quantity) } txReleaseStock := func() error { return productDao.ReleaseStock(order.ProductID, order.Quantity) } // 创建 Saga 协调器 saga := saga.NewSaga(txCreateOrder, txReserveStock).WithRecovery(txRollbackOrder, txReleaseStock) // 执行 Saga 事务 err := saga.Execute() if err != nil { return err } return nil }