使用python的pika链接rabbitMq断裂

比如我们执行一个很长的任务的时候,执行结束ack确认发现确认失败,mq都断了。

只要是使用pyhon的pika都会出现这个问题,因为pika本身是没有主动发送心跳机制的(你用java的话是没问题的)

解决方式:

在链接中heartbeat=0

credentials = pika.PlainCredentials('xxx','xxx')
connection = pika.BlockingConnection(pika.ConnectionParameters(
host = "xxxx",port = 5672, credentials = credentials , heartbeat=0
))

相关推荐

  1. 使用pythonpikarabbitMq断裂

    2023-12-28 13:20:05       49 阅读
  2. RabbitMQ + Spring Boot + Python使用过程

    2023-12-28 13:20:05       35 阅读
  3. Python爬虫如何处理页面中相对

    2023-12-28 13:20:05       63 阅读
  4. 保存

    2023-12-28 13:20:05       29 阅读
  5. RUST笔记: 动态创建和使用

    2023-12-28 13:20:05       69 阅读

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-28 13:20:05       94 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-28 13:20:05       100 阅读
  3. 在Django里面运行非项目文件

    2023-12-28 13:20:05       82 阅读
  4. Python语言-面向对象

    2023-12-28 13:20:05       91 阅读

热门阅读

  1. springboot实现数据库故障自动切换

    2023-12-28 13:20:05       60 阅读
  2. oj 1.8编程基础之多维数组 12:变幻的矩阵

    2023-12-28 13:20:05       56 阅读
  3. 【linux】select实现定时器

    2023-12-28 13:20:05       49 阅读
  4. mac配置subl命令打开sublime

    2023-12-28 13:20:05       50 阅读
  5. 网络安全领域的12个大语言模型用例

    2023-12-28 13:20:05       56 阅读
  6. Spring Boot学习:Flyway详解

    2023-12-28 13:20:05       62 阅读
  7. 机器学习笔记--图的基本表示和特征工程

    2023-12-28 13:20:05       64 阅读
  8. 6、docker 安装mysql8

    2023-12-28 13:20:05       53 阅读
  9. ARMday7

    ARMday7

    2023-12-28 13:20:05      55 阅读
  10. a-range-picker实现默认时间各种时分秒时间要求

    2023-12-28 13:20:05       62 阅读
  11. linux | pause函数 、alarm函数、signal函数

    2023-12-28 13:20:05       50 阅读