この記事では、workerman について紹介し、workerman でのワーカー クラスの使用法について説明します。一定の参考値があるので、困っている友達が参考になれば幸いです。
関連する推奨事項: 「workerman チュートリアル 」
workerman とは何ですか?
Workerman は、オープンソースの高性能非同期 PHP ソケット インスタント メッセージング フレームワークです。高い同時実行性と超高い安定性をサポートし、モバイル アプリ、モバイル通信、WeChat アプレット、モバイル ゲーム サーバー、オンライン ゲーム、PHP チャット ルーム、ハードウェア通信、スマート ホーム、車両のインターネット、モノのインターネットなどの分野で広く使用されています。 。 発達。 TCP の長い接続をサポートし、Websocket、HTTP およびその他のプロトコルをサポートし、カスタム プロトコルをサポートします。非同期 Mysql、非同期 Redis、非同期 Http、MQTT IoT クライアント、非同期メッセージ キューなど、多くの高性能コンポーネントを備えています。
公式サイト: https://www.workerman.net/
workerman の特徴
純粋な PHP 開発
PHP マルチプロセスをサポート
TCP をサポート、UDP
長時間接続をサポート
さまざまなアプリケーション層プロトコルをサポート
高同時実行をサポート
スムーズなサービスの再起動をサポート
HHVM
指定されたユーザーとして子プロセスの実行をサポート
モニタリングが付属
ミリ秒レベルのタイマーをサポート
非同期 IO をサポート
オブジェクトまたはリソースの永続的な保持をサポート
高パフォーマンス
分散展開をサポート
ハートビート検出をサポート
ワーカーマン アプリケーション シナリオ
をインストールします。 2. events または libevent 拡張機能をインストールすることをお勧めしますが、必須ではありません (event 拡張機能に注意してください)拡張機能には PHP>=5.4 が必要です)
未満です wget http://pecl.php .net/get/libevent-0.1.0.tgz
/user/local/php/bin/phpize
./configure --with-php-config=/usr/local/php/bin/php-config
make && make install
workerman の簡単な開発デモ
簡単な http サーバーを実装する
workerman の簡単な開発デモrequire_once 'workman/Autoloader.php';
use \Workerman\Worker;
$http_work = new Worker('http://0.0.0.0:1111’);
$http_work->onMessage = function($conn,$data){
$conn->send('hello workman');
};
Worker::runAll();
浏览器 访问 ip:1111 即可
WebSocket を実装するws.phprequire_once 'workman/Autoloader.php';
use \Workerman\Worker;
$http_work = new Worker('websocket://0.0.0.0:2222');
$http_work->onMessage = function($conn,$data){
$conn->send('hello workman'.$data);
};
Worker::runAll();
<!DOCTYPE HTML>
<html>
<body>
<script>
ws = new WebSocket("ws://192.168.113.136:2222");
ws.onopen = function(){
ws.send('lampol');
}
ws.onmessage = function(e){
console.log(e.data)
}
</script>
</body>
</html>workermanPrinciple
Workerクラスはポート監視を実現するクラスであり、クライアント接続イベント、接続メッセージイベント、接続切断イベントのコールバック関数を設定して業務処理を実現できます。
count
プロセスを開始する現在の Worker インスタンスの数を設定します。設定されていない場合、デフォルトは 1 です。 このプロパティを有効にするには、Worker::runAll(); を実行する前に設定する必要があります。 Windows システムはこの機能をサポートしていません。 プロセス数設定の根拠: 1. CPU コアの数2. メモリ サイズ3. ビジネスが IO かどうか-集中型または CPU 集中型どちらのタイプのビジネスを好むかわからない場合は、プロセス数を CPU コア数の約 2 倍に設定できます。 lscpu top 1 CPUコア数の確認id
当前worker进程的id编号，范围为0到$worker->count-1。进程重启后id编号值是不变的。
name
设置当前Worker实例的名称，方便运行status命令时识别进程。不设置时默认为none。
protocol
设置当前Worker实例的协议类。
transport
设置当前Worker实例所使用的传输层协议，目前只支持3种(tcp、udp、ssl)。不设置默认为tcp。
daemonize
此属性为全局静态属性，表示是否以daemon(守护进程)方式运行。如果启动命令使用了 -d参数，则该属性会自动设置为true。也可以代码中手动设置。
logFile
用来指定workerman日志文件位置。此文件记录了workerman自身相关的日志，包括启动、停止等。
Worker::$logFile = '/tmp/workerman.log’;
stdoutFile
此属性为全局静态属性，如果以守护进程方式(-d启动)运行，则所有向终端的输出(echo var_dump等)都会被重定向到stdoutFile指定的文件中。
Worker::$stdoutFile = 'test.log’;
pidFile
如果无特殊需要，建议不要设置此属性
Worker::$pidFile = '/var/run/workerman.pid’;
user
设置当前Worker实例以哪个用户运行。此属性只有当前用户为root时才能生效。不设置时默认以当前用户运行。
建议$user设置权限较低的用户，例如www-data、apache、nobody等。
connections
array(id=>connection, id=>connection, ...)
此属性中存储了当前进程的所有的客户端连接对象，其中id为connection的id编号
reloadable
设置当前Worker实例是否可以reload，即收到reload信号后是否退出重启。不设置默认为true，收到reload信号后自动重启进程。
reusePort
设置当前worker是否开启监听端口复用(socket的SO_REUSEPORT选项)，默认为false，不开启。
globalEvent
此属性为全局静态属性，为全局的eventloop实例，可以向其注册文件描述符的读写事件或者信号事件。
Worker类回调属性
onWorkerStart
设置Worker子进程启动时的回调函数，每个子进程启动时都会执行。
回掉函数参数 $worker Worker 对象
$worker->onWorkerStart = function($worker){
//代码
};
$worker->onWorkerStart = 'test’;
function test($worker){
echo 'hhhhh';
}onConnect
当客户端与Workerman建立连接时(TCP三次握手完成后)触发的回调函数。每个连接只会触发一次onConnect回调。
回调函数的参数
$connection
连接对象，即TcpConnection实例，用于操作客户端连接，如发送数据，关闭连接等
$worker->onConnect = function($connection){
echo 'new connect....'.$connection->getRemoteIp();
};onMessage
当客户端通过连接发来数据时(Workerman收到数据时)触发的回调函数
回调函数的参数
$connection
连接对象，即TcpConnection实例，用于操作客户端连接，如发送数据，关闭连接等
$data
客户端连接上发来的数据，如果Worker指定了协议，则$data是对应协议decode（解码）了的数据
$worker->onMessage = function($connection,$data){
echo $data;
$connection->send('hello '.$data.PHP_EOL);
};onClose
当客户端连接与Workerman断开时触发的回调函数。不管连接是如何断开的，只要断开就会触发onClose。每个连接只会触发一次onClose。由于断网或者断电等极端情况断开的连接 ，也就无法及时触发onClose，这种情况需要通过应用层心跳来解决
$worker->onClose = function($connection){
echo 'connection close';
};onError
当客户端的连接上发生错误时触发。
目前错误类型有
1、调用Connection::send由于客户端连接断开导致的失败（紧接着会触发onClose回调） (code:WORKERMAN_SEND_FAIL msg:client closed)
2、在触发onBufferFull后(发送缓冲区已满)，仍然调用Connection::send，并且发送缓冲区仍然是满的状态导致发送失败(不会触发onClose回调)(code:WORKERMAN_SEND_FAIL msg:send buffer full and drop package)
3、使用AsyncTcpConnection异步连接失败时(紧接着会触发onClose回调) (code:WORKERMAN_CONNECT_FAIL msg:stream_socket_client返回的错误消息)
onWorkerReload
此特性不常用到。
设置Worker收到reload信号后执行的回调。
可以利用onWorkerReload回调做很多事情，例如在不需要重启进程的情况下重新加载业务配置文件。
onBufferFull
每个连接都有一个单独的应用层发送缓冲区，如果客户端接收速度小于服务端发送速度，数据会在应用层缓冲区暂存，如果缓冲区满则会触发onBufferFull回调。
缓冲区大为TcpConnection::$maxSendBufferSize，默认值为1MB，可以为当前连接动态设置缓冲区大小例
onBufferDrain
每个连接都有一个单独的应用层发送缓冲区，缓冲区大小由TcpConnection::$maxSendBufferSize决定，默认值为1MB，可以手动设置更改大小，更改后会对所有连接生效。
Worker类接口方法
runAll
运行所有Worker实例。
Worker::runAll()执行后将永久阻塞，也就是说位于Worker::runAll()后面的代码将不会被执行。所有Worker实例化应该都在Worker::runAll()前进行。
stopAll
停止当前进程（子进程）的所有Worker实例并退出。
此方法用于安全退出当前子进程，作用相当于调用exit/die退出当前子进程。
listen
用于实例化Worker后执行监听。
Worker类代码流程分析
public function __construct($socket_name = '', $context_option = array())
public static function runAll()
{
static::checkSapiEnv(); //检测命令行模式
static::init(); //初始化日志 pid workid…
static::lock(); //启动文件 加锁 独占锁
static::parseCommand(); //解析命令 start stop restart …
static::daemonize(); //守护进程运行
static::initWorkers(); //初始化 所有worker 实例
static::installSignal(); //安装信号
static::saveMasterPid(); //保存主进程id
static::unlock(); //解锁
static::displayUI(); //展示UI
static::forkWorkers(); //fork 进程
static::resetStd(); //重置输入输出
static::monitorWorkers(); //主进程监控各个worker的状态
}SAPI（Server Application Programming Interface）服务器应用程序编程接口，即PHP与其他应用交互的接口，PHP脚本要执行有很多方式，通过Web服务器，或者直接在命令行下，也可以嵌入在其他程序中。
常见的SAPI有：cgi、fast-cgi、cli、apache模块的DLL、isapi
Linux 常用SIG信号及其键值
01 SIGHUP 挂起（hangup）
02 SIGINT 中断，当用户从键盘按^c键或^break键时
03 SIGQUIT 退出，当用户从键盘按quit键时
04 SIGILL 非法指令
05 SIGTRAP 跟踪陷阱（trace trap），启动进程，跟踪代码的执行
06 SIGIOT IOT指令
07 SIGEMT EMT指令
08 SIGFPE 浮点运算溢出
09 SIGKILL 杀死、终止进程
10 SIGBUS 总线错误
11 SIGSEGV 段违例（segmentation violation），进程试图去访问其虚地址空间以外的位置
12 SIGSYS 系统调用中参数错，如系统调用号非法
13 SIGPIPE 向某个非读管道中写入数据
14 SIGALRM 闹钟。当某进程希望在某时间后接收信号时发此信号
15 SIGTERM 软件终止（software termination）
16 SIGUSR1 用户自定义信号1
17 SIGUSR2 用户自定义信号2
18 SIGCLD 某个子进程死
更多计算机编程相关知识，请访问：编程视频！！
以上がworkerman でのワーカー クラスの使用法に関する簡単な説明の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
Workermanの組み込みWebsocketクライアントの主な機能は何ですか？Mar 18, 2025 pm 04:20 PMWorkermanのWebSocketクライアントは、非同期通信、高性能、スケーラビリティ、セキュリティなどの機能とのリアルタイム通信を強化し、既存のシステムと簡単に統合します。
リアルタイムのコラボレーションツールを構築するためにWorkermanを使用する方法は？Mar 18, 2025 pm 04:15 PMこの記事では、リアルタイムのコラボレーションツールを構築するために、高性能PHPサーバーであるWorkermanを使用して説明します。インストール、サーバーのセットアップ、リアルタイム機能の実装、既存のシステムとの統合をカバーし、Workermanのキーfを強調します
低遅延アプリケーションのためにWorkermanを最適化する最良の方法は何ですか？Mar 18, 2025 pm 04:14 PMこの記事では、非同期プログラミング、ネットワーク構成、リソース管理、データ転送の最小化、負荷分散、定期的な更新に焦点を当てた低遅延アプリケーションのWorkermanの最適化について説明します。
WorkermanおよびMySQLとのリアルタイムデータの同期を実装する方法は？Mar 18, 2025 pm 04:13 PMこの記事では、WorkermanとMySQLを使用したリアルタイムデータ同期の実装、セットアップ、ベストプラクティス、データの一貫性の確保、一般的な課題への対処に焦点を当てています。
サーバーレスアーキテクチャでWorkermanを使用するための重要な考慮事項は何ですか？Mar 18, 2025 pm 04:12 PMこの記事では、Swaremanをサーバーレスアーキテクチャに統合し、スケーラビリティ、ステートレス性、コールドスタート、リソース管理、統合の複雑さに焦点を当てています。 Workermanは、高い並行性を通じてパフォーマンスを向上させ、Cold STAを減らします
Workermanで高性能のeコマースプラットフォームを構築する方法は？Mar 18, 2025 pm 04:11 PMこの記事では、Workermanを使用して高性能のeコマースプラットフォームの構築について説明し、Websocketのサポートやスケーラビリティなどの機能に焦点を当て、リアルタイムの相互作用と効率を向上させます。
WorkermanのWebsocketサーバーの高度な機能は何ですか？Mar 18, 2025 pm 04:08 PMWorkermanのWebSocketサーバーは、一般的な脅威に対するスケーラビリティ、低レイテンシ、セキュリティ対策などの機能とのリアルタイム通信を強化します。
リアルタイム分析ダッシュボードを構築するためにWorkermanを使用する方法は？Mar 18, 2025 pm 04:07 PMこの記事では、高性能PHPサーバーであるWorkermanを使用して、リアルタイム分析ダッシュボードを構築することについて説明します。これは、React、Vue.JS、Angularなどのフレームワークとのインストール、サーバーのセットアップ、データ処理、フロントエンドの統合をカバーしています。キーfeatur
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
ホットツール
VSCode Windows 64 ビットのダウンロード
Microsoft によって発売された無料で強力な IDE エディター
DVWA
Damn Vulnerable Web App (DVWA) は、非常に脆弱な PHP/MySQL Web アプリケーションです。その主な目的は、セキュリティ専門家が法的環境でスキルとツールをテストするのに役立ち、Web 開発者が Web アプリケーションを保護するプロセスをより深く理解できるようにし、教師/生徒が教室環境で Web アプリケーションを教え/学習できるようにすることです。安全。 DVWA の目標は、シンプルでわかりやすいインターフェイスを通じて、さまざまな難易度で最も一般的な Web 脆弱性のいくつかを実践することです。このソフトウェアは、
SublimeText3 Linux 新バージョン
SublimeText3 Linux 最新バージョン
ドリームウィーバー CS6
ビジュアル Web 開発ツール
MantisBT
Mantis は、製品の欠陥追跡を支援するために設計された、導入が簡単な Web ベースの欠陥追跡ツールです。 PHP、MySQL、Web サーバーが必要です。デモおよびホスティング サービスをチェックしてください。
