Golang RabbitMQ: 使用单个连接建立多个通道
下面是一个使用 Go 和 RabbitMQ 的代码示例,该代码建立一个连接并在该连接上创建多个通道:
package main
import (
"fmt"
"log"
"github.com/streadway/amqp"
)
func main() {
conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
log.Fatalf("failed to connect to RabbitMQ: %v", err)
}
defer conn.Close()
ch1, err := conn.Channel()
if err != nil {
log.Fatalf("failed to open channel 1: %v", err)
}
defer ch1.Close()
ch2, err := conn.Channel()
if err != nil {
log.Fatalf("failed to open channel 2: %v", err)
}
defer ch2.Close()
// Use channels here...
fmt.Println("Channels opened successfully.")
}
在这个例子中,我们使用 amqp.Dial 函数建立一个连接到 RabbitMQ 服务器。然后,我们使用 conn.Channel() 函数创建两个通道 ch1 和 ch2,并在使用完它们后将它们关闭。
此外,我们可以在这些通道上执行各种操作,例如声明队列、发布消息或消费消息。这些操作的具体实现将取决于你的应用程序的需要。
最后,我们输出一条消息以确认通道已成功打开。
原文地址: https://www.cveoy.top/t/topic/lAen 著作权归作者所有。请勿转载和采集!