Workerman is an asynchronous event-driven PHP framework with high performance, making it easy to build fast, scalable web applications. Supports HTTP, Websocket, SSL and other custom protocols.

How to use workerman?

Requires

PHP 5.3 or higher

Installation

After downloading, unzip it

Address: https://www.workerman.net/download

##workerman usage steps

Create an ordinary 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();

Create a scheduled task (supports second level)

<?php  
use \Workerman\Worker;  
use \Workerman\Lib\Timer;  
require_once &#39;./Workerman/Autoloader.php&#39;;  
$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 sends messages to the client in real time

1. Create a websocket Worker to maintain a long client connection

2. Create a text Worker inside the websocket Worker

3. Websocket Worker and text Worker are the same process and can easily share client connections

4. An independent php backend system communicates with text Worker through text protocol

5. text Worker operates websocket connection to complete data push

push.php

<?php
use Workerman\Worker;
require_once &#39;./Workerman/Autoloader.php&#39;;
// 初始化一個(gè)worker容器，監(jiān)聽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以便打開一個(gè)內(nèi)部通訊端口
$worker->onWorkerStart = function($worker)
{
// 開啟一個(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)聽 ##
$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))
{
// 沒驗(yàn)證的話把第一個(gè)包當(dāng)做uid（這里為了方便演示，沒做真正的驗(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)有客戶端連接斷開時(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);
}
}
// 針對(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();

Start back-end service

php push.php start -d

Front-end code

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 backend code

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

Build a simple webserver

use \Workerman\Worker;
use \Workerman\WebServer;
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();

Features supported by Workerman

1. Pure PHP development, multi-process support, support php7, support hhvm

2. Support TCP/UDP, stand-alone Supports more than millions of TCP persistent connections

3. Supports distributed deployment, and the cluster can support millions or even higher concurrent TCP connections

4. Supports libevent event-triggered network library

5. Supports hot updates and smooth server restart

6. Has many high-performance components such as asynchronous Mysql, Redis, Dns, etc.

PHP Chinese website has a large number of free

workerman introductory tutorials, everyone is welcome to learn!

The above is the detailed content of How to use workerman?. For more information, please follow other related articles on the PHP Chinese website!