Apache进程不会在与RabbitMQ断开连接后死亡
我试图在我的项目中使用Server Side Events机制。 (这类似于类固醇上的长轮询)Apache进程不会在与RabbitMQ断开连接后死亡
来自“Sending events from the server”字幕的例子效果非常好。几秒钟后,断开连接,apache进程终止。此方法工作正常。
但是!如果我尝试使用RabbitMQ,则在浏览器从服务器断开连接后,Apache不会导致进程中断(es.close()
)。并且进程保持原样并在docker容器重新启动后才会被杀死。
connection_aborted和connection_status根本不起作用。 connection_aborted
仅返回0
,即使断开连接,connection_status也返回CONNECTION_NORMAL
。只有当我使用RabbitMQ时才会发生。没有RMQ这个功能运作良好。
ignore_user_abort(false)
也不起作用。
代码示例:
<?php use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Connection\AbstractConnection;
use PhpAmqpLib\Exception\AMQPTimeoutException;
use PhpAmqpLib\Message\AMQPMessage;
class RequestsRabbit
{
protected $rabbit;
/** @var AMQPChannel */
protected $channel;
public $exchange = 'requests.events';
public function __construct(AbstractConnection $rabbit)
{
$this->rabbit = $rabbit;
}
public function getChannel()
{
if ($this->channel === null) {
$channel = $this->rabbit->channel();
$channel->exchange_declare($this->exchange, 'fanout', false, false, false);
$this->channel = $channel;
}
return $this->channel;
}
public function send($message)
{
$channel = $this->getChannel();
$message = json_encode($message);
$channel->basic_publish(new AMQPMessage($message), $this->exchange);
}
public function subscribe(callable $callable)
{
$channel = $this->getChannel();
list($queue_name) = $channel->queue_declare('', false, false, true, false);
$channel->queue_bind($queue_name, $this->exchange);
$callback = function (AMQPMessage $msg) use ($callable) {
call_user_func($callable, json_decode($msg->body));
};
$channel->basic_consume($queue_name, '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
if (connection_aborted()) {
break;
}
try {
$channel->wait(null, true, 5);
} catch (AMQPTimeoutException $exception) {
}
}
$channel->close();
$this->rabbit->close();
}
}
会发生什么:
- 浏览器建立连接SSE到服务器。
var es = new EventSource(url);
- Apache2产生新的进程来处理这个请求。
- PHP生成一个新的队列并连接到它。
- 浏览器关闭连接
es.close()
- Apache2不会终止进程并保持原样。 RabbitMQ队列不会被删除。如果我做了一些重新连接,它会产生一堆进程和一堆队列(1重新连接= 1进程= 1队列)。
- 我关闭所有选项卡 - 活动进程。我关闭浏览器 - 相同的情况。
寻找某种类型的PHP错误。还是Apach2?
我用什么:
- 最后泊坞窗和码头工人,组成
- php:7.1.12-apache or php:5.6-apache图像(这种情况发生在PHP的两个版本)
一些截图:
请帮我弄清楚是怎么回事...
附:对不起我的英语不好。如果您可以找到错误或错字,请在评论中指出它。我会很感激:)
回答:
,如果你在你的服务器端事件使用send()
或subscribe()
(或两者)你不说。假设你正在使用subscribe()
没有错误。这个循环:
while (count($channel->callbacks)) { if (connection_aborted()) {
break;
}
try {
$channel->wait(null, true, 5);
} catch (AMQPTimeoutException $exception) {
}
}
将运行,直到进程被杀死或连接远离的RabbitMQ关闭。收听排队消息时这是正常的。如果你需要在某个时候停止循环,你可以设置一个变量来检查循环,或者在SSE结束时抛出异常(尽管我觉得这很尴尬)。
以上是 Apache进程不会在与RabbitMQ断开连接后死亡 的全部内容, 来源链接: utcz.com/qa/266612.html