Was sind die Schritte zur Verwendung von Workerman?

Erstellen Sie einen gemeinsamen DAEMON

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

Erstellen Sie eine geplante Aufgabe (unterstützt die zweite Ebene)

<?php  
use \Workerman\Worker;  
use \Workerman\Lib\Timer;  
require_once &#39;./Workerman/Autoloader.php&#39;;  
$task = new Worker();  
// 开启多少个进程运行定时任务，注意多进程并发问题  
$task->count = 1;  
$task->onWorkerStart = function($task)  
{  
    // 每1秒执行一次 支持小数，可以精确到0.001，即精确到毫秒级别  
    $time_interval = 1;  
    Timer::add($time_interval, function()  
    {  
        echo "****\n";  
    });  
};  
Worker::runAll();

PHP sendet Nachrichten in Echtzeit an den Client

1. Erstellen Sie einen Websocket-Worker, um lange Client-Verbindungen aufrechtzuerhalten.

2 Text-Worker im Worker

3. Der Websocket-Worker und der Text-Worker sind derselbe Prozess und können problemlos die Client-Verbindung teilen

4. Ein unabhängiges PHP-Backend-System kommuniziert über das Textprotokoll Text Worker-Kommunikation

5. Text Worker betreibt Websocket-Verbindung, um den Daten-Push abzuschließen

push.php

<?php
use Workerman\Worker;
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->count = 1;
// worker进程启动后创建一个text Worker以便打开一个内部通讯端口
$worker->onWorkerStart = function($worker)
{
// 开启一个内部端口，方便内部系统推送数据，Text协议格式 文本+换行符
$inner_text_worker = new Worker(&#39;text://0.0.0.0:5678&#39;);
$inner_text_worker->onMessage = function($connection, $buffer)
{
// $data数组格式，里面有uid，表示向那个uid的页面推送数据
$data = json_decode($buffer, true);
$uid = $data[&#39;uid&#39;];
// 通过workerman，向uid的页面推送数据
$ret = sendMessageByUid($uid, $buffer);
// 返回推送结果
$connection->send($ret ? &#39;ok&#39; : &#39;fail&#39;);
};
// ## 执行监听 ##
$inner_text_worker->listen();
};
// 新增加一个属性，用来保存uid到connection的映射
$worker->uidConnections = array();
// 当有客户端发来消息时执行的回调函数
$worker->onMessage = function($connection, $data)
{
global $worker;
// 判断当前客户端是否已经验证,既是否设置了uid
if(!isset($connection->uid))
{
// 没验证的话把第一个包当做uid（这里为了方便演示，没做真正的验证）
$connection->uid = $data;
/* 保存uid到connection的映射，这样可以方便的通过uid查找connection，
* 实现针对特定uid推送数据
*/
$worker->uidConnections[$connection->uid] = $connection;
return;
}
};
listen

// 当有客户端连接断开时
$worker->onClose = function($connection)
{
global $worker;
if(isset($connection->uid))
{
// 连接断开时删除映射
unset($worker->uidConnections[$connection->uid]);
}
};
// 向所有验证的用户推送数据
function broadcast($message)
{
global $worker;
foreach($worker->uidConnections as $connection)
{
$connection->send($message);
}
}
// 针对uid推送数据
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();

Back-End-Dienst starten

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连接到内部推送端口
$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);

Erstellen Sie einen einfachen Webserver

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

Die chinesische PHP-Website bietet eine große Anzahl kostenloser Workerman-Einführungs-Tutorials, zum Lernen ist jeder herzlich willkommen!

Das obige ist der detaillierte Inhalt vonWas sind die Schritte zur Verwendung von Workerman?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!