PHP-Framework
Denken Sie an PHP
Der WebSocket-Room von Think-Swoole tritt dem Raum bei, verlässt ihn und sendet Raumnachrichten
Der WebSocket-Room von Think-Swoole tritt dem Raum bei, verlässt ihn und sendet Raumnachrichten
Think-Swoole 3.0 fügt Websocket die Room-Chatroom-Funktion hinzu, die hauptsächlich für Gruppennachrichten verwendet wird, aber Nachrichten zwischen verschiedenen Räumen sind voneinander isoliert. Wenn wir einen Chatraum betreten, kann nur der FD dieses Chatraums die Nachrichten empfangen, die wir betreten, verlassen und senden.
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' => [],
],Es gibt ein Raumkonfigurationselement und der darin enthaltene Typ gibt an, welche Datenverarbeitungsmethode verwendet wird. Es gibt zwei Typen, „Tabelle“ und „Redis“, die direkt verwendet werden können erfordert die Installation der Redis-Erweiterung in unserem System und Projekt. table ist ein leistungsstarker, prozessübergreifender Speicherverarbeitungsdienst, der Daten zwischen verschiedenen Prozessen austauschen kann.
Ereignisse erstellen
Geben Sie die folgenden Befehle in das Stammverzeichnis des Projekts ein, um Ereignisse zum Betreten des Raums, Ereignisse zum Verlassen des Raums bzw. zum Chatten im Raum zu erstellen:
php think make:listener WsJoin php think make:listener WsLeave php think make:listener RoomTest
Dann definieren Sie Ereignisse in 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' => [
],
];wie oben Namen wie „Join“, „Leave“ und „RoomTest“ werden alle angepasst und müssen dem Szenenwert der vom Front-End gesendeten Nachricht entsprechen.
Natürlich kann die Ereignisdefinition auch im Websocket-Listen der Konfigurationsdatei config/swoole.php konfiguriert werden. Weitere Informationen finden Sie im vorherigen Artikel.
H5 WebSocker-Client-Verbindung
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>SocketIO-Client-Verbindung
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>Seiten-, Join()-, Leave()- und Send()-Funktionen Die definierten Szenenwerte sind Join, Leave und RoomTest. Wir haben die Ereignisse, die diesen Szenenwerten entsprechen, in app/leave.php definiert, sodass die Ereignisse WsJoin.php, WsLeave.php und RoomTest.php jeweils ausgelöst werden.
Schreiben von Back-End-Ereignissen
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']);
}
}Die oben genannten sind die Front-End-HTML-Seiten und die Back-End-Ergänzungen Room, hinterlassen Sie den Room- und Room-Chat-Ereigniscode und beginnen Sie unten mit dem Testen.
Aktivieren Sie zunächst den Think-Swoole-Dienst im Projektstammverzeichnis.
Besuchen Sie die Seite wsroot.html oder ioroomtest.html. Sie können mehrere Registerkarten öffnen und zunächst drei Clients öffnen 1 und Clients von 2 treten alle dem Raum „eins“ bei, und Clients mit fd von 3 treten dem Raum „zwei“ bei, da wir im WsJoin.php-Event „Raum beitreten“ alle FDS des Benutzers ausdrucken, der dem Raum beitritt Räume, denen der Benutzername beigetreten ist, werden diese Informationen in der Befehlszeile gedruckt und schließlich werden der aktuelle Client-Chat-Szenenwert und die Informationen „Dem Raum erfolgreich beitreten“ an den Client gesendet, die in der Browserkonsole angezeigt werden können.
Nachdem Sie dem Raum beigetreten sind, verwenden Sie den Client mit fd = 1, um die zu sendende Nachricht in das Eingabefeld der Seite einzugeben. Nachdem Sie auf „Senden“ geklickt haben, geben Sie den Namen des zu sendenden Raums als „eins“ ein und dann den Die Nachricht wird an den „einen“ Raum gesendet. Nur alle Clients im „einen“ Raum (fd ist 1 und 2) können die Nachricht empfangen.
Lassen Sie nun den Client mit fd 2 den Raum „eins“ verlassen. Da wir im WsLeave.php-Event den verbleibenden fd nach dem Verlassen ausdrucken, werden in der Befehlszeile nur die Informationen angezeigt „ein“ Raum ist übrig, fd 1 sendet Informationen, fd 2 kann sie nicht empfangen.
Weitere Funktionen von WebSocket-Room wurden im obigen Code kommentiert und müssen zum Testen geöffnet werden.
H5 WebSocket und SocketIO haben die Verarbeitung von Nachrichten bereits im vorherigen Artikel demonstriert. Ersteres erfordert eine manuelle Analyse der vom Server zurückgegebenen Nachricht, bevor sie verwendet werden kann, während letzteres die Nachricht entsprechend dem Szenenwert empfängt Nachricht und verarbeiten Sie sie, bevor Sie sie direkt verwenden.
Das obige ist der detaillierte Inhalt vonDer WebSocket-Room von Think-Swoole tritt dem Raum bei, verlässt ihn und sendet Raumnachrichten. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
Heiße KI -Werkzeuge
Undresser.AI Undress
KI-gestützte App zum Erstellen realistischer Aktfotos
AI Clothes Remover
Online-KI-Tool zum Entfernen von Kleidung aus Fotos.
Undress AI Tool
Ausziehbilder kostenlos
Clothoff.io
KI-Kleiderentferner
AI Hentai Generator
Erstellen Sie kostenlos Ai Hentai.
Heißer Artikel
Heiße Werkzeuge
Notepad++7.3.1
Einfach zu bedienender und kostenloser Code-Editor
SublimeText3 chinesische Version
Chinesische Version, sehr einfach zu bedienen
Senden Sie Studio 13.0.1
Leistungsstarke integrierte PHP-Entwicklungsumgebung
Dreamweaver CS6
Visuelle Webentwicklungstools
SublimeText3 Mac-Version
Codebearbeitungssoftware auf Gottesniveau (SublimeText3)
Heiße Themen
1386
52
Leistungsoptimierung und Debugging des TP6 Think-Swoole RPC-Dienstes
Oct 12, 2023 am 11:16 AM
Leistungsoptimierung und Debugging des TP6Think-SwooleRPC-Dienstes 1. Einführung Mit der rasanten Entwicklung des Internets ist verteiltes Rechnen zu einem unverzichtbaren Bestandteil der modernen Softwareentwicklung geworden. Beim verteilten Rechnen ist RPC (RemoteProcedureCall, Remoteprozeduraufruf) ein häufig verwendeter Kommunikationsmechanismus, über den Methodenaufrufe im gesamten Netzwerk implementiert werden können. Think-Swoole kann als leistungsstarkes PHP-Framework RPC-Dienste gut unterstützen. Aber
Hohe Skalierbarkeit und verteilte Bereitstellung des TP6 Think-Swoole RPC-Dienstes
Oct 12, 2023 am 11:07 AM
TP6 (ThinkPHP6) ist ein auf PHP basierendes Open-Source-Framework, das sich durch hohe Skalierbarkeit und verteilte Bereitstellung auszeichnet. In diesem Artikel wird erläutert, wie Sie TP6 mit der Swoole-Erweiterung verwenden, um einen hoch skalierbaren RPC-Dienst zu erstellen, und es werden spezifische Codebeispiele gegeben. Zuerst müssen wir die Erweiterungen TP6 und Swoole installieren. Führen Sie den folgenden Befehl in der Befehlszeile aus: Composerrequiretopthink/thinkpeclinstallswo
Datenverschlüsselungs- und Identitätsauthentifizierungsmechanismus des TP6 Think-Swoole RPC-Dienstes
Oct 12, 2023 am 11:29 AM
Datenverschlüsselungs- und Identitätsauthentifizierungsmechanismus des TP6Think-SwooleRPC-Dienstes Mit der rasanten Entwicklung des Internets müssen immer mehr Anwendungen Remoteaufrufe durchführen, um Dateninteraktionen und Funktionsaufrufe zwischen verschiedenen Modulen zu realisieren. In diesem Zusammenhang hat sich RPC (RemoteProcedureCall) zu einer wichtigen Kommunikationsmethode entwickelt. Das TP6Think-Swoole-Framework kann leistungsstarke RPC-Dienste implementieren. In diesem Artikel wird die Verwendung von Datenverschlüsselung und Identitätsauthentifizierung vorgestellt.
TP6 Integration und Anwendung des RPC-Dienstes und der Nachrichtenwarteschlange von Think-Swoole
Oct 12, 2023 am 11:37 AM
Integration und Anwendung des RPC-Dienstes und der Nachrichtenwarteschlange von TP6Think-Swoole In der modernen Softwareentwicklung sind RPC-Dienst (RemoteProcedureCall) und Nachrichtenwarteschlange gängige technische Mittel zur Implementierung von Dienstaufrufen und asynchroner Nachrichtenverarbeitung in verteilten Systemen. Durch die Integration von Think-Swoole-Komponenten in das TP6-Framework können die Funktionen von RPC-Diensten und Nachrichtenwarteschlangen einfach implementiert werden, und es werden prägnante Codebeispiele bereitgestellt, die Entwickler verstehen und anwenden können. 1. RPC
Hochgradig gleichzeitige Anforderungsverarbeitung und Planung des TP6 Think-Swoole RPC-Dienstes
Oct 12, 2023 pm 12:33 PM
Hochgradig gleichzeitige Anforderungsverarbeitung und Planung des TP6Think-SwooleRPC-Dienstes Mit der kontinuierlichen Entwicklung der Internettechnologie ist die gleichzeitige Anforderungsverarbeitung und Planung von Netzwerkanwendungen zu einer wichtigen Herausforderung geworden. Im TP6-Framework kann die Think-Swoole-Erweiterung verwendet werden, um die Anforderungsverarbeitung mit hoher Parallelität und die Planung des RPC-Dienstes (RemoteProcedureCall) zu implementieren. In diesem Artikel wird erläutert, wie Sie einen Think-Swoole-basierten RPC-Dienst im TP6-Framework erstellen und bereitstellen
Sicherheitsschutz und Autorisierungsüberprüfung des TP6 Think-Swoole RPC-Dienstes
Oct 12, 2023 pm 01:15 PM
Sicherheitsschutz und Autorisierungsüberprüfung des TP6Think-SwooleRPC-Dienstes Mit dem Aufkommen von Cloud Computing und Microservices ist Remote Procedure Call (RPC) zu einem unverzichtbaren Bestandteil der täglichen Arbeit von Entwicklern geworden. Bei der Entwicklung von RPC-Diensten sind Sicherheitsschutz und Autorisierungsüberprüfung sehr wichtig, um sicherzustellen, dass nur legitime Anfragen auf den Dienst zugreifen und ihn aufrufen können. In diesem Artikel wird erläutert, wie der Sicherheitsschutz und die Autorisierungsüberprüfung von RPC-Diensten im TP6Think-Swoole-Framework implementiert werden. 1. Grundkonzepte von RPC-Diensten
Leistungstests und Leistungsoptimierung des TP6 Think-Swoole RPC-Dienstes
Oct 12, 2023 pm 02:19 PM
Leistungstests und Leistungsoptimierung des TP6Think-SwooleRPC-Dienstes 1. Einführung Mit der rasanten Entwicklung des Internets wird die Anwendung verteilter Systeme immer weiter verbreitet. In verteilten Systemen ist RPC (Remote Procedure Call) ein allgemeiner Kommunikationsmechanismus, der es Diensten auf verschiedenen Knoten ermöglicht, sich gegenseitig anzurufen und in verteilten Systemen eine Zusammenarbeit zu erreichen. Im TP6-Framework bietet Think-Swoole als leistungsstarker Swoole-Treiber praktische RPC-Serviceunterstützung. In diesem Artikel wird hauptsächlich T. vorgestellt
Von Think-Swoole erstellte TP6-RPC-Service- und Microservice-Architektur-Übungsfälle
Oct 12, 2023 pm 12:04 PM
Einführung in den praktischen Fall der von TP6Think-Swoole erstellten RPC-Service- und Microservice-Architektur: Mit der schnellen Entwicklung des Internets und der Ausweitung des Geschäftsumfangs kann die traditionelle monolithische Architektur die Anforderungen großer Geschäftsszenarien nicht mehr erfüllen. Daher entstand die Microservice-Architektur. In der Microservice-Architektur ist der RPC-Dienst (RemoteProcedureCall) eine wichtige Möglichkeit, die Kommunikation zwischen Diensten zu erreichen. Über RPC-Dienste können sich verschiedene Microservices bequem und effizient gegenseitig anrufen. In diesem Artikel
