Zend Framework ZEND_QUEUE實現

Question

我是ZEND新手，我正在使用該版本（ZEND 1.11.1）我正在嘗試在我的zend應用程序中實現ZEND_QUEUE，並且沒有適合我的教程。通過我試圖實現隊列。

我正在開發一個DB隊列。該應用程序的工作原理如下： 1.用戶通過應用程序輸入SQL查詢並等待結果。 2.查詢成功完成後，查詢將移至隊列並使用數據庫進行處理。查詢應該發送結果發送給用戶。

在我的控制器：

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'); 
    } 
} 

，我現在面臨是我不能夠以我想添加的代碼文件夾來理解這個問題。

我沒有在我的應用程序中使用MODEL，因爲應用程序的要求是僅使用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 \ library \ Zend \ Controller \ Front.php（946）：

請向我建議正確的文件夾或幫助初學者使用ZEND JOBQUEUE的任何教程。

Answer 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這是在模頭譯碼（ '完成'）;

如果我在第一次運行的代碼我收到與以下的輸出：

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

當我再次運行同一個文件時，它的輸出

Done 

當家，我是一個，但是困惑，爲什麼它在不同的實例中給出了不同的輸出。幾個小時後，如果我再次運行代碼，它會給我第一個O/P。

DB的變化：

我有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 ; 

以上兩個是DB結構。 我可以看到插入隊列表中的一些數據，但我不知道哪些數據會受到影響？

請幫助我理解隊列和腳本的結構。

它工作正常嗎？如果我理解了Above邏輯並希望能夠在Zend中創建用於查詢執行的DB隊列。我正在努力解釋。

對我複製&粘貼代碼不是一個好的編程，知道我在做什麼是好的！

謝謝！任何幫助將不勝感激！