PHP RabbitMQ的心跳问题

环境
PHP7，Thinkphp5，php-amqp类库

场景描述
生产的消息队列，其消费者总是无故断开，基本在五天左右就会断开，但是程序端消费者的进程却仍在继续，并且没有捕获到任何异常。经过多次尝试，最终将问题定位在mq的心跳问题。因为我们数据中心的防火墙正在终止空闲连接

mq心跳
1.rabbitmq使用心跳机制来保持连接，在正常场景下，客户端期望通过发送心跳包来告知服务端自己存活。如果服务端连续两次发送心跳客户端均无回应，服务端会断开与客户端的连接。心跳间隔可在每次连接时设置。
2.因php是同步语言，它无法在后台运行耗时任务时持续发送心跳包。这时候服务端就会断开连接，而客户端只有继续使用这个队列的时候才会发现已断开

查看消费者源码可以发现，heartbeat的默认值为0，表示不开启心跳检测

当heartbeat>0时表示开启心跳，此时需要注意的问题有：

应该重新设定read_write_timeout的值，如果该属性低于心跳，则连接将在尝试写入时消失，一般来说，应该使用双倍心跳的值。我使用的是60/30。
网络问题可能会影响心跳包的发送与接收，导致脚本的异常中断。为防止该问题，应该在消费者外层进行异常捕获，并对异常进行响应的处理，例如脚本中断后进行重启（例如：supervisor进程守护）。

此外，由于mq长时间等待的问题，可能会造成数据库连接的断开，因此我在程序中的处理方法是处理完一次业务后主动断开数据库连接（Db::close()），这样下次业务开始时会重新建立连接。

消费者代码

PHP RabbitMQ的心跳问题相关推荐

RabbitMQ之心跳检测
Heartbeat超时值 heartbeat超时值定义了RabbitMQ及其client库在多久之后认为TCP连接不可到达.这个值是在client连接RabbitMQ服务器的时候协商好的,在Rabbi ...
rabbitmq 心跳机制
首先上官方说明:https://www.rabbitmq.com/heartbeats.html 从官方文档可以看到有个heartbeat timeout,服务端默认60s,这里的描述可能有些迷惑性 ...
python使用pika订阅rabbitmq消息链接被重置问题
最近在做一个运维监控系统的时候,使用python的pika插件订阅rabbitmq消息,程序在运行一段时间后,总是会报链接被充值的错误,具体报错如下: Traceback (most recent c ...
RabbitMQ狂神说笔记（RabbitMQ B站狂神说笔记、KuangStudy、学相伴飞哥）
一. 引用文章 RabbitMQ狂神说笔记(B站狂神说笔记.KuangStudy.学相伴飞哥) RabbitMQ狂神说笔记(B站狂神说笔记.KuangStudy.学相伴飞哥)百度云盘地址,提取码:07 ...
OpenStack Summit Paris 会议纪要 - 11-04-2014
前言: 来源:https://wiki.openstack.org/wiki/Summit/Kilo/Etherpads#Ops 不一定翻译准,因为是在summit上随手写的. 重点关注Ops Sum ...
websocket心跳链接代码_Hyperf+RabbitMQ+WebSocket实现大屏幕消息推送
作者:八重樱来源:www.cnblogs.com/a609251438/p/12713467.html 介绍基于 Hyperf+ WebSocket +RabbitMQ 实现的一个简单大屏幕的消息 ...
RabbitMq学习笔记006---修改RabbitMq端口号和心跳时间
假设读者在Windows系列的操作系统中安装好了Rabbit MQ后,请找到安装路径下的etc文件夹下,将rabbitmq.config.example备份一份,并修改为config类型的文件,即为r ...
JAVA调用mq时做心跳检测,[翻译]RabbitMQ 心跳
用心跳检测死TCP连接介绍网络可能会以许多方式失败,有时会很细微(例如高比率的数据包丢失).中断的TCP连接需要比较长时间(例如,在Linux上默认是大约11分钟)才能被操作系统检测到.AMQP ...
rabbitmq 学习之心跳检测（13）
https://www.rabbitmq.com/heartbeats.html 简介网络在很多情况下会失败,有时情况很微妙(比如丢包率很高).操作系统检测到 TCP 断开是一个适中的时间(在 L ...

PHP RabbitMQ的心跳问题

PHP RabbitMQ的心跳问题相关推荐

最新文章

热门文章