Workerman是一個異步事件驅(qū)動的PHP框架，具有高性能，可輕松構(gòu)建快速，可擴展的網(wǎng)絡(luò)應(yīng)用程序。支持HTTP，Websocket，SSL和其他自定義協(xié)議。

怎么使用workerman？

要求

PHP 5.3或更高版本

安裝

下載后解壓即可

地址：https://www.workerman.net/download

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){     //執(zhí)行一個回調(diào)函數(shù)     call_user_func('******'); }; Worker::runAll();

建立一個定時任務(wù)（支持秒級）

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

php給客戶端實時發(fā)送消息

1、建立一個websocket Worker，用來維持客戶端長連接

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

3、websocket Worker 與 text Worker是同一個進程，可以方便的共享客戶端連接

4、某個獨立的php后臺系統(tǒng)通過text協(xié)議與text Worker通訊

5、text Worker操作websocket連接完成數(shù)據(jù)推送

push.php

<?php use WorkermanWorker; require_once './Workerman/Autoloader.php'; // 初始化一個worker容器，監(jiān)聽1234端口 $worker = new Worker('websocket://0.0.0.0:1234'); /* * 注意這里進程數(shù)必須設(shè)置為1，否則會報端口占用錯誤 * (php 7可以設(shè)置進程數(shù)大于1，前提是$inner_text_worker->reusePort=true) */ $worker->count = 1; // worker進程啟動后創(chuàng)建一個text Worker以便打開一個內(nèi)部通訊端口 $worker->onWorkerStart = function($worker) { // 開啟一個內(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，表示向那個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(); }; // 新增加一個屬性，用來保存uid到connection的映射 $worker->uidConnections = array(); // 當(dāng)有客戶端發(fā)來消息時執(zhí)行的回調(diào)函數(shù) $worker->onMessage = function($connection, $data) { global $worker; // 判斷當(dāng)前客戶端是否已經(jīng)驗證,既是否設(shè)置了uid if(!isset($connection->uid)) { // 沒驗證的話把第一個包當(dāng)做uid（這里為了方便演示，沒做真正的驗證） $connection->uid = $data; /* 保存uid到connection的映射，這樣可以方便的通過uid查找connection， * 實現(xiàn)針對特定uid推送數(shù)據(jù) */ $worker->uidConnections[$connection->uid] = $connection; return; } }; listen  // 當(dāng)有客戶端連接斷開時 $worker->onClose = function($connection) { global $worker; if(isset($connection->uid)) { // 連接斷開時刪除映射 unset($worker->uidConnections[$connection->uid]); } }; // 向所有驗證的用戶推送數(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; } // 運行所有的worker Worker::runAll();

啟動后端服務(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后臺代碼

// 建立socket連接到內(nèi)部推送端口 $client = stream_socket_client('tcp://127.0.0.1:5678', $errno, $errmsg, 1); // 推送的數(shù)據(jù)，包含uid字段，表示是給這個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);

建立一個簡單的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選項，添加域名與網(wǎng)站根目錄的關(guān)聯(lián)，可設(shè)置多個域名多個目錄 $webserver->addRoot('www.example.com', '/your/path/of/web/'); $webserver->addRoot('blog.example.com', '/your/path/of/blog/'); // 設(shè)置開啟多少進程 $webserver->count = 4; Worker::runAll();

Workerman支持的特性

1. 純PHP開發(fā)，多進程支持，支持php7，支持hhvm

2. 支持TCP/UDP，單機可支持數(shù)百萬以上TCP長連接

3. 支持分布式部署，集群能支持數(shù)百萬甚至更高的并發(fā)TCP連接

4. 支持libevent事件觸發(fā)網(wǎng)絡(luò)庫

5. 支持熱更新及服務(wù)器平滑重啟

6. 擁有異步Mysql、Redis、Dns等眾多高性能組件

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