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服务器：
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)
以上就是golang架构如何做到消息队列？的详细内容，大量请关注其他类似文章！