IronMQ и Laravel: задержки и повторные попытки

Это именно то, что делает Laravel, когда вы запускаете команду artisan queue:subscribe Напомним, что после того, как вы выполните необходимую настройку в файле queue.php(заполнив его значениями project_id, token и queue_name) , вы запускаете команду для регистрации ваших подписчиков:

 php artisan queue:subscribe queue_name http://foo.com/queue/receive

Эта команда запускает следующий код:

/vendor/laravel/framework/src/Illuminate/Queue/Console/SubscribeCommand.php

 public function fire()
    {
		$iron->getIron()->updateQueue($this->argument('queue'), $this->getQueueOptions());
	}

Некоторый контент исключен из файла для краткости.

Вот как Laravel преобразует нашу очередь в очередь push. Это то же самое, что и при использовании библиотеки Iron MQ.

Использование PHP-библиотеки Iron MQ

1. Создать новый контроллер IronController в приложении / контроллеры

    <?php
           
           class IronController extends Controller {
           
               protected $ironmq;
   
           	public function __construct()
           	{
           		$this->ironmq = new IronMQ(array(
           					    "token" => 'XXXXXXXXXXXXXXXXXXX', //Your token from dashboard
           					    "project_id" => 'XXXXXXXXXXXXXXX' //Your project ID from dashboard
           					));
           	}
           
           }

   Приложение / контроллер / IronController.php

2. Прежде чем мы создадим наши методы, давайте создадим маршруты, чтобы понять, что будет делать наш контроллер:

    Route::get('iron/create','IronController@create'); //Create a Queue and add subscribers
           Route::get('iron/push','IronController@push'); //Push a message to Queue
           Route::get('iron/status/{id}','IronController@status'); //Know the status of the message we pushed
           Route::post('iron/receive','IronController@receive'); //Receive the message and process it

   Приложение / routes.php

3. Теперь давайте напишем метод для создания очереди с подписчиком

    public function create()
       	{
       		$params = array(
       		    "subscribers" => array(
       		        array("url" => url('iron/receive'))
       		    )
       		);
       
       		$this->ironmq->updateQueue('testing', $params);
       
       		return 'Push Queue Created';
       	}

   Приложение / контроллер / IronController.php

4. Вам нужно посетить http://953ffbb.ngrok.com/iron/create/iron/create Примечание. Ваш URL-адрес ngrok будет другим.

   На этом этапе вы можете перейти к Iron DashBoard -> MQ -> Queues -> Найти очередь с именем ‘testing’ -> Push Queues и убедиться, что ваш подписчик указан там аналогично http://953ffbb.ngrok.com/iron/receive

5. Давайте добавим методы, чтобы отправить сообщение в очередь и проверить статус.

   Способ отправить сообщение:

    public function push()
           {
           	//Just some data you want to pass
           	$data = array(
           		'first_name' => 'Rajiv', 
           		'last_name'  => 'Seelam'
           	);
           
           	//Convert data into a string so that we can pass it
           	$data = serialize($data);
           
           	//Post the message
           	$job = $this->ironmq->postMessage('testing', $data);
           
           	Log::info(__METHOD__.' - Message pushed with job_id : '.$job->id);
           
               return Redirect::to('iron/status/'.$job->id);
           }

   Способ проверки статуса сообщения:

    public function status($id)
   	{
   	$status = $this->ironmq->getMessagePushStatuses('testing',$id);
   	dd($status);
   	}

   Приложение / контроллер / IronController.php

6. Нам нужен метод для получения сообщения, когда мы нажимаем.

    public function receive()
           {
           	$req = Request::instance();
       
       		$jobId = $req->header('iron-message-id'); //Get job id 
       
       		$data = unserialize($req->getContent()); //Get content and unserialize it
       
       		Log::info(__METHOD__.' - Job Received From Iron with Job ID : '.$jobId);
       
       		return Response::json(array(),200);
       	}

   Приложение / контроллер / IronController.php

На этом этапе вы должны понимать, что это метод, который будет получать сообщение, потому что в методе createurl('iron/receive')

Держите ваше приложение / storage / logs / laravel.log открытым, чтобы увидеть, что происходит.

Теперь, если вы посетите http://953ffbb.ngrok.com/iron/push

 array (size=1)
          0 => 
            object(stdClass)[184]
              public 'retries_delay' => int 60
              public 'retries_remaining' => int 3
              public 'retries_total' => int 3
              public 'status_code' => int 200
              public 'status' => string 'deleted' (length=7)
              public 'url' => string 'http://953ffbb.ngrok.com/iron/receive' (length=38)
              public 'id' => string '6019569765635787179' (length=19)

И ваши журналы должны быть похожи на:

 [2014-05-31 12:45:04] production.INFO: IronController::push - Message pushed with job_id : 6019569765635787179 [] []
[2014-05-31 12:45:05] production.INFO: IronController::receive - Job Received From Iron with Job ID : 6019569765635787179 [] []

приложение / хранение / журналы / laravel.log

Эти журналы подтверждают нашу активность. Давайте подведем итоги того, что мы сделали здесь:

• Мы отправили сообщение в очередь под названием «тестирование»
• Затем мы проверили статус сообщения в очереди
• Мы получили сообщение и что-то записали.

Задержки и повторные попытки

Теперь давайте пойдем немного глубже. Откройте панель управления Iron и перейдите на страницу очередей (щелкните MQ) -> Откройте очередь тестирования и выберите «Push Queues», вы увидите список подписчиков, а в «Push Information» вы увидите «Retries» и «Retries Delay». ».

 public 'status' => string 'deleted'

 $this->ironmq->postMessages('testing', "data", array(
        "timeout" => 300 // Wait for 300 seconds = 5 minutes
    ));

 $params = array(
	    "retries" => 5
	);

	$this->ironmq->updateQueue('testing', $params);