可能原因
如果你连接的 mq 需要指定vhost,八成就是下面这个问题
解决方法
amqp.Dial("amqp://guest:guest@127.0.0.1:5672//dlyp")
可以用下面这段代码测试
package main
import (
"fmt"
"github.com/streadway/amqp"
"log"
)
func main() {
// 连接RabbitMQ服务器
//conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
conn, err := amqp.Dial("amqp://guest:guest@127.0.0.1:5672/dlyp")
if err != nil {
log.Fatalf("无法连接到RabbitMQ: %v", err)
}
defer conn.Close()
fmt.Println("连接成功!")
}