使用pika库,如何判断connection和channel是open还是closed的?

发布于 2022-09-05 22:55:21 字数 1075 浏览 16 评论 0

近期使用rabbitmq,python2.7,pika 0.10.0,想要判断connection和channel是否open,但是用connection里的is_closed()和is_open()似乎不生效。
我的测试代码如下:
程序运行后,即使我重启了rabbitmq所在的机器,打印的is_closed和is_open也是不变的。

#!/usr/bin/env python  
import pika  
import time  


credit = pika.PlainCredentials(username='cloud', password='cloud')

connection = pika.BlockingConnection(pika.ConnectionParameters(
    host='10.32.1.12', credentials=credit))

channel = connection.channel()  

while True:
    connect_close = connection.is_closed
    connect_open = connection.is_open
    channel_close = channel.is_closed
    channel_open = channel.is_open
    
    print("connection is_closed ", connect_close)
    print("connection is_open ", connect_open)
    print("channel is_closed ", channel_close)
    print("channel is_open ", channel_open)
    print("")
    time.sleep(5)

下面是每隔5s打印一次的结果,一直是没变的,即使当中重启了rabbitmq所在的机器也是这样。不知道究竟如何判断当前连接的状态呢?因为发现断链的话,要重新进行连接。
图片描述

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文