Zend Framework ZEND_QUEUE реализация

Я новичок в ZEND и работаю над версией (ZEND 1.11.1). Я пытаюсь реализовать ZEND_QUEUE в своем приложении Zend, и для меня нет подходящего учебника. Все время я пытаюсь реализовать Очередь.

Я разрабатываю очередь для БД. Приложение работает следующим образом: 1. Пользователь вводит SQL-запрос через приложение и ожидает результата. 2. Запрос будет перемещен в очередь QUEUE и обработан с базой данных после успешного выполнения запроса. Запрос должен отправить результат, отправленный пользователю.

Внутри моего контроллера:

class IndexController extends Zend_Controller_Action
{
  public function indexAction()
  {
   $options = array(
        'name'          => 'queue1',
        'driverOptions' => array(
        'host'      => '127.0.0.1',
        'port'      => '3306',
        'username'  => 'queue',
        'password'  => 'queue',
        'dbname'    => 'queue',
        'type'      => 'pdo_mysql'
             )
        );

        // Create a database queue.
        // Zend_Queue will prepend Zend_Queue_Adapter_ to 'Db' for the class name.
        $queue = new Zend_Queue('Db', $options);
        foreach ($queue->getQueues() as $name) {
          echo $name, "\n";
        }
       $queue->send('My Test Message');
     }
}

Проблема, с которой я сталкиваюсь, заключается в том, что я не могу понять, в какую папку я хочу добавить код.

Я не использую МОДЕЛИ в своем приложении, так как требование к приложению - использовать только CONTROLLER и VIEW.

Также, когда я пытаюсь расширить Zend_Queue_Adapter_Db, я получаю следующую ошибку:

Неустранимая ошибка: класс 'ZendJobQueue' не найден

или же

Неустранимая ошибка: необработанное исключение "Zend_Controller_Dispatcher_Exception" с сообщением "Указан неверный контроллер (ошибка)" в F:\wamp\www\helloworld\library\Zend\Controller\Dispatcher\Standard.php:242 Трассировка стека: #0 F:\wamp\ WWW \ HelloWorld \ библиотека \Zend\Controller\Front.php(946):

Пожалуйста, посоветуйте мне правильную папку или любой учебник, который поможет начинающему работать с ZEND JOBQUEUE.

Источник

1 ответ

Решение

Я получил некоторый код, полезный по следующей ссылке:

http://dennisgurnick.com/2011/09/29/zend-queue-with-mysql/

И я сделал точно так же, как указано на сайте:

; file: application/configs/application.ini

[production]
; ...
resources.frontController.params.displayExceptions = 0
; ...
queue.driverOptions.type = "pdo_mysql"
queue.driverOptions.host = "localhost"
queue.driverOptions.username = "howtoqueue"
queue.driverOptions.password = "howtoqueue"
queue.driverOptions.dbname = "howtoqueue"

Добавлен следующий код в файл Boostrap.php:

<?php

// file: application/Bootstrap.php

class Bootstrap extends Zend_Application_Bootstrap_Bootstrap
{
  protected function _initQueue()
  {
    $options = $this->getOptions();

    $queueAdapter = new Zend_Queue_Adapter_Db( $options[ 'queue' ] );
    Zend_Registry::getInstance()->queueAdapter = $queueAdapter;

  }

}

Также добавлен еще один файл в папке библиотеки, но я не понимаю, почему этот файл добавлен.

<?php

// file: library/EmailPopo.php

class EmailPopo
{
  private $_data = array();

  public function __get($key) {
    return $this->_data[$key];
  }

  public function __set($key, $value) {
    $this->_data[$key] = $value;
  }

}

Добавлен следующий код в IndexController:

// file: application/controllers/IndexController.php

require_once "EmailPopo.php";
public function indexAction()
{
  $queueAdapter = Zend_Registry::getInstance()->queueAdapter;

  $options = array( 'name' => 'emailqueue' );
  $queue = new Zend_Queue( $queueAdapter, $options );

  $email = new EmailPopo();
  $email->date = time();
  $email->from = "minnie.mouse@disney.com";
  $email->to = "mickey.mouse@disney.com";
  $email->subject = "I want a divorce";
  $email->body = "Letter's in the mail.";

  $message = base64_encode( gzcompress( serialize( $email ) ) );

  $queue->send( $message );

}
public function queueAction() {

  $queueAdapter = Zend_Registry::getInstance()->queueAdapter;

  $options = array( 'name' => 'emailqueue' );
  $queue = new Zend_Queue( $queueAdapter, $options );

  $messages = $queue->receive( 2 );
  foreach( $messages as $message ) {
    try {
      $email = unserialize( gzuncompress( base64_decode( $message->body ) ) );
      $queue->deleteMessage( $message );

      echo sprintf(
        "Sent email to %s (time: %s)<br/>",
        $email->to,
        new Zend_Date( $email->date )
        ); 

    } catch( Exception $ex ) {
      echo "Kaboom!: " . $ex->getMessage() . "<br/>";   
    }
  }
  die( "Done" );
}

Чтобы быть открытым и откровенным, этот код, кажется, работает, так как я получаю "DONE" как O/P, который был закодирован в die("Done");

Если я запускаю код сначала, я получаю вывод со следующим:

Sent email to minnie.mouse@disney.com (time: current time)<br/>
Done

Когда я снова запускаю тот же файл, он выводит

Done

В одиночку, но я в замешательстве, почему это дает разные ставки в разных инстанциях. Через несколько часов, если я снова запускаю код, он выдаст мне первый O/P.

Изменения БД:

У меня есть 2 таблицы для этого приложения они:

  1. сообщение
  2. очередь

1.Message:

CREATE TABLE IF NOT EXISTS `message` (
  `message_id` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
  `queue_id` int(10) unsigned NOT NULL,
  `handle` char(32) DEFAULT NULL,
  `body` varchar(8192) NOT NULL,
  `md5` char(32) NOT NULL,
  `timeout` decimal(14,4) unsigned DEFAULT NULL,
  `created` int(10) unsigned NOT NULL,
  PRIMARY KEY (`message_id`),
  UNIQUE KEY `message_handle` (`handle`),
  KEY `message_queueid` (`queue_id`)
) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=15 ;

ALTER TABLE `message`
  ADD CONSTRAINT `message_ibfk_1` FOREIGN KEY (`queue_id`) REFERENCES `queue` (`queue_id`) ON DELETE CASCADE ON UPDATE CASCADE;

2.Queue

CREATE TABLE IF NOT EXISTS `queue` (
  `queue_id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `queue_name` varchar(100) NOT NULL,
  `timeout` smallint(5) unsigned NOT NULL DEFAULT '30',
  PRIMARY KEY (`queue_id`)
) ENGINE=InnoDB  DEFAULT CHARSET=utf8 AUTO_INCREMENT=9 ;

Вышеупомянутые два являются структурой БД. Я вижу некоторые данные, вставленные в таблицу очередей, но не знаю, на что это влияет?

Пожалуйста, помогите мне понять структуру очереди и сценария.

Это работает хорошо? Если я понимаю вышеприведенную логику и надеюсь, что смогу создать очередь БД для выполнения запросов в Zend. Я изо всех сил пытаюсь получить какое-то объяснение.

Для меня Copy & Paste Code - плохое программирование. Знание того, что я делаю - хорошо!

Спасибо! Любая помощь будет высоко оценена!

Источник
Другие вопросы по тегам