建立一個(gè)普通的DAEMON

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

建立一個(gè)定時(shí)任務(wù)（支援秒級(jí)）

<?php  
use \Workerman\Worker;  
use \Workerman\Lib\Timer;  
require_once &#39;./Workerman/Autoloader.php&#39;;  
$task = new Worker();  
// 開(kāi)啟多少個(gè)進(jìn)程運(yùn)行定時(shí)任務(wù)，注意多進(jìn)程并發(fā)問(wèn)題  
$task->count = 1;  
$task->onWorkerStart = function($task)  
{  
    // 每1秒執(zhí)行一次 支持小數(shù)，可以精確到0.001，即精確到毫秒級(jí)別  
    $time_interval = 1;  
    Timer::add($time_interval, function()  
    {  
        echo "****\n";  
    });  
};  
Worker::runAll();

php給客戶端即時(shí)發(fā)送訊息

1、建立一個(gè)websocket Worker，用來(lái)維持客戶端長(zhǎng)連線

2、websocket Worker內(nèi)部建立一個(gè)text Worker

3、websocket Worker 與text Worker是同一個(gè)進(jìn)程，可以方便的共享客戶端連線

4、某個(gè)獨(dú)立的php後臺(tái)系統(tǒng)透過(guò)text協(xié)定與text Worker通訊

5、text Worker操作websocket連線完成資料推送

push.php

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

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

啟動(dòng)後端服務(wù)

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後臺(tái)程式碼

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

#建立一個(gè)簡(jiǎn)單的webserver

use \Workerman\Worker;
use \Workerman\WebServer;
require_once __DIR__ . '/Workerman/Autoloader.php';
// 這里監(jiān)聽(tīng)8080端口，如果要監(jiān)聽(tīng)80端口，需要root權(quán)限，并且端口沒(méi)有被其它程序占用
$webserver = new WebServer('http://0.0.0.0:8080');
// 類似nginx配置中的root選項(xiàng)，添加域名與網(wǎng)站根目錄的關(guān)聯(lián)，可設(shè)置多個(gè)域名多個(gè)目錄
$webserver->addRoot('www.example.com', '/your/path/of/web/');
$webserver->addRoot('blog.example.com', '/your/path/of/blog/');
// 設(shè)置開(kāi)啟多少進(jìn)程
$webserver->count = 4;
Worker::runAll();

PHP中文網(wǎng)，有大量免費(fèi)的workerman入門教學(xué)，歡迎大家來(lái)學(xué)習(xí)！

以上是workerman使用步驟是什麼的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！