Go 微服务：高级架构与实践

轻松学习Python，无需理论负担。在浏览器中直接解决带自动检查的实践任务，无需安装任何东西。

Go 微服务：高级架构与实践

从单体架构向微服务架构的迁移，是许多高负载系统演进的必经阶段。Go 语言（Golang）凭借其高性能、内置并发支持和轻量级运行时，已成为该领域的领导者之一。本文将探讨构建 Go 微服务的高级架构模式和实践技巧，帮助您创建可靠、可扩展且容错性强的系统。

1. 架构模式：Go 中的 CQRS 与事件溯源

对于复杂的领域模型，传统的 CRUD 往往不够用。CQRS（命令查询职责分离）和事件溯源模式允许将写入和读取操作分离，并存储状态变更的历史记录。

在 Go 中实现 CQRS

将模型分为命令（改变状态）和查询（读取）。以订单管理服务为例。

// commands.gopackage orders

type CreateOrderCommand struct {    UserID  string    Items   []OrderItem}

type OrderCommandHandler struct {    repo OrderRepository    bus  EventBus}

func (h *OrderCommandHandler) Handle(ctx context.Context, cmd CreateOrderCommand) error {    order := NewOrder(cmd.UserID, cmd.Items)    if err := h.repo.Save(ctx, order); err != nil {        return err    }    h.bus.Publish(ctx, OrderCreatedEvent{        OrderID: order.ID,        UserID:  order.UserID,    })    return nil}

// queries.gotype OrderQueryHandler struct {    readRepo OrderReadRepository}

func (h *OrderQueryHandler) GetOrderByID(ctx context.Context, orderID string) (*OrderView, error) {    return h.readRepo.FindByID(ctx, orderID)}

对于事件溯源，可以使用 github.com/looplab/eventhorizon 库，或者基于 Go 通道编写自己的实现。

2. Saga 模式：分布式事务

在微服务世界中，跨多个服务的 ACID 事务是不可能的。Saga 模式通过一系列带有补偿操作的本地事务来解决这个问题。

编排 vs 协调

有两种方法：编排（服务通过事件通信）和协调（中央协调器）。Go 项目通常选择编排，因为它具有去中心化的特点。

// saga.gopackage saga

type SagaStep struct {    Name     string    Action   func(ctx context.Context) error    Compensate func(ctx context.Context) error}

type Saga struct {    steps []SagaStep}

func (s *Saga) Execute(ctx context.Context) error {    executed := []SagaStep{}    for _, step := range s.steps {        if err := step.Action(ctx); err != nil {            // 补偿所有已执行的步骤            for i := len(executed) - 1; i >= 0; i-- {                executed[i].Compensate(ctx)            }            return err        }        executed = append(executed, step)    }    return nil}

// 使用示例：func CreateOrderSaga(ctx context.Context) error {    saga := Saga{        steps: []SagaStep{            {Name: "ReserveInventory", Action: reserveInventory, Compensate: releaseInventory},            {Name: "ChargePayment", Action: chargePayment, Compensate: refundPayment},            {Name: "SendEmail", Action: sendEmail, Compensate: noop},        },    }    return saga.Execute(ctx)}

对于消息代理，请使用 RabbitMQ 或 NATS——它们通过 github.com/streadway/amqp 和 github.com/nats-io/nats.go 包与 Go 完美集成。