我正在尝试使用streadway/amqp连接到RabbitMQ总线Go的驱动程序。我正在处理重新连接例程,为此,我有一个rabbitMQConsume函数调用rabbitMQConnect函数。funcrabbitMQConnect(cfgobjects.GlobalConfig)(*amqp.Connection,*amqp.Channel,error){rabbitConfig:=amqp.Config{Vhost:cfg.RabbitVHost,Heartbeat:5,}//OpenconnectiontoRabbiturl:=fmt.Sprintf("amqp://"+cfg