Think-Swoole の WebSocket-Room がルームに参加、退出し、ルーム メッセージを送信します
Think-Swoole 3.0 では Websocket に Room チャット ルーム機能が追加されました。これは主にグループ メッセージングに使用されますが、異なる Room 間のメッセージは互いに分離されます。チャット ルームに入ると、このチャット ルームの fd のみが、入力、退出、送信したメッセージを受信できます。
config.swoole.php
'websocket' => [
'enable' => true,
'handler' => Handler::class,
'parser' => Parser::class,
'ping_interval' => 25000,
'ping_timeout' => 60000,
'room' => [
'type' => 'table',
'table' => [
'room_rows' => 4096,
'room_size' => 2048,
'client_rows' => 8192,
'client_size' => 2048,
],
'redis' => [
'host' => '127.0.0.1',
'port' => 6379,
'max_active' => 3,
'max_wait_time' => 5,
],
],
'listen' => [],
'subscribe' => [],
],ルーム設定項目があり、その中の種類はどのようなデータ処理方法を使用しているかを示しており、以下の「table」と「redis」の2種類があります。表は直接使用できますが、redis を使用するにはシステムとプロジェクトに redis 拡張機能がインストールされている必要があります。 table は、異なるプロセス間でデータを共有できる、高性能のクロスプロセス メモリ処理サービスです。
イベントの作成
プロジェクト ルート ディレクトリに次のコマンドを入力して、ルーム参加イベント、ルーム退出イベント、ルーム チャット イベントをそれぞれ作成します。 # 次に、app/event.php でイベントを定義します。
php think make:listener WsJoin php think make:listener WsLeave php think make:listener RoomTest
Join、Leave、RoomTest などの上記の名前はすべてカスタマイズされており、フロントエンドによって送信されるメッセージのシーン値に対応する必要があります。
もちろん、config/swoole.php設定ファイルのwebsocket listenでもイベント定義を設定することができますので、詳しくは前回の記事を参照してください。
H5 WebSocker クライアント接続wsroot.html
[
],
'listen' => [
'AppInit' => [],
'HttpRun' => [],
'HttpEnd' => [],
'LogLevel' => [],
'LogWrite' => [],
//监听连接，swoole 事件必须以 swoole 开头
'swoole.websocket.Connect' => [
app\listener\WsConnect::class
],
//监听关闭
'swoole.websocket.Close' => [
\app\listener\WsClose::class
],
//监听 Test 场景
'swoole.websocket.Test' => [
\app\listener\WsTest::class
],
//加入房间事件
'swoole.websocket.Join' => [
\app\listener\WsJoin::class
],
//离开房间事件
'swoole.websocket.Leave' => [
\app\listener\WsLeave::class
],
//处理聊天室消息
'swoole.websocket.RoomTest' => [
\app\listener\RoomTest::class
],
],
'subscribe' => [
],
];ioroomtest.html
<!DOCTYPE HTML>
<html>
<head>
<meta charset="UTF-8">
<title>Document</title>
</head>
<body>
<button onclick="join()">加入房间</button>
<button onclick="leave()">离开房间</button>
<input type="text" id="message">
<button onclick="send()">发送</button>
<script>
var ws = new WebSocket("ws://127.0.0.1:9501/?uid=1");
ws.onopen = function(){
console.log('连接成功');
}
//数据返回的解析
function mycallback(data){
var start = data.indexOf('[') // 第一次出现的位置
var start1 = data.indexOf('{')
if(start < 0){
start = start1;
}
if(start >= 0 && start1 >= 0){
start = Math.min(start,start1);
}
if(start >= 0){
console.log(data);
var json = data.substr(start); //截取
var json = JSON.parse(json);
console.log(json);
// if(json instanceof Array){
// window[json[0]](json[1]);
// }
}
}
function sendfd($message){
console.log($message)
}
function testcallback($message){
console.log($message)
}
function joincallback($message){
// console.log($message)
console.log(11);
}
function leavecallback($message){
console.log($message)
}
ws.onmessage = function(data){
// console.log(data.data);
mycallback(data.data);
}
ws.onclose = function(){
console.log('连接断开');
}
function join()
{
var room = prompt('请输入房间号');
ws.send(JSON.stringify(['join',{
room:room
}])); //发送的数据必须是 ['test',数据] 这种格式
}
function leave()
{
var room = prompt('请输入要离开的房间号');
ws.send(JSON.stringify(['leave',{
room:room
}])); //发送的数据必须是 ['test',数据] 这种格式
}
function send()
{
var message = document.getElementById('message').value;
var room = prompt('请输入接收消息的房间号')
ws.send(JSON.stringify(['RoomTest',{
message:message,
room:room
}])); //发送的数据必须是 ['test',数据] 这种格式
}
</script>
</body>
</html>このページでは、join()、leave()、send() 関数で定義されているシーンの値は、それぞれ join、leave、RoomTest であり、app/leave.php で定義しています。これらのシーン値はイベントに対応するため、それぞれ WsJoin.php、WsLeave.php、RoomTest.php イベントをトリガーします。
バックエンド イベントの書き込みapp/listener/WsJoin.php
<!DOCTYPE HTML>
<html>
<head>
<meta charset="UTF-8">
<title>Document</title>
</head>
<body>
<button onclick="join()">加入房间</button>
<button onclick="leave()">离开房间</button>
<input type="text" id="message">
<button onclick="send()">发送</button>
<script src="./socketio.js"></script>
<script>
//http 协议
var socket = io("http://127.0.0.1:9501?uid=1", {transports: ['websocket']});
socket.on('connect', function(){
console.log('connect success');
});
socket.on('close',function(){
console.log('connect close')
});
//send_fd 为自定义的场景值，和后端对应
socket.on("sendfd", function (data) {
console.log(data)
});
//testcallback 为自定义的场景值，和后端对应
socket.on("testcallback", function (data) {
console.log(data)
});
socket.on("joincallback", function (data) {
console.log(data)
});
socket.on("roomtestcallback", function (data) {
console.log(data)
});
function join()
{
var room = prompt('请输入房间号');
socket.emit('join',{
room : room
});
}
function leave()
{
var room = prompt('请输入要离开的房间号');
socket.emit('leave',{
room : room
});
}
function send()
{
var message = document.getElementById('message').value;
var room = prompt('请输入接收消息的房间号')
socket.emit('RoomTest',{
message : message,
room : room
});
}
</script>
</body>
</html>app/listener/WsLeave.php
<?php
declare (strict_types = 1);
namespace app\listener;
class WsJoin
{
/**
* 事件监听处理
*
* @return mixed
*/
public function handle($event)
{
$ws = app('think\swoole\Websocket');
$roomobj = app('think\swoole\websocket\Room');
//当前客户端加入指定 Room
$ws -> join($event['room']);
//同时加入多个房间
// $ws -> join(['room1','room2']);
//指定客户端加入指定 room
// $ws -> setSender(2) -> join($event['room']);
//获取当前房间所有的 fd
$getAllFdInRoom = $roomobj -> getClients($event['room']);
//获取指定 fd 加入哪些房间
$getAllRoom = $roomobj -> getRooms($ws -> getSender());
var_dump('当前房间所有 fd：',$getAllFdInRoom);
var_dump('当前 fd 加入的所有房间：',$getAllRoom);
var_dump('当前请求数据：',$event);
$ws -> emit('joincallback','房间加入成功');
}
}app /listener/RoomTest.php
<?php
declare (strict_types = 1);
namespace app\listener;
class WsLeave
{
/**
* 事件监听处理
*
* @return mixed
*/
public function handle($event)
{
$ws = app('think\swoole\Websocket');
$roomobj = app('think\swoole\websocket\Room');
// 当前客户端离开指定 room
$ws -> leave($event['room']);
// 同时离开多个 room
// $ws -> leave(['one','two']);
// 指定客户端离开指定 room
// $ws -> setSender(2) -> leave($event['room']);
// 获取指定 room 中的所有客户端 fd
$getAllFdInRoom = $roomobj -> getClients($event['room']);
var_dump('当前房间还剩 fd：',$getAllFdInRoom);
$ws -> emit('leavecallback','房间离开成功');
}
}上記は、フロントエンド HTML ページとバックエンドのルームへの参加、ルームからの退出、ルーム チャットのイベント コードです。テストを開始しましょう。
まず、プロジェクトのルート ディレクトリで Think-Swoole サービスを有効にします。
ブラウザが wsroot.html または ioroomtest.html ページにアクセスすると、複数のタブを開いて複数のクライアントをシミュレートできます。最初に 3 つ開きます。接続が成功すると、FD は 1、2、および 3 になります。 fd 1 と 2 の両方を持つクライアントを「1 つの」ルームに参加させ、fd 3 を持つクライアントを「2 つの」ルームに参加させます。ユーザーがルームに参加しているすべての fd を WsJoin.php に出力するためです。ルーム参加イベント、および参加したすべてのルームのユーザーの fd 名。この情報はコマンド ラインに出力され、最後にチャット シーンの値と「ルームに正常に参加しました」メッセージが現在のクライアントに送信され、表示できます。ブラウザコンソールで。
ルーム参加後、クライアントでfdを1にして送信するメッセージをページの入力ボックスに入力し、送信をクリック後、送信するルーム名を「one」と入力してください。 、その後、メッセージは「1 つの」ルームに送信され、「1 つの」ルーム (fd は 1 と 2) 内のすべてのクライアントのみがメッセージを受信できます。
ここで、fd 2 を持つクライアントが「one」ルームから退出できるようにします。WsLeave.php の退室イベントでは、退出後に残りの fd を出力するため、コマンド ラインに情報が表示されます。 「部屋には fd 1 しか残っていない。fd 1 は情報を送信するが、fd 2 は受信できない。
WebSocket-Room の他の機能については、上記のコードでコメント化されているため、テストのために開く必要があります。
H5 WebSocket と SocketIO は、前の記事でメッセージの処理をすでに示しています。前者は使用する前にサーバーから返されたメッセージを手動で解析する必要がありますが、後者はシーン値に基づいてメッセージを受信します処理は直接使用できます。
以上がThink-Swoole の WebSocket-Room がルームに参加、退出し、ルーム メッセージを送信しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
ホットAIツール
Undresser.AI Undress
リアルなヌード写真を作成する AI 搭載アプリ
AI Clothes Remover
写真から衣服を削除するオンライン AI ツール。
Undress AI Tool
脱衣画像を無料で
Clothoff.io
AI衣類リムーバー
AI Hentai Generator
AIヘンタイを無料で生成します。
人気の記事
ホットツール
メモ帳++7.3.1
使いやすく無料のコードエディター
SublimeText3 中国語版
中国語版、とても使いやすい
ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境
ドリームウィーバー CS6
ビジュアル Web 開発ツール
SublimeText3 Mac版
神レベルのコード編集ソフト（SublimeText3）
ホットトピック
7562
15
1384
52
84
11
28
98
TP6 Think-Swoole RPC サービスのパフォーマンスの最適化とデバッグ
Oct 12, 2023 am 11:16 AM
TP6Think-SwooleRPC サービスのパフォーマンスの最適化とデバッグ 1. はじめに インターネットの急速な発展に伴い、分散コンピューティングは現代のソフトウェア開発に不可欠な部分となっています。分散コンピューティングでは、RPC (RemoteProcedureCall、リモート プロシージャ コール) は、ネットワーク全体でメソッド呼び出しを実装できる一般的に使用される通信メカニズムです。 Think-Swoole は、高性能 PHP フレームワークとして、RPC サービスを適切にサポートできます。しかし
TP6 Think-Swoole RPC サービスの高い拡張性と分散展開
Oct 12, 2023 am 11:07 AM
TP6 (ThinkPHP6) は、PHP をベースとしたオープンソースのフレームワークであり、高い拡張性と分散展開の特徴を持っています。この記事では、TP6 と Swoole 拡張機能を使用して拡張性の高い RPC サービスを構築する方法と、具体的なコード例を紹介します。まず、TP6 と Swoole 拡張機能をインストールする必要があります。コマンドラインで次のコマンドを実行します:composerrequiretopthink/thinkpeclinstallswo
TP6 Think-Swoole RPC サービスのデータ暗号化と本人認証メカニズム
Oct 12, 2023 am 11:29 AM
TP6Think-SwooleRPC サービスのデータ暗号化と ID 認証メカニズム インターネットの急速な発展に伴い、異なるモジュール間のデータ対話や関数呼び出しを実現するためにリモート呼び出しを行う必要のあるアプリケーションがますます増えています。このような状況において、RPC (RemoteProcedureCall) は重要な通信方法となっています。高性能な RPC サービスを実装できる TP6Think-Swoole フレームワークでのデータ暗号化と本人認証の使い方を紹介します。
TP6 Think-Swoole RPC サービスの高度な同時リクエスト処理とスケジューリング
Oct 12, 2023 pm 12:33 PM
TP6Think-SwooleRPC サービスの高度な同時リクエスト処理とスケジューリング インターネット技術の継続的な発展に伴い、ネットワーク アプリケーションの同時リクエスト処理とスケジューリングが重要な課題となっています。 TP6 フレームワークでは、Think-Swoole 拡張機能を使用して、同時実行性の高いリクエスト処理と RPC (RemoteProcedureCall) サービスのスケジューリングを実装できます。この記事では、TP6 フレームワークで Think-Swoole ベースの RPC サービスを構築し、提供する方法を紹介します。
TP6 Think-Swoole の RPC サービスとメッセージ キューの統合とアプリケーション
Oct 12, 2023 am 11:37 AM
TP6Think-Swoole の RPC サービスとメッセージ キューの統合とアプリケーション 最新のソフトウェア開発では、RPC サービス (RemoteProcedureCall) とメッセージ キューは、分散システムでサービス コールと非同期メッセージ処理を実装するために使用される一般的な技術手段です。 Think-Swoole コンポーネントを TP6 フレームワークに統合すると、RPC サービスとメッセージ キューの機能を簡単に実装でき、開発者が理解して適用できる簡潔なコード例が提供されます。 1.RPC
TP6 Think-Swoole RPC サービスのセキュリティ保護と認可検証
Oct 12, 2023 pm 01:15 PM
TP6Think-SwooleRPC サービスのセキュリティ保護と認可検証 クラウド コンピューティングとマイクロサービスの台頭により、リモート プロシージャ コール (RPC) は開発者の日常業務に不可欠な部分になりました。 RPC サービスを開発する場合、正当なリクエストのみがサービスにアクセスして呼び出すことができるようにするため、セキュリティ保護と認可の検証が非常に重要です。この記事では、TP6Think-Swoole フレームワークで RPC サービスのセキュリティ保護と認可検証を実装する方法を紹介します。 1. RPCサービスの基本概念
TP6 Think-Swoole RPC サービスのパフォーマンス テストとパフォーマンス チューニング
Oct 12, 2023 pm 02:19 PM
TP6Think-SwooleRPC サービスのパフォーマンス テストとパフォーマンス チューニング 1. はじめに インターネットの急速な発展に伴い、分散システムの適用はますます普及しています。分散システムでは、RPC (リモート プロシージャ コール) が一般的な通信メカニズムであり、これにより、異なるノード上のサービスが相互に呼び出し、分散システムでの共同作業を実現できます。 TP6 フレームワークでは、Think-Swoole は高性能 Swoole ドライバーとして、便利な RPC サービス サポートを提供します。この記事では主にTについて紹介します。
Think-Swoole によって構築された TP6 RPC サービスおよびマイクロサービス アーキテクチャの実践ケース
Oct 12, 2023 pm 12:04 PM
TP6Think-Swoole が構築した RPC サービスとマイクロサービス アーキテクチャの実践事例の紹介: インターネットの急速な発展とビジネス規模の拡大に伴い、従来のモノリシック アーキテクチャでは大規模なビジネス シナリオのニーズを満たすことができなくなりました。そこで、マイクロサービス アーキテクチャが登場しました。マイクロサービス アーキテクチャでは、RPC (RemoteProcedureCall) サービスはサービス間の通信を実現する重要な方法です。 RPC サービスを通じて、さまざまなマイクロサービスが便利かつ効率的に相互に呼び出すことができます。記事上で
