Skip to content
7 de agosto de 2015 / rafaelti

Primeiro job com Beanstalk e ZF2

Objetivo

Criar jobs através do ZF2

Plataforma

Linux, php, zf2, beanstalk

Conhecimento

Linux, php, zf2

Introdução

Após instalar o Beanstalk agora é hora de integrar o ZF2 e automatizar a criação de jobs.

Solução

Utilização do SlmQueue especificamente SlmQueueBeanstalkd, com o composer para instalação é o jeito mais fácil. Ao instalar SlmQueueBeanstalkd via composer automaticamente instala suas dependências.

Inserir os módulos no application.config.php

'SlmQueue' ,
'SlmQueueBeanstalkd',

Após a instalação copiar os arquivos slm_queue.global.php e slm_queue_beanstalkd.local.php para o Autoload.
Minha configuração ficou

//slm_queue.global.php
return array(
 'slm_queue' => array(
  ///
  //Configurações
  //
 'job_manager' => array(
 'invokables' => array(
 'Application\Job\PrintHelloWorldJob' => 'Application\Job\PrintHelloWorldJob',
 ),
 ),
 'queue_manager' => array(
 'factories' => array(
 'default' => 'SlmQueueBeanstalkd\Factory\BeanstalkdQueueFactory'
 )
 ),

 ),
);

E

//slm_queue_beanstalkd.local.php
return array(
'slm_queue' => array(
 /**
 * Configuration for Beanstalkd
 */
 'beanstalkd' => array(
 'connection' => array(
 /**
 * Connection host
 */
 'host' => '0.0.0.0',

 /**
 * Connection post
 */
 'port' => 11300,

 /**
 * How long, in seconds, the socket will wait for the server to respond to its
 * initial connection attempt
 */
 'timeout' => 2
 ),
 ),
 ),
);

Job Hello World

namespace Application\Job;

use SlmQueue\Job\AbstractJob;
use SlmQueue\Queue\QueueInterface;

class PrintHelloWorldJob extends AbstractJob
{
 public function execute()
 {
 echo "Hello World \n";
 }
}

Colocando um job na fila.

 public function queueAction() {
 $response = $this->getResponse();
 $job = $this->getServiceLocator()->get('SlmQueue\Job\JobPluginManager')->get('Application\Job\PrintHelloWorldJob');

 $queue = $this->getServiceLocator()->get('SlmQueue\Queue\QueuePluginManager')->get('default');
 $queue->push($job);
 return '';
 }

Ao acessar http://localhost/proj/queue
Resultado

rafael@ubuntu:/var/www/html/proj$ php public/index.php queue beanstalkd default
Hello World 

Hello World
Anúncios

Deixe um comentário

Preencha os seus dados abaixo ou clique em um ícone para log in:

Logotipo do WordPress.com

Você está comentando utilizando sua conta WordPress.com. Sair / Alterar )

Imagem do Twitter

Você está comentando utilizando sua conta Twitter. Sair / Alterar )

Foto do Facebook

Você está comentando utilizando sua conta Facebook. Sair / Alterar )

Foto do Google+

Você está comentando utilizando sua conta Google+. Sair / Alterar )

Conectando a %s

%d blogueiros gostam disto: