cadre php
PensezPHP
WebSocket-Room de Think-Swoole rejoint, quitte la salle et envoie des messages à la salle
WebSocket-Room de Think-Swoole rejoint, quitte la salle et envoie des messages à la salle
Think-Swoole 3.0 a ajouté la fonction de salle de discussion Room à Websocket, qui est principalement utilisée pour la messagerie de groupe, mais les messages entre différentes salles sont isolés les uns des autres. Lorsque nous entrons dans une salle de discussion, seul le fd de cette salle de discussion peut recevoir les messages que nous entrons, laissons et envoyons.
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' => [],
],Il y a un élément de configuration de la salle, et le type à l'intérieur indique quelle méthode de traitement des données est utilisée. Il existe deux types ci-dessous, "table" et "redis", table is Il peut être utilisé directement, mais redis nécessite que l'extension redis soit installée dans notre système et notre projet. table est un service de traitement de mémoire inter-processus hautes performances qui peut partager des données entre différents processus.
Créer des événements
Entrez les commandes suivantes dans le répertoire racine du projet pour créer respectivement des événements de participation à la salle, des événements de sortie de salle et des événements de discussion en salle :
php think make:listener WsJoin php think make:listener WsLeave php think make:listener RoomTest
Définissez ensuite l'événement dans app/event.php :
[
],
'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' => [
],
];Les noms ci-dessus tels que Join, Leave et RoomTest sont tous personnalisés et doivent correspondre à la valeur de scène du message envoyé par le front-end.
Bien sûr, la définition de l'événement peut également être configurée dans l'écoute websocket du fichier de configuration config/swoole.php. Veuillez vous référer à l'article précédent pour plus de détails.
Connexion client H5 WebSocker
wsroot.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>Connexion client SocketIO
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 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>, les valeurs de scène définies dans les fonctions join(), Leave() et send() sont respectivement join, Leave et RoomTest, que nous avons définies dans app/leave.php. Ces scènes les valeurs correspondent à des événements et déclenchent donc respectivement les événements WsJoin.php, WsLeave.php et RoomTest.php.
Écriture d'événements backend
app/listener/WsJoin.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/WsLeave.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','房间离开成功');
}
}app /listener/RoomTest.php
<?php
declare (strict_types = 1);
namespace app\listener;
class RoomTest
{
/**
* 事件监听处理
*
* @return mixed
*/
public function handle($event)
{
var_dump($event);
$ws = app('think\swoole\Websocket');
//给指定的 room 内所有 fd 发送消息，包括当前客户端，当前客户端没有加入该 room 也可发送
$ws -> to($event['room']) -> emit('roomtestcallback',$event['message']);
//指定多个 room 发送消息
//$ws -> to(['one','two']) -> emit('客户端场景值',$event['message']);
}
}Ce qui précède sont la page HTML frontale et les codes d'événement de participation à la salle, de sortie de la salle et de discussion en salle. Commençons les tests.
Activez d'abord le service Think-Swoole dans le répertoire racine du projet.
Lorsque vous accédez à la page wsroot.html ou ioroomtest.html avec votre navigateur, vous pouvez ouvrir plusieurs onglets et simuler plusieurs clients. Nous en ouvrons trois d'abord. Une fois la connexion réussie, les fds sont 1, 2,. et 3 respectivement. Nous laissons les clients avec fd 1 et 2 rejoindre la salle "un", et le client avec fd 3 rejoindre la salle "deux" puisque nous imprimons tous les fds que l'utilisateur rejoint dans la salle dans WsJoin. .php join room event, et les fds de l'utilisateur. Noms de toutes les salles rejointes, ces informations seront imprimées dans la ligne de commande, et enfin la valeur de la scène de discussion et le message "Rejoindre la salle avec succès" seront envoyés au client actuel. , qui peut être consulté dans la console du navigateur.
Après avoir rejoint la salle, utilisez le client avec fd 1 pour saisir le message à envoyer dans la zone de saisie de la page. Après avoir cliqué sur Envoyer, saisissez le nom de la salle à envoyer comme "une", puis le message sera envoyé à la salle "une", seuls tous les clients de la salle "une" (fd est 1 et 2) peuvent recevoir le message.
Maintenant, laissez le client avec fd 2 quitter la salle "one". Puisque dans l'événement de sortie de salle WsLeave.php, nous imprimons le fd restant après avoir quitté, les informations apparaîtront dans la ligne de commande, visible "one". " Il ne reste plus que le fd 1 dans la pièce. Le fd 1 envoie des informations, mais le fd 2 ne peut pas les recevoir.
D'autres fonctions de WebSocket-Room ont été commentées dans le code ci-dessus et doivent être ouvertes pour tests.
H5 WebSocket et SocketIO ont déjà démontré le traitement des messages dans l'article précédent. Le premier nécessite une analyse manuelle des messages renvoyés par le serveur avant de pouvoir être utilisés, tandis que le second recevra les messages selon le valeur de scène des messages et l'avons fait, le traitement peut être utilisé directement.
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
Outils d'IA chauds
Undresser.AI Undress
Application basée sur l'IA pour créer des photos de nu réalistes
AI Clothes Remover
Outil d'IA en ligne pour supprimer les vêtements des photos.
Undress AI Tool
Images de déshabillage gratuites
Clothoff.io
Dissolvant de vêtements AI
AI Hentai Generator
Générez AI Hentai gratuitement.
Article chaud
Outils chauds
Bloc-notes++7.3.1
Éditeur de code facile à utiliser et gratuit
SublimeText3 version chinoise
Version chinoise, très simple à utiliser
Envoyer Studio 13.0.1
Puissant environnement de développement intégré PHP
Dreamweaver CS6
Outils de développement Web visuel
SublimeText3 version Mac
Logiciel d'édition de code au niveau de Dieu (SublimeText3)
Optimisation des performances et débogage du service RPC TP6 Think-Swoole
Oct 12, 2023 am 11:16 AM
Optimisation des performances et débogage du service TP6Think-SwooleRPC 1. Introduction Avec le développement rapide d'Internet, l'informatique distribuée est devenue un élément indispensable du développement logiciel moderne. En informatique distribuée, RPC (RemoteProcedureCall, appel de procédure à distance) est un mécanisme de communication couramment utilisé grâce auquel les appels de méthode sur le réseau peuvent être implémentés. Think-Swoole, en tant que framework PHP hautes performances, peut bien prendre en charge les services RPC. mais
Haute évolutivité et déploiement distribué du service TP6 Think-Swoole RPC
Oct 12, 2023 am 11:07 AM
TP6 (ThinkPHP6) est un framework open source basé sur PHP, qui présente les caractéristiques d'une grande évolutivité et d'un déploiement distribué. Cet article explique comment utiliser TP6 avec l'extension Swoole pour créer un service RPC hautement évolutif et donne des exemples de code spécifiques. Tout d’abord, nous devons installer les extensions TP6 et Swoole. Exécutez la commande suivante dans la ligne de commande : composerrequiretopthink/thinkpeclinstallswo
Mécanisme de cryptage des données et d'authentification de l'identité du service TP6 Think-Swoole RPC
Oct 12, 2023 am 11:29 AM
Mécanisme de cryptage des données et d'authentification d'identité du service TP6Think-SwooleRPC Avec le développement rapide d'Internet, de plus en plus d'applications doivent effectuer des appels à distance pour réaliser des interactions de données et des appels de fonctions entre différents modules. Dans ce contexte, RPC (RemoteProcedureCall) est devenu un moyen de communication important. Le framework TP6Think-Swoole peut implémenter des services RPC hautes performances. Cet article explique comment utiliser le cryptage des données et l'authentification de l'identité.
Intégration et application du service RPC et de la file d'attente de messages de TP6 Think-Swoole
Oct 12, 2023 am 11:37 AM
Intégration et application du service RPC et de la file d'attente de messages de TP6Think-Swoole Dans le développement logiciel moderne, le service RPC (RemoteProcedureCall) et la file d'attente de messages sont des moyens techniques courants utilisés pour implémenter les appels de service et le traitement asynchrone des messages dans les systèmes distribués. L'intégration des composants Think-Swoole dans le framework TP6 peut facilement implémenter les fonctions des services RPC et des files d'attente de messages, et fournit des exemples de code concis que les développeurs peuvent comprendre et appliquer. 1. RPC
Traitement des demandes hautement simultané et planification du service RPC TP6 Think-Swoole
Oct 12, 2023 pm 12:33 PM
Traitement des demandes hautement simultanées et planification du service TP6Think-SwooleRPC Avec le développement continu de la technologie Internet, le traitement des demandes simultanées et la planification des applications réseau sont devenus un défi important. Dans le framework TP6, l'extension Think-Swoole peut être utilisée pour implémenter le traitement des requêtes à haute concurrence et la planification du service RPC (RemoteProcedureCall). Cet article présentera comment créer un service RPC basé sur Think-Swoole dans le framework TP6 et fournira
Protection de sécurité et vérification de l'autorisation du service TP6 Think-Swoole RPC
Oct 12, 2023 pm 01:15 PM
Protection de la sécurité et vérification des autorisations du service TP6Think-SwooleRPC Avec l'essor du cloud computing et des microservices, l'appel de procédure à distance (RPC) est devenu un élément indispensable du travail quotidien des développeurs. Lors du développement de services RPC, la protection de la sécurité et la vérification des autorisations sont très importantes pour garantir que seules les demandes légitimes peuvent accéder au service et l'appeler. Cet article présentera comment implémenter la protection de sécurité et la vérification des autorisations des services RPC dans le framework TP6Think-Swoole. 1. Concepts de base des services RPC
Tests de performances et réglage des performances du service TP6 Think-Swoole RPC
Oct 12, 2023 pm 02:19 PM
Tests de performances et réglage des performances du service TP6Think-SwooleRPC 1. Introduction Avec le développement rapide d'Internet, l'application de systèmes distribués devient de plus en plus répandue. Dans les systèmes distribués, RPC (Remote Procedure Call) est un mécanisme de communication courant, qui permet aux services sur différents nœuds de s'appeler et de réaliser un travail collaboratif dans les systèmes distribués. Dans le framework TP6, Think-Swoole, en tant que pilote Swoole hautes performances, fournit une prise en charge pratique du service RPC. Cet article présente principalement T
Cas pratiques de service TP6 RPC et d'architecture de microservices créés par Think-Swoole
Oct 12, 2023 pm 12:04 PM
Introduction au cas pratique de l'architecture de service et de microservice RPC construite par TP6Think-Swoole : Avec le développement rapide d'Internet et l'expansion de l'échelle commerciale, l'architecture monolithique traditionnelle ne peut plus répondre aux besoins des scénarios commerciaux à grande échelle. C’est pourquoi l’architecture des microservices a vu le jour. Dans l'architecture des microservices, le service RPC (RemoteProcedureCall) est un moyen important d'établir la communication entre les services. Grâce aux services RPC, divers microservices peuvent s'appeler de manière pratique et efficace. Dans cet article
