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();