如何在 docker 中重置rabbitmq 服务时自动使用

问题描述

有时会在我的 docker 服务中重置rabbitmq 服务

重置后，rabbitmq消费者变为零 我必须在终端中使用 docker-compose 像下面的代码一样运行 kill & up

docker-compose kill datacleanup
docker-compose up -d datacleanup

在我运行它之后，rabbitmq 消费者正在工作而不是零了

但每次发生时我都必须运行它

我想知道有没有办法通过rabbitmq服务本身自动做到这一点？

这是我的rabbitmq连接代码：

def start(self):
        try:
            credentials = pika.PlainCredentials(settings.RABBIT_USER,settings.RABBIT_USER)
            connection = pika.BlockingConnection(
                pika.ConnectionParameters(host=settings.SERVER_RABBITMQ_URL,credentials=credentials,heartbeat=600,blocked_connection_timeout=300))
            channel = connection.channel()
            channel.queue_declare(queue=os.environ.get('QUEUENAME'),durable=True)
            channel.basic_qos(prefetch_count=1)
            channel.basic_consume(queue=os.environ.get('QUEUENAME'),on_message_callback=self.callback)
            channel.start_consuming()
            connection.close()

        except Exception as e:
            print("consuming exception: {}".format(str(e)))

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）