點擊下載
本文文檔

當前位置：首頁 - 科技 - 知識百科 - 正文

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用

來源：懂視網責編：小采時間：2020-11-02 18:02:00

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用:Think-Swoole 教程之WebSocket 消息、廣播以及 Swoole 原生方法調用什么是客戶端的 fdfd 是在 Swoole 中客戶端的唯一標識符，fd 是復用的，當連接關閉后 fd 會被新進入的連接復用，正在維持的 TCP 連接 fd 不會被復用。獲取當前客戶端的fdapp/li

推薦度：

點擊下載本文 文檔為doc格式

導讀Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用:Think-Swoole 教程之WebSocket 消息、廣播以及 Swoole 原生方法調用什么是客戶端的 fdfd 是在 Swoole 中客戶端的唯一標識符，fd 是復用的，當連接關閉后 fd 會被新進入的連接復用，正在維持的 TCP 連接 fd 不會被復用。獲取當前客戶端的fdapp/li

Think-Swoole 教程之WebSocket 消息、廣播以及 Swoole 原生方法調用

什么是客戶端的 fd

fd 是在 Swoole 中客戶端的唯一標識符，fd 是復用的，當連接關閉后 fd 會被新進入的連接復用，正在維持的 TCP 連接 fd 不會被復用。

獲取當前客戶端的fd

app/listener/WsConnect.php

<?php
declare (strict_types = 1);
namespace applistener;
use 	hinkswooleWebsocket;
class WsTest
{
 /**
 * 事件監聽處理
 *
 * @return mixed
 */
 public function handle($event,Websocket $ws)
{
// $ws = app('thinkswooleWebsocket'); // 單例
 //獲取當前發送消息客戶端的 fd
 var_dump($ws -> getSender());
 }
}

test.html

<!DOCTYPE HTML>
<html>
<head>
 <meta charset="UTF-8">
 <title>Document</title>
</head>
<body>
消息：<input type="text" id="message">
接收者：<input type="text" id="to">
<button onclick="send()">發送</button>
<script>
 var ws = new WebSocket("ws://127.0.0.1:9501/");
 ws.onopen = function(){
 console.log('連接成功');
 }
 ws.onmessage = function(data){
 console.log(data.data);
 }
 ws.onclose = function(){
 console.log('連接斷開');
 }
 function send()
{
 var message = document.getElementById('message').value;
 var to = document.getElementById('to').value;
 console.log("準備給" + to + "發送數據：" + message);
 ws.send(JSON.stringify(['test',{
 to:to,
 message:message
 }])); //發送的數據必須是 ['test',數據] 這種格式
 }
</script>
</body>
</html>

瀏覽器打開多個標簽，來模擬多個客戶端連接，均訪問 test.html 文件，控制臺將會打印出每個客戶端的 fd ，如下圖我們打開三個標簽進行訪問：

也就是說，服務端發送過來的消息，都會被 HTML 中的 ws.onmessage 接收到。

給指定 fd 的客戶端發送消息（單發、群發）

app/listener/WsTest.php

<?php
declare (strict_types = 1);
namespace applistener;
use 	hinkswooleWebsocket;
class WsTest
{
 /**
 * 事件監聽處理
 *
 * @return mixed
 */
 public function handle($event,Websocket $ws)
{
// $ws = app('thinkswooleWebsocket'); // 單例
 //獲取當前發送消息客戶端的 fd
 var_dump($ws -> getSender());
 //發送給指定 fd 的客戶端，包括發送者自己
 $ws -> to(intval($event['to'])) -> emit('testcallback',$event['message']);
 }
}

$ws -> to()是設置收件人 fd 或聊天室名，如果發送給多個人可以數組設置多個，例如 [1,2,3]，fd 須為整型。$ws -> emit() 是發送消息方法，第一個參數是事件名稱，用于多場景，可任意定義，就如上一片文章中客戶端給服務端發送消息的 Test 一樣。第二個參數是發送的內容，可以是字符串、數組，單獨調用不設置收件人的話，就是發送消息給當前 fd 。

重啟 Think-Swoole 服務，分別打開三個客戶端進行連接，fd 分別為 1、2、3，現在，現在，我們用 fd 為 1 的客戶端，發消息給 fd 為 2 的客戶端：

發送后，可見只有 fd 為 1、2 的客戶端能收到消息（也就是說消息發出者自身也會收到消息），而 fd 為 3 的客戶端卻沒有收到消息：

發送廣播消息

廣播消息就是發送一條消息給所有客戶端，但是不包括自己。

app/listener/WsConnect.php

<?php
declare (strict_types = 1);
namespace applistener;
use 	hinkswooleWebsocket;
class WsTest
{
 /**
 * 事件監聽處理
 *
 * @return mixed
 */
 public function handle($event,Websocket $ws)
{
 //獲取當前發送消息客戶端的 fd
 var_dump($ws -> getSender());
 //發送廣播消息
 $ws -> broadcast() -> emit('testcallback',$event['message']);
 }
}

$ws -> broadcast() 方法就是發送廣播消息。

但是如果想自己也收到廣播消息，那就需要增加一條 $ws -> to($ws -> getSender()) -> emit('testcallback',$event['message']); 即可。

模擬客戶端給另一個客戶端發消息

假設我當前 fd 為 1，但是我要模擬用 fd 為 2 的客戶端給 fd 為 3 的客戶端發送消息，只需設置發送者 fd 和接收者兩個 fd 即可：

$ws -> setSender(2) -> to(3) -> emit('testcallback',$event['message']);

經測試，1 沒有收到消息，2 和 3 都收到了。

獲取 SwooleWebSocketServer

假設說我們現在需要一個功能，判斷一個客戶端是否為有效客戶端，即是否與服務端握手成功。Think-Swoole 擴展中沒有這個功能，但是查閱 Swoole 官方文檔，有個 isEstablished 函數可以完成我們需要的功能，那么怎樣通過 Think-Swoole 拿到原生 Swoole 函數呢，答案就是獲取 SwooleWebSocketServer 這個類。有兩種方式：

1、app('swoole.server');

2、app('thinkswooleManager') -> getServer();

實例化后，就可以調用 Swoole 原生方法了，如：

$manager = app('thinkswooleManager');
$manager -> getServer() -> isEstablished(2);

附： hinkSwooleWebsocket類對象方法：

broadcast 設置進行廣播消息發送

isBroadcast 判斷當前是否是廣播模式

to 設置收件人 fd 或聊天室名（可以數組設置多個）

getTo 獲取收件人 fd 或聊天室名

join 當前客戶端加入到指定聊天室（可以多個）

leave 當前客戶端離開指定聊天室（可以多個）

emit 消息發送

close 關閉當前連接

getSender 獲取當前客戶端 id（即fd）

setSender 設置發件人的 fd

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用

推薦度：

點擊下載本文 文檔為doc格式

標簽：消息廣播調用

熱門焦點

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用

Think-Swoole之WebSocket消息、廣播以及 Swoole 原生方法調用

最新推薦

猜你喜歡

熱門推薦