なぜこの記事を書くのか?
私はワークマンを何度か学習しましたが、毎回失敗しました(目的の機能を達成できませんでした。愚かであることを許してください)。しかし今回は、これまでに実装されていない機能の実装にも数時間かかりました。実際には、1 対 1 でメッセージを送信する機能と、メッセージをブロードキャストする (グループ チャット) という 2 つの単純な機能があります。この機能は昔から swoole で実装していましたが、私が think-worker を使いたいと思っていたからでもあります。考えてみれば、やはり自分で考えなければなりません。他の人が作ったフレームワークは去勢されているのかもしれません。バージョン。
workman は Windows で実行できるため、なぜ swoole を使用しないのかは聞かないでください。
(1) まず、thinkphp workman のインストールについて簡単に説明します。
thinkphp5.1のインストール
composer create-project topthink/think=5.1.x-dev tp5andworkman
think-workerのインストール
composer require topthink/think-worker=2.0.*
workmanを直接インストール
composer require workerman/workerman
(2) 見てみましょうit first think-worker code
config/worker_server.php
まず、メッセージをブロードキャストするサーバーの例を見てみましょう。 10 秒ごとにメッセージを定期的にブロードキャストします
'onWorkerStart' => function ($worker) { \Workerman\Lib\Timer::add(10, function()use($worker){ // 遍历当前进程所有的客户端连接,发送自定义消息 foreach($worker->connections as $connection){ $send['name'] = '系统信息'; $send['content'] = '这是一个定时任务信息'; $send['time'] = time(); $connection->send(json_encode($send)); } }); }
しかし、onMessage の間は $worker オブジェクトを取得できないため、メッセージをブロードキャストできません。
'onMessage' => function ($connection, $data) { $origin = json_decode($data,true); $send['name'] = '广播数据'; $send['content'] = $origin['content']; $message = json_encode($send); foreach($worker->connections as $connection) { $connection->send($message); } }
さまざまな方法を試しましたが、どれもうまくいきませんでした
'onMessage' => function ($connection, $data)use($worker) { // 这样是获取不到 $worker 对象的 // ...省略代码 }
したがって、thinkphp がカプセル化した think-worker フレームワークを放棄するしかなく、自分でそれを作成する (または変更する) 必要があります。フレームワークの内部コード)
フレームワーク内のコードを変更します: /vendor/topthink/think-worker/src/command/Server.php
(主に onMessage メソッドを自分で追加します)
use() つまり、内部使用のために関数に外部変数を渡すか、global $worker
$worker = new Worker($socket, $context); $worker->onMessage = function ($connection, $data)use($worker) { $origin = json_decode($data,true); $send['name'] = '广播数据'; $send['content'] = $origin['content']; $send['uid'] = $connection->uid; $message = json_encode($send); foreach($worker->connections as $connection) { $connection->send($message); } };
を使用します。このようにして、$worker を取得できます。 object
$worker->onMessage = function ($connection, $data)use($worker) { ... }
( 3) $connection は uid
にバインドされています。実際、$worker->connections が現在のすべてのユーザーの接続を取得することはすでにわかりました。 、接続もリンクの 1 つです。
Web ソケット接続時間を記録する:
$worker->onConnect = function ($connection) { $connection->login_time = time(); };
Web ソケット接続時間を取得する:
$worker->onMessage = function ($connection, $data)use($worker) { $login_time = $connection->login_time; };
$connection 接続の属性にデータをバインドできることがわかります。たとえば、 :
$connection->uid = $uid;
JavaScript 側が WebSocket サーバーに正常に接続すると、すぐにその uid をバインドのためにサーバーに送信します:
$worker->onMessage = function ($connection, $data)use($worker) { $origin = json_decode($data,true); if(array_key_exists('bind',$origin)){ $connection->uid = $origin['uid']; } };
(4) ユニキャスト メッセージ、つまりカスタム送信
$worker->onMessage = function ($connection, $data)use($worker) { $origin = json_decode($data,true); $sendTo = $origin['sendto']; // 需要发送的对方的uid $content = $origin['content']; // 需要发送到对方的内容 foreach($worker->connections as $connection) { if( $connection->uid == $sendTo){ $connection->send($content); } } };
この時点で、workman に基づいてメッセージを送信するカスタム オブジェクトが完了しました。
php ファイルはコンポーザーに保存されているため、ファイルをコピーして application/command
に配置し、名前空間を変更して独自のプロジェクトに保存するだけです
(5) swoole との比較
1. Workman は Windows システムで実行できますが、swoole は実行できません。
2. workman: $worker->connections はすべての接続を取得し、$connection->id は独自の接続 ID を取得します; swoole: $server->connections はすべての接続を取得します、$connection->fd独自の接続 ID を取得します。
3. onWorkerStart メソッドは workman の開始時に実行され、タイマーを書き込むことができます。swoole は WorkerStart を使用してタイマーを開始します。
チャットルームやタイマーならやはりワークマンの方が便利です。
ThinkPHP 関連の技術記事の詳細については、ThinkPHP の使用法チュートリアル 列にアクセスして学習してください。
以上がWorkman を使用してチャット ルームを作成するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

ホットAIツール

Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。

Undress AI Tool
脱衣画像を無料で

Clothoff.io
AI衣類リムーバー

Video Face Swap
完全無料の AI 顔交換ツールを使用して、あらゆるビデオの顔を簡単に交換できます。

人気の記事

ホットツール

SublimeText3 Linux 新バージョン
SublimeText3 Linux 最新バージョン

VSCode Windows 64 ビットのダウンロード
Microsoft によって発売された無料で強力な IDE エディター

MinGW - Minimalist GNU for Windows
このプロジェクトは osdn.net/projects/mingw に移行中です。引き続きそこでフォローしていただけます。 MinGW: GNU Compiler Collection (GCC) のネイティブ Windows ポートであり、ネイティブ Windows アプリケーションを構築するための自由に配布可能なインポート ライブラリとヘッダー ファイルであり、C99 機能をサポートする MSVC ランタイムの拡張機能が含まれています。すべての MinGW ソフトウェアは 64 ビット Windows プラットフォームで実行できます。

Dreamweaver Mac版
ビジュアル Web 開発ツール

DVWA
Damn Vulnerable Web App (DVWA) は、非常に脆弱な PHP/MySQL Web アプリケーションです。その主な目的は、セキュリティ専門家が法的環境でスキルとツールをテストするのに役立ち、Web 開発者が Web アプリケーションを保護するプロセスをより深く理解できるようにし、教師/生徒が教室環境で Web アプリケーションを教え/学習できるようにすることです。安全。 DVWA の目標は、シンプルでわかりやすいインターフェイスを通じて、さまざまな難易度で最も一般的な Web 脆弱性のいくつかを実践することです。このソフトウェアは、
