怎么使用workerman？

$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 WorkermanWorker;   use WorkermanLibTimer;   require_once &#39;./Workerman/Autoloader.php&#39;;   $task = new Worker();   // 開啟多少個進程運行定時任務，注意多進程并發問題   $task->count?=?1;?? $task-&gt;onWorkerStart?=?function($task)?? {?? ????//?每1秒執行一次?支持小數，可以精確到0.001，即精確到毫秒級別?? ????$time_interval?=?1;?? ????Timer::add($time_interval,?function()?? ????{?? ????????echo?"****n";?? ????});?? };?? Worker::runAll();

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

//?建立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);

use?WorkermanWorker; use?WorkermanWebServer; 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();