MQ - 消息队列
MQ 提供消息队列功能。
特性
- 消息发布和订阅
- 多种队列类型
- 消息持久化
- 消息确认
安装
bash
go get github.com/go-zoox/mq快速开始
基本使用
go
package main
import (
"fmt"
"github.com/go-zoox/mq"
)
func main() {
// 创建消息队列
messageQueue := mq.New()
// 订阅消息
messageQueue.Subscribe("topic1", func(msg mq.Message) {
fmt.Printf("Received: %s\n", msg.Data)
})
// 发布消息
messageQueue.Publish("topic1", mq.Message{
Data: "Hello, World!",
})
}