Ошибка подключения php-amqplib - PullRequest
Новая
       33

Ошибка подключения php-amqplib

0 голосов
/ 12 июня 2018

Я просто делаю тест, чтобы попытаться заставить RabbitMQ работать с php-amqplib.Я только что отредактировал вопрос, чтобы он использовал правильный порт.Есть идеи по этому поводу?

Это мой PHP-файл ... 

1 #!/usr/bin/env php
2 <?php
3
4 require __DIR__ . '/vendor/autoload.php';
5
6 $dotenv = new Dotenv\Dotenv(__DIR__);
7 $dotenv->load();
8
9 $sample_msg = "0% chance of rain!";
10
11 $amqpConnection = new \PhpAmqpLib\Connection\AMQPStreamConnection(
12     getenv('RABBITMQ_HOST'),
13     getenv('RABBITMQ_PORT'),
14     getenv('RABBITMQ_USER'),
15     getenv('RABBITMQ_PASSWORD'),
16     getenv('RABBITMQ_VHOST')
17 );
18
19 $amqpChannel = $amqpConnection->channel();
20 $amqpChannel->queue_declare(getenv('SFTP_RABBITMQ_QUEUE'), false, true, false, false);
21
22 $msg = new AMQPMessage($sample_msg);
23 $channel->basic_publish($msg, '', 'hello');
24
25 echo " [x] Sent $sample_msg\n";

Это мой .env ... 

RABBITMQ_HOST=dev.website.co.uk
RABBITMQ_PORT=5672 // ammended
RABBITMQ_VHOST=/
RABBITMQ_LOGIN=xxxxxx
RABBITMQ_PASSWORD=xxxxxx

SFTP_RABBITMQ_QUEUE=my_test_queue

Это композитор.json ... 

{
    "name": "neil/sftp-user-create",
    "type": "project",
    "require": {
        "php-amqplib/php-amqplib": "^2.7",
        "vlucas/phpdotenv": "^2.4"
        },
    "license": "proprietary",
    "authors": [
        {
             "name": "Me",
             "email": "my@email-address.com"
                                                             }
     ]
}

Это ошибка, которую я получаю ... 

PHP Fatal error:  Uncaught PhpAmqpLib\Exception\AMQPRuntimeException: Broken pipe or closed connection in /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php:214
Stack trace:
#0 /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/AMQPReader.php(149): PhpAmqpLib\Wire\IO\StreamIO->read(7)
#1 /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/AMQPReader.php(106): PhpAmqpLib\Wire\AMQPReader->rawread(7)
#2 /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Connection/AbstractConnection.php(522): PhpAmqpLib\Wire\AMQPReader->read(7)
#3 /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Connection/AbstractConnection.php(570): PhpAmqpLib\Connection\AbstractConnection->wait_frame(0)
#4 /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Channel/AbstractChannel.php(225): PhpAmqpLib\Connection\Abstr in /home/neil/PhpstormProjects/sftp-user-create/vendor/php-amqplib/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php on line 214

1 Ответ

0 голосов
/ 12 июня 2018

У вас есть несколько проблем в вашем коде:

  1. В вашем .env файле, который вы объявили RABBITMQ_LOGIN, но в своем коде вы используете RABBITMQ_USER, что дает вам пустой логин и "Broken pipe""ошибки после того, как вы исправили порт подключения, как @iainn упомянул
  2. $channel->basic_publish у вас нет переменной с именем $channel, она должна быть $amqpChannel
  3. In basic_publish ваш последнийАргументом должно быть имя очереди, в которую вы хотите отправить сообщение, поэтому оно должно быть таким же, как в queue_declare, то есть getenv('SFTP_RABBITMQ_QUEUE')

Исправьте это в своем коде: 

$amqpConnection = new \PhpAmqpLib\Connection\AMQPStreamConnection(
     getenv('RABBITMQ_HOST'),
     getenv('RABBITMQ_PORT'),
     getenv('RABBITMQ_LOGIN'), // Use _LOGIN as declared in .env
     getenv('RABBITMQ_PASSWORD'),
     getenv('RABBITMQ_VHOST')
);

(...) 

// Use $amqpChannel as you declared it earlier in code
// And use the same queue name in last parameter as you used in queue_declare
$amqpChannel->basic_publish($msg, '', getenv('SFTP_RABBITMQ_QUEUE'));
...