Swoole和Workerman的消息队列与实时日志处理的协同处理能力

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
SwooleEvent::add($redis->Socket, function($fd) use ($redis) {
    $message = $redis->lPop('message_queue');
    // 处理消息
    // ...
});
SwooleTimer::tick(1000, function() use ($redis) {
    // 生成消息，加入队列
    $message = generateMessage();
    $redis->rPush('message_queue', $message);
});
SwooleEvent::wait();

<?php
use WorkermanWorker;

$worker = new Worker();
$worker->name = 'log-worker';
$worker->onWorkerStart = function($worker) {
    $file = fopen('/path/to/log.txt', 'a');
    Worker::runAll();
};
$worker->onMessage = function($connection, $data) {
    // 处理日志
    // ...
    fwrite($file, $data);
};
$worker->onWorkerStop = function($worker) {
    fclose($file);
};
Worker::runAll();