我编写了一个函数来检查rabbitmq 是否正在运行。
function getBrokerStatus()
{
log_message("info", "Checking if broker is running....");
try {
$amqpConnection = new AMQPConnection();
$amqpConnection->setLogin("guest");
$amqpConnection->setPassword("guest");
$amqpConnection->setVhost("/");
$amqpConnection->connect();
} catch (Exception $e) {
log_message("info", "Exception: " . $e->getMessage());
return false;
}
if (!$amqpConnection->isConnected()) {
log_message("info", "Cannot connect to the broker! It might not be running");
return false;
}
$amqpConnection->disconnect();
return true;
}
我的代码捕获了这个异常。我在日志中看到下面 -
Exception: Socket error: could not connect to host.
但是我的 rabbitmq 服务器正在运行,那么为什么会出现这个异常?我正在使用v3.1.1
rabbitmq-server。