workerman 簡單的使用

• 建立一個普通的DAEMON

$worker = new Worker();
$worker::$pidFile = $config['pid'];
$worker::$logFile = $config['log'];
$worker->name = $config['title'];
$worker->count = $config['num'];
$worker->onWorkerStart = function($worker){
    //執行一個回調函數
    call_user_func('******');
};
Worker::runAll();    

• 建立一個定時任務（支持秒級）

<?php  
use \Workerman\Worker;  
use \Workerman\Lib\Timer;  
require_once './Workerman/Autoloader.php';  

$task = new Worker();  
// 開啟多少個進程運行定時任務，注意多進程並發問題  
$task->count = 1;  
$task->onWorkerStart = function($task)  
{  
    // 每1秒執行一次 支持小數，可以精確到0.001，即精確到毫秒級別  
    $time_interval = 1;  
    Timer::add($time_interval, function()  
    {  
        echo "****\n";  
    });  
};  

Worker::runAll(); 

• php給客戶端實時發送消息

1、建立一個websocket Worker，用來維持客戶端長連接
2、websocket Worker內部建立一個text Worker
3、websocket Worker 與 text Worker是同一個進程，可以方便的共享客戶端連接
4、某個獨立的php后台系統通過text協議與text Worker通訊
5、text Worker操作websocket連接完成數據推送
push.php

<?php

use Workerman\Worker;
require_once './Workerman/Autoloader.php';
// 初始化一個worker容器，監聽1234端口
$worker = new Worker('websocket://0.0.0.0:1234');
/*
 * 注意這里進程數必須設置為1，否則會報端口占用錯誤
 * (php 7可以設置進程數大於1，前提是$inner_text_worker->reusePort=true)
*/
$worker->count = 1;
// worker進程啟動后創建一個text Worker以便打開一個內部通訊端口
$worker->onWorkerStart = function ($worker) {
    // 開啟一個內部端口，方便內部系統推送數據，Text協議格式 文本+換行符
    $inner_text_worker = new Worker('text://0.0.0.0:5678');
    $inner_text_worker->onMessage = function ($connection, $buffer) {
        // $data數組格式，里面有uid，表示向那個uid的頁面推送數據
        $data = json_decode($buffer, true);
        $uid = $data['uid'];
        // 通過workerman，向uid的頁面推送數據
        $ret = sendMessageByUid($uid, $buffer);
        // 返回推送結果
        $connection->send($ret ? 'ok' : 'fail');
    };
    // ## 執行監聽 ##
    $inner_text_worker->listen();
};
// 新增加一個屬性，用來保存uid到connection的映射
$worker->uidConnections = array();
// 當有客戶端發來消息時執行的回調函數
$worker->onMessage = function ($connection, $data) {
    global $worker;
    // 判斷當前客戶端是否已經驗證,既是否設置了uid
    if (!isset($connection->uid)) {
        // 沒驗證的話把第一個包當做uid（這里為了方便演示，沒做真正的驗證）
        $connection->uid = $data;
        /* 保存uid到connection的映射，這樣可以方便的通過uid查找connection，
         * 實現針對特定uid推送數據
        */
        $worker->uidConnections[$connection->uid] = $connection;
        return;
    }
};

// 當有客戶端連接斷開時
$worker->onClose = function ($connection) {
    global $worker;
    if (isset($connection->uid)) {
        // 連接斷開時刪除映射
        unset($worker->uidConnections[$connection->uid]);
    }
};
// 向所有驗證的用戶推送數據
function broadcast($message) {
    global $worker;
    foreach ($worker->uidConnections as $connection) {
        $connection->send($message);
    }
}
// 針對uid推送數據
function sendMessageByUid($uid, $message) {
    global $worker;
    if (isset($worker->uidConnections[$uid])) {
        $connection = $worker->uidConnections[$uid];
        $connection->send($message);
        return true;
    }
    return false;
}
// 運行所有的worker
Worker::runAll();

啟動后端服務

php push.php start -d

前端代碼

var ws = new WebSocket('ws://127.0.0.1:1234');
ws.onopen = function(){
    var uid = 'uid1';
    ws.send(uid);
};
ws.onmessage = function(e){
    alert(e.data);
};

php后台代碼

// 建立socket連接到內部推送端口
$client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1);
// 推送的數據，包含uid字段，表示是給這個uid推送
$data = array('uid'=>'uid1', 'percent'=>'88%');
// 發送數據，注意5678端口是Text協議的端口，Text協議需要在數據末尾加上換行符
fwrite($client, json_encode($data)."\n");
// 讀取推送結果
echo fread($client, 8192);

• 建立一個簡單的webserver

use \Workerman\Worker;
use \Workerman\WebServer;
require_once __DIR__ . '/Workerman/Autoloader.php';
// 這里監聽8080端口，如果要監聽80端口，需要root權限，並且端口沒有被其它程序占用
$webserver = new WebServer('http://0.0.0.0:8080');
// 類似nginx配置中的root選項，添加域名與網站根目錄的關聯，可設置多個域名多個目錄
$webserver->addRoot('www.example.com', '/your/path/of/web/');
$webserver->addRoot('blog.example.com', '/your/path/of/blog/');
// 設置開啟多少進程
$webserver->count = 4;
Worker::runAll();