站長資訊網(wǎng)Workerman是一個(gè)異步事件驅(qū)動(dòng)的PHP框架，具有高性能，可輕松構(gòu)建快速，可擴(kuò)展的網(wǎng)絡(luò)應(yīng)用程序。支持HTTP，Websocket，SSL和其他自定義協(xié)議。
怎么使用workerman？
要求
PHP 5.3或更高版本
安裝
下載后解壓即可
地址：https://www.workerman.net/download
workerman使用步驟
建立一個(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 WorkermanWorker; use WorkermanLibTimer; require_once './Workerman/Autoloader.php'; $task = new Worker(); // 開啟多少個(gè)進(jìn)程運(yùn)行定時(shí)任務(wù)，注意多進(jìn)程并發(fā)問題 $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í)時(shí)發(fā)送消息
1、建立一個(gè)websocket Worker，用來維持客戶端長連接
2、websocket Worker內(nèi)部建立一個(gè)text Worker
3、websocket Worker 與 text Worker是同一個(gè)進(jìn)程，可以方便的共享客戶端連接
4、某個(gè)獨(dú)立的php后臺(tái)系統(tǒng)通過text協(xié)議與text Worker通訊
5、text Worker操作websocket連接完成數(shù)據(jù)推送
push.php
<?php use WorkermanWorker; require_once './Workerman/Autoloader.php'; // 初始化一個(gè)worker容器，監(jiān)聽1234端口 $worker = new Worker('websocket://0.0.0.0:1234'); /* * 注意這里進(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以便打開一個(gè)內(nèi)部通訊端口 $worker->onWorkerStart = function($worker) { // 開啟一個(gè)內(nèi)部端口，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)，Text協(xié)議格式 文本+換行符 $inner_text_worker = new Worker('text://0.0.0.0:5678'); $inner_text_worker->onMessage = function($connection, $buffer) { // $data數(shù)組格式，里面有uid，表示向那個(gè)uid的頁面推送數(shù)據(jù) $data = json_decode($buffer, true); $uid = $data['uid']; // 通過workerman，向uid的頁面推送數(shù)據(jù) $ret = sendMessageByUid($uid, $buffer); // 返回推送結(jié)果 $connection->send($ret ? 'ok' : 'fail'); }; // ## 執(zhí)行監(jiān)聽 ## $inner_text_worker->listen(); }; // 新增加一個(gè)屬性，用來保存uid到connection的映射 $worker->uidConnections = array(); // 當(dāng)有客戶端發(fā)來消息時(shí)執(zhí)行的回調(diào)函數(shù) $worker->onMessage = function($connection, $data) { global $worker; // 判斷當(dāng)前客戶端是否已經(jīng)驗(yàn)證,既是否設(shè)置了uid if(!isset($connection->uid)) { // 沒驗(yàn)證的話把第一個(gè)包當(dāng)做uid（這里為了方便演示，沒做真正的驗(yàn)證） $connection->uid = $data; /* 保存uid到connection的映射，這樣可以方便的通過uid查找connection， * 實(shí)現(xiàn)針對特定uid推送數(shù)據(jù) */ $worker->uidConnections[$connection->uid] = $connection; return; } }; listen // 當(dāng)有客戶端連接斷開時(shí) $worker->onClose = function($connection) { global $worker; if(isset($connection->uid)) { // 連接斷開時(shí)刪除映射 unset($worker->uidConnections[$connection->uid]); } }; // 向所有驗(yàn)證的用戶推送數(shù)據(jù) function broadcast($message) { global $worker; foreach($worker->uidConnections as $connection) { $connection->send($message); } } // 針對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è)簡單的webserver
use WorkermanWorker; use WorkermanWebServer; require_once __DIR__ . '/Workerman/Autoloader.php'; // 這里監(jiān)聽8080端口，如果要監(jiān)聽80端口，需要root權(quán)限，并且端口沒有被其它程序占用 $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è)置開啟多少進(jìn)程 $webserver->count = 4; Worker::runAll();
Workerman支持的特性
-
純PHP開發(fā)，多進(jìn)程支持，支持php7，支持hhvm
-
支持TCP/UDP，單機(jī)可支持?jǐn)?shù)百萬以上TCP長連接
-
支持分布式部署，集群能支持?jǐn)?shù)百萬甚至更高的并發(fā)TCP連接
-
支持libevent事件觸發(fā)網(wǎng)絡(luò)庫
-
支持熱更新及服務(wù)器平滑重啟
-
擁有異步Mysql、Redis、Dns等眾多高性能組件
PHP中文網(wǎng)，有大量免費(fèi)的workerman入門教程，歡迎大家學(xué)習(xí)！
