使用Cakephp事件发送服务器附带事件？

Question

class MyController extends AppController {
    public function someAction() {
        //........
        $event = new CakeEvent('Controller.MyController.example', $this, array(
            'data' => $someData
        ));
        $this->getEventManager()->dispatch($event);
        //.........
    }
}

并在config/bootstrap.php中添加了以下行：

require_once APP . 'Config' . DS . 'events.php';

在config/events.php中

App::uses('CakeEventManager', 'Event');
App::uses('MyListener', 'Lib/Event');
// Global Listener
CakeEventManager::instance()->attach(new MyListener());

在lib/event/mylistener.php中

App::uses('CakeEventListener', 'Event');
class MyListener implements CakeEventListener {

    public function implementedEvents() {
        return array(
        'Controller.MyController.example' => 'example',  
        );
    }

    public function example(CakeEvent $event) {
        /*Do some optional manipulation with the $event->data,then send the data using event stream.
        How can I call some another Controller to create event stream ?
        (Should I create Event Stream here itself? If yes, how?)
        I know how to create event stream in simple php :

        header('Content-Type: text/event-stream');
        header('Cache-Control: no-cache');
        header('Connection: keep-alive');

        echo "data: $someData\n\n";
        flush();
         */
    }
}

PS：我使用Cakephp事件是因为它允许我在一个地方从不同的控制器收集所需的数据，然后从那里，我可以创建事件流（服务器发送的事件）。如果有更好的选择，请分享。

Answer 1

我认为这个问题很宽泛，要用一个合理的长文本来回答。因此，我建议您阅读这个问题和前两个答案服务器发送的事件和php是什么触发服务器上的事件？因为它很相似，很好地解释了SSE。

如果您了解SSE，您就会意识到您需要一个在循环中运行的php进程。我认为，来自libSSE库的代码或多或少是自我解释的。

class YourEventHandler extends SSEEvent {
    public function update(){
        //Here's the place to send data
        return 'Hello, world!';
    }
    public function check(){
        //Here's the place to check when the data needs update
        return true;
    }
}

$sse = new SSE();//create a libSSE instance
$sse->addEventListener('event_name',new YourEventHandler());//register your event handler
$sse->start();//start the event loop

您可以通过使用CakePHP shell实现这一点来归档相同的内容。