在 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" 的消息主题，发布了一条消息，然后订阅了该主题。当我们收到一条消息时，我们会打印它的内容。