golang 中实现消息队列可以利用 nats 框架。安装 nats 后，启动服务器，使用 publish() 发布消息和 subscribe() 订阅消息。在实战中，订单服务通过 nats 通知库存服务新订单，从而实现高效的库存管理。
Golang 框架实现消息队列
在 Golang 中实现消息队列，可以使用开源框架轻松完成。一个流行的选择是 [NATS](https://nats.io/)，它是一个高性能、轻量级的消息代理，支持多种编程语言，包括 Golang。
安装 NATS
首先，使用以下命令安装 NATS：
go get github.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) 
