例1
(要求Workermanバージョン>=3.3.0)
Workerベースのマルチプロセスグループプッシュシステム
use Workerman\Worker;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
$channel_server = new Channel\Server('0.0.0.0', 2206);
$worker = new Worker('websocket://0.0.0.0:1234');
$worker->count = 8;
// グローバルグループと接続のマッピング配列
$group_con_map = array();
$worker->onWorkerStart = function(){
// ChannelクライアントがChannelサーバーに接続
Channel\Client::connect('127.0.0.1', 2206);
// グローバルグループへのメッセージ送信イベントをリッスン
Channel\Client::on('send_to_group', function($event_data){
$group_id = $event_data['group_id'];
$message = $event_data['message'];
global $group_con_map;
var_dump(array_keys($group_con_map));
if (isset($group_con_map[$group_id])) {
foreach ($group_con_map[$group_id] as $con) {
$con->send($message);
}
}
});
};
$worker->onMessage = function(TcpConnection $con, $data){
// グループ参加メッセージ{"cmd":"add_group", "group_id":"123"}
// または グループメッセージ{"cmd":"send_to_group", "group_id":"123", "message":"このメッセージです"}
$data = json_decode($data, true);
var_dump($data);
$cmd = $data['cmd'];
$group_id = $data['group_id'];
switch($cmd) {
// 接続してグループに参加する
case "add_group":
global $group_con_map;
// 接続を対応するグループ配列に追加
$group_con_map[$group_id][$con->id] = $con;
// この接続がどのグループに参加しているかを記録し、onclose時にgroup_con_mapの対応グループのデータをクリーンアップする
$con->group_id = isset($con->group_id) ? $con->group_id : array();
$con->group_id[$group_id] = $group_id;
break;
// グループにメッセージを送信する
case "send_to_group":
// Channel\Clientがすべてのサーバーのすべてのプロセスにグループメッセージ送信イベントをブロードキャスト
Channel\Client::publish('send_to_group', array(
'group_id'=>$group_id,
'message'=>$data['message']
));
break;
}
};
// ここが重要です、接続が閉じるときに接続をグローバルグループデータから削除し、メモリリークを回避する
$worker->onClose = function(TcpConnection $con){
global $group_con_map;
// 接続が参加しているすべてのグループを処理し、group_con_mapから対応するデータを削除
if (isset($con->group_id)) {
foreach ($con->group_id as $group_id) {
unset($group_con_map[$group_id][$con->id]);
if (empty($group_con_map[$group_id])) {
unset($group_con_map[$group_id]);
}
}
}
};
Worker::runAll();テスト （すべてローカルホスト127.0.0.1で実行するものと仮定）
1、サーバーを実行する
php start.php start
Workerman[del.php] DEBUGモードでスタート
----------------------- WORKERMAN -----------------------------
Workermanバージョン:3.4.2 PHPバージョン:7.1.3
------------------------ WORKERS -------------------------------
ユーザー ワーカー リッスン プロセス 状態
liliang ChannelServer frame://0.0.0.0:2206 1 [OK]
liliang none websocket://0.0.0.0:1234 12 [OK]
----------------------------------------------------------------
終了するにはCtrl-Cを押してください。スタート成功。
2、クライアントがサーバーに接続する
Chromeブラウザを開き、F12キーを押してデベロッパーツールを開き、Console欄に入力する（または以下のコードをHTMLページに入れてJSを実行）
// サーバーIPが127.0.0.1であると仮定し、テスト時には実際のサーバーIPに変更してください
ws = new WebSocket('ws://127.0.0.1:1234');
ws.onmessage = function(data){console.log(data.data)};
ws.onopen = function() {
ws.send('{"cmd":"add_group", "group_id":"123"}');
ws.send('{"cmd":"send_to_group", "group_id":"123", "message":"このメッセージです"}');
};