Create a common 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();

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();  
// 開啟多少個進(jìn)程運行定時任務(wù)，注意多進(jìn)程并發(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 sends messages to the client in real time

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

2. websocket Establish a text Worker inside the Worker

3. The websocket Worker and the text Worker are the same process and can easily share the client connection

4. An independent php background system communicates with the text worker through the text protocol text Worker communication

5. Text Worker operates websocket connection to complete data push

push.php

<?php
use Workerman\Worker;
require_once &#39;./Workerman/Autoloader.php&#39;;
// 初始化一個worker容器，監(jiān)聽1234端口
$worker = new Worker(&#39;websocket://0.0.0.0:1234&#39;);
/*
* 注意這里進(jìn)程數(shù)必須設(shè)置為1，否則會報端口占用錯誤
* (php 7可以設(shè)置進(jìn)程數(shù)大于1，前提是$inner_text_worker->reusePort=true)
*/
$worker->count = 1;
// worker進(jìn)程啟動后創(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(&#39;text://0.0.0.0:5678&#39;);
$inner_text_worker->onMessage = function($connection, $buffer)
{
// $data數(shù)組格式，里面有uid，表示向那個uid的頁面推送數(shù)據(jù)
$data = json_decode($buffer, true);
$uid = $data[&#39;uid&#39;];
// 通過workerman，向uid的頁面推送數(shù)據(jù)
$ret = sendMessageByUid($uid, $buffer);
// 返回推送結(jié)果
$connection->send($ret ? &#39;ok&#39; : &#39;fail&#39;);
};
// ## 執(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();

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 back-end code

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

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選項，添加域名與網(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è)置開啟多少進(jìn)程
$webserver->count = 4;
Worker::runAll();

PHP中文網(wǎng), there are a large number of free workerman introductory tutorials, everyone is welcome to learn!

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