jjzjj

streadway

全部标签

go - 如何检查 channel 是否仍在 streadway/amqp RabbitMQ 客户端中工作?

这个问题在这里已经有了答案:HowtodetectdeadRabbitMQconnection?(4个答案)关闭9个月前。我正在使用github.com/streadway/amqp对于我的程序。在重新初始化之前,我应该如何确保用于消费和/或生产的channel仍在工作?例如,在ruby​​中,我可以简单地做:bunny_client=Bunny.new({....})bunny_client.start启动客户端,ifnotbunny_clientorbunny_client.status!=:connected#re-initializetheclient如何使用streadway

go - 使用 Go RabbitMQ streadway/amqp 驱动程序时无法从函数返回 *amqp.Channel

我正在尝试使用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