在Golang中实现消息队列可以使用Golang的内置库和第三方库来实现。以下是两种常见的实现方式:
package main
import (
"fmt"
)
func main() {
queue := make(chan string, 10) // 定义一个容量为10的channel作为队列
go func() {
for i := 0; i < 10; i++ {
queue <- fmt.Sprintf("message %d", i) // 发送消息到队列
}
close(queue) // 关闭队列
}()
for msg := range queue { // 从队列接收消息
fmt.Println(msg)
}
}
package main
import (
"log"
"github.com/streadway/amqp"
)
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/") // 连接到RabbitMQ服务器
if err != nil {
log.Fatal(err)
}
defer conn.Close()
ch, err := conn.Channel() // 创建一个channel
if err != nil {
log.Fatal(err)
}
defer ch.Close()
q, err := ch.QueueDeclare(
"my_queue", // 队列名称
false, // 是否持久化
false, // 是否自动删除
false, // 是否排他性
false, // 是否等待服务器响应
nil, // 其他属性
)
if err != nil {
log.Fatal(err)
}
msgs, err := ch.Consume(
q.Name, // 队列名称
"", // 消费者名称
true, // 是否自动确认消息
false, // 是否独占
false, // 是否阻塞
false, // 其他属性
)
if err != nil {
log.Fatal(err)
}
for msg := range msgs {
log.Printf("Received message: %s", msg.Body)
}
}
以上是两种常见的实现消息队列的方式,选择哪种方式取决于具体的需求和场景。