无法使用Go从RabbitMQ发送消息

conn, err := amqp.Dial("amqp://guest:guest@localhost:5672/")
if err != nil {
    // 处理连接错误
}
defer conn.Close()

ch, err := conn.Channel()
if err != nil {
    // 处理通道创建错误
}
defer ch.Close()

queue, err := ch.QueueDeclare(
    "my_queue", // 队列名称
    false,     // 是否持久化
    false,     // 是否自动删除
    false,     // 是否具有排他性
    false,     // 是否阻塞
    nil,       // 额外参数
)
if err != nil {
    // 处理队列声明错误
}

message := amqp.Publishing{
    ContentType: "text/plain",
    Body:        []byte("Hello, RabbitMQ!"),
}
err = ch.Publish(
    "",           // 交换机名称
    queue.Name,   // 队列名称
    false,        // 是否强制
    false,        // 是否立即发送
    message,
)
if err != nil {
    // 处理消息发送错误
}