Think-Swoole의 WebSocket-Room이 방에 들어오고 나가고 방 메시지를 보냅니다.
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!
핫 AI 도구
Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱
AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.
Undress AI Tool
무료로 이미지를 벗다
Clothoff.io
AI 옷 제거제
AI Hentai Generator
AI Hentai를 무료로 생성하십시오.
인기 기사
뜨거운 도구
메모장++7.3.1
사용하기 쉬운 무료 코드 편집기
SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.
스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경
드림위버 CS6
시각적 웹 개발 도구
SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)
뜨거운 주제
7552
15
1382
52
83
11
58
19
22
91
TP6 Think-Swoole RPC 서비스 성능 최적화 및 디버깅
Oct 12, 2023 am 11:16 AM
TP6Think-SwooleRPC 서비스의 성능 최적화 및 디버깅 1. 서론 인터넷의 급속한 발전으로 인해 분산 컴퓨팅은 현대 소프트웨어 개발에서 없어서는 안 될 부분이 되었습니다. 분산 컴퓨팅에서 RPC(RemoteProcedureCall, 원격 프로시저 호출)는 네트워크를 통한 메서드 호출을 구현할 수 있는 일반적으로 사용되는 통신 메커니즘입니다. 고성능 PHP 프레임워크인 Think-Swoole은 RPC 서비스를 잘 지원할 수 있습니다. 하지만
TP6 Think-Swoole RPC 서비스의 높은 확장성과 분산 배포
Oct 12, 2023 am 11:07 AM
TP6(ThinkPHP6)는 PHP 기반의 오픈소스 프레임워크로 높은 확장성과 분산 배포라는 특징을 가지고 있습니다. 이 기사에서는 Swoole 확장과 함께 TP6을 사용하여 확장성이 뛰어난 RPC 서비스를 구축하는 방법을 소개하고 구체적인 코드 예제를 제공합니다. 먼저 TP6 및 Swoole 확장을 설치해야 합니다. 명령줄에서 다음 명령을 실행합니다: Composerrequiretopthink/thinkpeclinstallswo
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:29 AM
TP6Think-SwooleRPC 서비스의 데이터 암호화 및 신원 인증 메커니즘 인터넷의 급속한 발전으로 인해 서로 다른 모듈 간의 데이터 상호 작용 및 기능 호출을 실현하기 위해 원격 호출을 수행해야 하는 응용 프로그램이 점점 더 많아지고 있습니다. 이러한 맥락에서 RPC(RemoteProcedureCall)는 중요한 통신 방법이 되었습니다. TP6Think-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 서비스를 통해 다양한 마이크로서비스가 서로 편리하고 효율적으로 호출할 수 있습니다. 이 기사에서는
