Think-Swoole 3.0에서는 주로 그룹 메시징에 사용되는 Websocket에 룸 채팅방 기능이 추가되었지만, 서로 다른 룸 간의 메시지는 서로 격리되어 있습니다. 우리가 채팅방에 입장하면, 이 채팅방의 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은 서로 다른 프로세스 간에 데이터를 공유할 수 있는 고성능 크로스 프로세스 메모리 처리 서비스입니다.
Create events
방 참여 이벤트, 방 나가기 이벤트 및 방 채팅 이벤트를 각각 생성하려면 프로젝트 루트 디렉터리에 다음 명령을 입력하세요.
php think make:listener WsJoin php think make:listener WsLeave php think make:listener RoomTest
그런 다음 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' => [
],
];위 Join, Leave, RoomTest 등의 이름은 모두 사용자 정의되었으며 프런트 엔드에서 보낸 메시지의 장면 값과 일치해야 합니다.
물론, config/swoole.php 구성 파일을 통해 websocket에서 이벤트 정의를 구성할 수도 있습니다. 자세한 내용은 이전 기사를 참조하세요.
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>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>페이지, Join(), Leave() 및 send() 함수 정의된 장면 값 각각 Join, Leave 및 RoomTest입니다. app/leave.php에서 이러한 장면 값에 해당하는 이벤트를 정의했으므로 WsJoin.php, WsLeave.php 및 RoomTest.php 이벤트가 각각 트리거됩니다.
백엔드 이벤트 작성
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']);
}
}위는 프론트엔드 HTML 페이지입니다. 그리고 백엔드 추가 룸, 룸 및 룸 채팅 이벤트 코드를 남겨두고 아래에서 테스트를 시작하세요.
먼저 프로젝트 루트 디렉터리에서 Think-Swoole 서비스를 활성화하세요.
브라우저를 사용하여 wsroot.html 또는 ioroomtest.html 페이지에 액세스하면 여러 탭을 열고 여러 클라이언트를 시뮬레이션할 수 있습니다. 연결이 성공한 후 fd는 각각 1, 2, 3입니다. fd 1과 클라이언트 2는 모두 "1" 룸에 참여하고, fd 3을 가진 클라이언트는 "2" 룸에 참여합니다. 왜냐하면 우리는 WsJoin.php 룸 참여 이벤트에서 룸에 참여하는 사용자의 모든 fd를 인쇄하기 때문입니다. 이름, 이 정보는 명령줄에 인쇄되고 마지막으로 현재 클라이언트 채팅 장면 값과 "방에 성공적으로 참여했습니다" 정보가 클라이언트로 전송되며 이는 브라우저 콘솔에서 볼 수 있습니다. .
방에 입장한 후 fd = 1인 클라이언트를 이용하여 페이지의 입력란에 보낼 메시지를 입력한 후 보내기를 클릭한 후 "one"으로 보낼 방 이름을 입력한 후 메시지는 "one" 룸으로 전송됩니다. "one" 룸(fd는 1과 2)의 모든 클라이언트만 메시지를 받을 수 있습니다.
이제 fd 2가 있는 클라이언트가 "one" 룸을 나가도록 합니다. WsLeave.php 룸 나가기 이벤트에서 떠난 후 남은 fd를 인쇄하므로 해당 정보만 명령줄에 표시됩니다. "1"개의 방이 남았습니다. fd 1은 정보를 보내고, fd 2는 이를 받을 수 없습니다.
WebSocket-Room의 다른 기능은 위 코드에 주석 처리되어 있으며 테스트를 위해 열어야 합니다.
H5 WebSocket 및 SocketIO는 이미 이전 기사에서 메시지 처리를 시연했습니다. 전자는 사용하기 전에 서버에서 반환된 메시지를 수동으로 구문 분석해야 하는 반면, 후자는 장면 값에 따라 메시지를 받습니다. 직접 사용하기 전에 메시지를 전송하고 처리하세요.
위 내용은 Think-Swoole의 WebSocket-Room이 방에 들어오고 나가고 방 메시지를 보냅니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
