php – 使用System_Daemon包的Codeigniter守护进程

这就是我所拥有的：
将消息注入AWS SQS队列的CI控制器(感谢[url = http://codeigniter.com/forums/member/196201/]coccodrillo[/url]提供有关如何将AWS SDK集成到CI中的优秀说明.请参见此处：Integrating AWS SDK as a library in Codeigniter).

一个CI控制器,它接收队列中的消息并将其写入日志文件,然后删除队列中的消息.

我想有一个CI守护进程,它将监听这个队列,当它们在那里时接收消息并对该消息做一些有用的事情,然后删除该消息.所以我从System_Daemon文档中的示例开始,并在接收程序的CI代码中添加.见下面的代码

这是正确的做法吗？你能指导我做“正确的方式”吗？我已经把各种知识渊博的论坛搞得一团糟了……请帮帮我吧！

Mmiz

#!/usr/bin/php -q
<?php

// Make it possible to test in source directory
// This is for PEAR developers only
ini_set('include_path',ini_get('include_path').':..');

// Include Class
error_reporting(E_ALL);
require_once "System/Daemon.php";

// Bare minimum setup
System_Daemon::setOption("appName","receiveaws");
System_Daemon::setOption("logLocation","/tmp/log/receiveaws.log");
System_Daemon::setOption("appPidLocation","/tmp/log/receiveaws/receiveaws.pid");
System_Daemon::log(System_Daemon::LOG_INFO,"Daemon not yet started so this will be written on-screen");

// Spawn Deamon!
System_Daemon::start();
System_Daemon::log(System_Daemon::LOG_INFO,"Daemon: '".
    System_Daemon::getOption("appName").
        "' spawned! This will be written to ".
            System_Daemon::getOption("logLocation"));

System_Daemon::log(System_Daemon::LOG_WARNING,'My php code starting');
class Receiveaws extends CI_Controller {

    public function index(){
    if ($this->input->is_cli_request()) {
        //Load the aws library
        $this->load->library('awslib');
        $sqs = new AmazonSQS();

        //Get the queue to look at
        $res=$sqs->get_queue_url('example-queue');

        //Get the queue's url
        $qurl=($res->body->GetQueueUrlResult->QueueUrl);
        System_Daemon::log(System_Daemon::LOG_INFO,$qurl);

        //Get a message from the queue
        $response = $sqs->receive_message($qurl);

        //If there was a message received,then do something
            if ($res->isOK()) {
            System_Daemon::log(System_Daemon::LOG_INFO,"Receive message successful");
                            //Now delete message from queue
            $res=$sqs->delete_message($qurl,$rcpt_hand);
            if ($res->isOK()) {
                System_Daemon::log(System_Daemon::LOG_INFO,"Delete message successful");
            }
        } else {
            //go back to check for messages
            //How do you do that?
        }
    } else {
        //Access from URL - so bail out?
        //how do you not bail out of the daemon from here?
    }
    }
}
System_Daemon::stop();
?>