Rabbitmq socket error occurred

@pinepain yes, reloading php-fpm can solves the issue; php version is 7.0.6 and rabbitmq version is 3.6.5;
when i run the code as follows i get the error. thanks

$conn_args = array(
‘host’ => ‘192.168.204.72’,
‘port’ => ‘5672’,
‘login’ => ‘root’,
‘password’ => ‘root’,
‘heartbeat’ => 6
);
$conn = new AMQPConnection($conn_args);
if ($conn->pconnect()) {
echo «Established a connection to the broker n»;
} else {
echo «Cannot connect to the broker n «;
}
$channel = new AMQPChannel($conn);

$ex = new AMQPExchange($channel);
$ex->setName(‘exchange33’);
$ex->setType(AMQP_EX_TYPE_DIRECT);
$ex->setFlags(AMQP_DURABLE);

echo «exchange status:».$ex->declareExchange();
echo «n»;

$queue = new AMQPQueue($channel);
$queue->setName(‘queue33’);
$queue->setFlags(AMQP_NOPARAM);
$queue->declareQueue();
$queue->bind(‘exchange33′,’key’);

$message = json_encode(array(‘Hello World3!’,’php3′,’c++3:’));
$routingkey=’key’;
$res = $ex->publish($message,$routingkey);

php -version

PHP 7.0.6 (cli) (built: Jun 4 2016 13:48:07) ( NTS )
Copyright (c) 1997-2016 The PHP Group
Zend Engine v3.0.0, Copyright (c) 1998-2016 Zend Technologies
with Xdebug v2.4.1, Copyright (c) 2002-2016, by Derick Rethans

rabbitmqctl status

Status of node rabbit@localhost …
[{pid,27552},
{running_applications,
[{rabbitmq_management,»RabbitMQ Management Console»,»3.6.5″},
{rabbitmq_management_agent,»RabbitMQ Management Agent»,»3.6.5″},
{rabbit,»RabbitMQ»,»3.6.5″},
{os_mon,»CPO CXC 138 46″,»2.4.1″},
{rabbitmq_web_dispatch,»RabbitMQ Web Dispatcher»,»3.6.5″},
{webmachine,»webmachine»,»1.10.3″},
{mochiweb,»MochiMedia Web Server»,»2.13.1″},
{ssl,»Erlang/OTP SSL application»,»8.0.2″},
{public_key,»Public key infrastructure»,»1.2″},
{crypto,»CRYPTO»,»3.7.1″},
{amqp_client,»RabbitMQ AMQP Client»,»3.6.5″},
{rabbit_common,[],»3.6.5″},
{compiler,»ERTS CXC 138 10″,»7.0.2″},
{ranch,»Socket acceptor pool for TCP protocols.»,»1.2.1″},
{asn1,»The Erlang ASN1 compiler version 4.0.4″,»4.0.4″},
{syntax_tools,»Syntax tools»,»2.1″},
{inets,»INETS CXC 138 49″,»6.3.3″},
{xmerl,»XML parser»,»1.3.12″},
{mnesia,»MNESIA CXC 138 12″,»4.14.1″},
{sasl,»SASL CXC 138 11″,»3.0.1″},
{stdlib,»ERTS CXC 138 10″,»3.1″},
{kernel,»ERTS CXC 138 10″,»5.1″}]},
{os,{unix,linux}},
{erlang_version,
«Erlang/OTP 19 [erts-8.1] [source-77fb4f8] [64-bit] [smp:4:4] [async-threads:64] [hipe] [kernel-poll:true]n»},
{memory,
[{total,59202976},
{connection_readers,0},
{connection_writers,0},
{connection_channels,0},
{connection_other,2832},
{queue_procs,209624},
{queue_slave_procs,0},
{plugins,602808},
{other_proc,19381184},
{mnesia,82456},
{mgmt_db,509904},
{msg_index,48168},
{other_ets,1515968},
{binary,34472},
{code,24815589},
{atom,1033401},
{other_system,10966570}]},
{alarms,[]},
{listeners,[{clustering,25672,»::»},{amqp,5672,»::»}]},
{vm_memory_high_watermark,0.4},
{vm_memory_limit,3301144985},
{disk_free_limit,50000000},
{disk_free,52243738624},
{file_descriptors,
[{total_limit,102300},
{total_used,3},
{sockets_limit,92068},
{sockets_used,0}]},
{processes,[{limit,1048576},{used,236}]},
{run_queue,0},
{uptime,39},
{kernel,{net_ticktime,60}}]

Socket error: could not connect to host.

Как избавиться от таких ошибок в rabbitMQ?

Во-первых, нужно посмотреть сколько для rabbit доступно открытых файлов (см. file descriptors и socket descriptors).

Это можно сделать либо через админку на вкладке Overview. Либо через консоль с помощью команды sudo rabbitmqctl status:

$ sudo rabbitmqctl status | grep -A 2 file_descriptors 
 {file_descriptors,
     [{total_limit,10140},
      {total_used,8622},

Во-вторых, если количество открытых файлов приближается к максимально доступному (доступные ресурсы см. total_limit в консоли или available в админке), то это значит что ресурсы rabbitMQ заканчиваются и он может «отфутболивать» соединения. Это выглядит будто rabbitMQ подвис.

У rabbitMQ есть некоторые  проблемы с автоматическим освобождением ресурсов. Точнее дело в том, что rabbitMQ освобождает ресурсы в какие то моменты, а мы можем не дождаться этого момента и быть «отфутболенным».

Для увеличения количества свободных файлов нам могут помочь следующие действия:

1. Перезагрузка rabbitMQ (как временное решение).
2. Увеличение количества открытых файлов в настройках rabbitMQ. (для вступления изменений в силу все равно требуется перезапуск rabbit).

Как увеличить количество file descriptors / socket descriptors rabbitmq?

Это настраивается в файле /etc/default/rabbitmq-server. Вот всё его содержимое:

$ cat /etc/default/rabbitmq-server
# This file is sourced by /etc/init.d/rabbitmq-server. Its primary
# reason for existing is to allow adjustment of system limits for the
# rabbitmq-server process.
#
# Maximum number of open file handles. This will need to be increased
# to handle many simultaneous connections. Refer to the system
# documentation for ulimit (in man bash) for more information.
#

ulimit -S -n 1024

Нужно изменить единственный параметр ulimit -S -n <VALUE> и установить вместо <VALUE> значение 4096, 8192, 10240,  12288 или то, которое вам ближе. Затем перезапустить кролика.

После этого лимит открытых файлов должен увеличиться. Проверим, так ли это:

$ sudo rabbitmqctl status | grep -A 4 file_descriptors
 {file_descriptors,
     [{total_limit,99900},
      {total_used,5085},
      {sockets_limit,89908},
      {sockets_used,3386}]},

Если у вас не получаетcя задать большой ulimit:

/etc/init.d/rabbitmq-server: 11: ulimit: error setting limit (Invalid argument)

То сначала установите более высокий hard limit, затем soft limit. Т.к. софт лимит не может быть больше hard limit. Задаём в две строки:

ulimit -n 100000 #hard limit
ulimit -S -n 100000 #soft limit

Первый можно с -H.

Дата добавления:
7 лет назад