Workerman? ???? ?? ?? ?? ???? ???? ??

??:
??? ??? ??? ??? ? ???? ??? ?? ??? ?? ?? ? ??? ???? ??? ??? ?????. ?? ?? ?? ???? ??? ???? ???? ?? ??? ? ? ???? ??????, ?? ? ?? ??? ??? ???? ?? ?? ??? ? ??? ?????. Workerman? ???? ??? ? ?? ???? ??? ??? ?? ??? PHP ????????. ? ????? Workerman? ???? ??? ?? ?? ?? ???? ???? ??? ???? ???? ?? ??? ?????.

1. ?? ??
1. PHP ??: Workerman? PHP ???????? ?? PHP ?? ??? ???? ???. apt-get? ???? PHP? ??? ? ????(?? ??? ?? ???? ?? ?? ? ????):

sudo apt-get install php-fpm

2. Workerman ??: Workerman? ?? Composer? ???? ???. Composer? ????? ?? ??? ??????.

curl -sS https://getcomposer.org/installer | php
sudo mv composer.phar /usr/local/bin/composer

?? ?? ???? ?????? ?? ??? ???? Workerman? ?????.

composer require workerman/workerman

3. Redis ??: Redis? ?? ?? ?? ???? ??? ???? ?????. ?? ??? ?? Redis? ??? ? ????.

sudo apt-get install redis-server

2. ?? ?? ?? ??? ??
?? ?? ?? ?? ???? ????? ????? ???? ???. ?? ????? ??? ?? ??? ????:

1. LogProducer: ?? ???, ??? ??? ???? ?? ?? ????? ??? ?? ?????.
2. LogConsumer: ?? ???? ?? ???? ?? ??? ???? Redis? ?????.
3. LogAnalyzer: ?? ???? Redis?? ????? ??? ?? ?????.

??? ???? ?? ????.

1. LogProducer.php

   <?php
   
   use WorkermanWorker;
   use WorkermanConnectionAsyncTcpConnection;
   
   require_once __DIR__.'/vendor/autoload.php';
   
   // 連接日志消費(fèi)者
   $producer = new AsyncTcpConnection('text://127.0.0.1:1234');
   $producer->onConnect = function($producer) {
    $producer->send("Hello, LogConsumer!");
   };
   $producer->onMessage = function($producer, $data) {
    // 產(chǎn)生日志
    $log = generateLogData();
    // 發(fā)送日志給日志消費(fèi)者
    $producer->send($log);
   };
   // 運(yùn)行日志生產(chǎn)者
   Worker::runAll();
   
   function generateLogData()
   {
    // 生成日志數(shù)據(jù)的代碼
    // ...
    return $log;
   }

2. LogConsumer.php

   <?php
   
   use WorkermanWorker;
   use WorkermanConnectionAsyncTcpConnection;
   
   require_once __DIR__.'/vendor/autoload.php';
   
   // 連接Redis
   $redis = new AsyncTcpConnection('tcp://127.0.0.1:6379');
   $redis->onConnect = function($redis) {
    $redis->send("AUTH yourpassword"); // 如果Redis服務(wù)器設(shè)置了密碼，請?zhí)鎿Q成實(shí)際的密碼
   };
   $redis->onMessage = function($redis, $data) {
    // 存儲日志到Redis
    $redis->send("LPUSH log_queue $data");
   };
   $redis->connect();
   
   // 運(yùn)行日志消費(fèi)者
   Worker::runAll();

3. LogAnalyzer.php

   <?php
   
   use WorkermanWorker;
   use WorkermanConnectionAsyncTcpConnection;
   
   require_once __DIR__.'/vendor/autoload.php';
   
   // 連接Redis
   $redis = new AsyncTcpConnection('tcp://127.0.0.1:6379');
   $redis->onConnect = function($redis) {
    $redis->send("AUTH yourpassword"); // 如果Redis服務(wù)器設(shè)置了密碼，請?zhí)鎿Q成實(shí)際的密碼
   };
   $redis->onMessage = function($redis, $data) {
    // 從Redis中讀取日志并進(jìn)行分析
    $redis->send("RPOP log_queue 10");
    // 進(jìn)行日志分析的代碼
   };
   $redis->connect();
   
   // 運(yùn)行日志分析器
   Worker::runAll();

   ? ???? ??? ?? ?? ????? ??.

   ??:
   ? ???? Workerman? ???? ?? ?? ?? ???? ???? ??? ?????. ?? ?? ?? ???? ?? ???? ?? ??? ? ? ?????? ??? ??? ???? ??? ? ????. ??? Workerman? ??? ??? ?? ???? ?? ???? ??? ???? ??? ? ????. ? ?? Workerman? ??? ?? ?? ?? ???? ????? ??? ??? ????.

   ? ??? Workerman? ???? ?? ?? ?? ???? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!