在 go 中实现分布式 mq 的框架包括 nats、nsq、kafka。实战案例中，使用 nats 框架连接到服务器，创建主题 "my_subject"，发布消息 "hello nats!"，并订阅该主题，当收到消息时，打印其内容。
Golang 框架中实现分布式消息队列
简介
分布式消息队列（MQ）是一种服务，允许应用程序异步地发送和接收消息。在 Go 中，有几个框架可以帮助你实现分布式 MQ。
立即学习“go语言免费学习笔记（深入）”；
框架
- NATS: 一个高性能、低延迟的消息传递系统。
- NSQ: 一个高吞吐量、低延迟、高可靠性的 MQ。
- Kafka: 一个强大的分布式流处理平台。
实战案例：使用 NATS 实现分布式 MQ
在本节中，我们将使用 NATS 框架创建一个分布式 MQ。
import (
"context"
"fmt"
"time"
"github.com/nats-io/go-nats"
)
func main() {
// 连接到 NATS 服务器
conn, err := nats.Connect("localhost:4222")
if err != nil {
panic(err)
}
defer conn.Close()
// 创建一个消息主题
subject := "my_subject"
// 发布消息
msg := "Hello NATS!"
err = conn.Publish(subject, []byte(msg))
if err != nil {
panic(err)
}
// 订阅消息
sub, err := conn.Subscribe(subject, func(msg *nats.Msg) {
fmt.Println("Received message:", string(msg.Data))
})
if err != nil {
panic(err)
}
defer sub.Unsubscribe()
// 等待 10 秒以接收消息
time.Sleep(10 * time.Second)
}在这个示例中，我们创建了一个名为 "my_subject" 的消息主题，发布了一条消息，然后订阅了该主题。当我们收到一条消息时，我们会打印它的内容。
