golang 中实现消息队列可以利用 nats 框架。安装 nats 后，启动服务器，使用 publish() 发布消息和 subscribe() 订阅消息。在实战中，订单服务通过 nats 通知库存服务新订单，从而实现高效的库存管理。

Golang 框架实现消息队列

在 Golang 中实现消息队列，可以使用开源框架轻松完成。一个流行的选择是 [NATS](https://nats.io/)，它是一个高性能、轻量级的消息代理，支持多种编程语言，包括 Golang。

安装 NATS

首先，使用以下命令安装 NATS：

go get <a style='color:#f60; text-decoration:underline;' href="https://www.php.cn/zt/15841.html" target="_blank">git</a>hub.com/nats-io/nats-server
go get github.com/nats-io/nats-client

启动 NATS 服务器

在启动应用程序之前，需要启动 NATS 服务器：

立即学习“go语言免费学习笔记（深入）”；

nats-server &

发布消息

可以使用 Publish() 函数发布消息：

import "github.com/nats-io/nats-client"

// 创建 NATS 客户端
nc, err := nats.Connect("nats://localhost:4222")
if err != nil {
    log.Fatal(err)
}
defer nc.Close()

// 发布消息
nc.Publish("my-topic", []byte("Hello, world!"))

订阅消息

可以使用 Subscribe() 函数订阅消息：

// 订阅主题
sub, err := nc.Subscribe("my-topic", func(m *nats.Msg) {
    log.Printf("Received: %s", string(m.Data))
})
if err != nil {
    log.Fatal(err)
}

// 等待消息
sub.WaitFor(10 * time.Second)

实战案例：库存管理系统

考虑一个库存管理系统，负责跟踪产品库存并处理订单。可以使用 NATS 实现一个消息队列，以便订单服务在收到新订单时通知库存服务。

订单服务：

// 创建 NATS 客户端
nc, err := nats.Connect("nats://localhost:4222")
if err != nil {
    log.Fatal(err)
}
defer nc.Close()

// 当收到新订单时，发布消息
func HandleNewOrder(order Order) {
    nc.Publish("new-order", []byte(order.ID))
}

库存服务：

// 创建 NATS 客户端
nc, err := nats.Connect("nats://localhost:4222")
if err != nil {
    log.Fatal(err)
}
defer nc.Close()

// 订阅新订单主题
sub, err := nc.Subscribe("new-order", func(m *nats.Msg) {
    orderID := string(m.Data)
    // 根据收到的订单 ID 更新库存
    UpdateInventory(orderID)
})
if err != nil {
    log.Fatal(err)
}

// 等待消息
sub.WaitFor(10 * time.Second)