Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し-ThinkPHP-php.cn

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し

藏色散人

リリース： 2020-10-19 14:52:28

転載

3483 人が閲覧しました

Think-Swoole チュートリアル WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し

クライアントの fd とは何ですか

fd は、クライアントの一意の識別子です。 Swoole , fd は再利用されます。コネクションが閉じられると、新しく入ったコネクションによって fd が再利用されます。維持されている TCP コネクションの fd は再利用されません。

現在のクライアントの fd を取得します

app/listener/WsConnect.php

<?php
declare (strict_types = 1);
namespace app\listener;
use \think\swoole\Websocket;
class WsTest
{
    /**
     * 事件监听处理
     *
     * @return mixed
     */
    public function handle($event,Websocket $ws)
{
//        $ws = app(&#39;think\swoole\Websocket&#39;); // 单例
        //获取当前发送消息客户端的 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(&#39;连接成功&#39;);
    }
    ws.onmessage = function(data){
        console.log(data.data);
    }
    ws.onclose = function(){
        console.log(&#39;连接断开&#39;);
    }
    function send()
{
        var message = document.getElementById(&#39;message&#39;).value;
        var to = document.getElementById(&#39;to&#39;).value;
        console.log("准备给" + to + "发送数据：" + message);
        ws.send(JSON.stringify([&#39;test&#39;,{
            to:to,
            message:message
        }])); //发送的数据必须是 [&#39;test&#39;,数据] 这种格式
    }
</script>
</body>
</html>

ログイン後にコピー

Openブラウザ複数のクライアント接続をシミュレートするための複数のタグ。すべて test.html ファイルにアクセスします。以下に示すように、コンソールは各クライアントの fd を出力します。アクセスのために 3 つのタグを開きます。

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し

つまり、サーバーから送信されたメッセージは、HTML の ws.onmessage によって受信されます。

指定された fd (単一またはグループ) のクライアントにメッセージを送信します

app/listener/WsTest.php

<?php
declare (strict_types = 1);
namespace app\listener;
use \think\swoole\Websocket;
class WsTest
{
    /**
     * 事件监听处理
     *
     * @return mixed
     */
    public function handle($event,Websocket $ws)
{
//        $ws = app(&#39;think\swoole\Websocket&#39;); // 单例
        //获取当前发送消息客户端的 fd
        var_dump($ws -> getSender());
        //发送给指定 fd 的客户端，包括发送者自己
        $ws -> to(intval($event[&#39;to&#39;])) -> emit(&#39;testcallback&#39;,$event[&#39;message&#39;]);
    }
}

ログイン後にコピー

$ws -> to() は受信者の fd またはチャットルーム名を設定します。複数の人に送信する場合は、[1,2,3] などの複数の配列を設定できます。fd は整数である必要があります。 $ws -> Emit() はメッセージ送信メソッドです。最初のパラメータはイベント名で、クライアントがメッセージを送信する前の記事のテストと同様に、複数のシナリオで使用され、任意に定義できます。サーバ。 2 番目のパラメータは送信する内容で、文字列または配列を指定できます。受信者を設定せずに個別に呼び出すと、メッセージは現在の fd に送信されます。

Think-Swoole サービスを再起動し、3 つのクライアントを開いて接続します。fd は 1、2、および 3 です。ここで、fd 1 のクライアントを使用して、fd 2 のクライアントにメッセージを送信します。 . クライアント:

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し

送信後、fd 1 と 2 を持つクライアントのみがメッセージを受信できることがわかります (つまり、メッセージ送信者自身も受信できます)メッセージを受信します)、しかし、fd 3 を持つクライアントはメッセージを受信しませんでした:

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し

送信後、fd 1 と 2 を持つクライアントだけがメッセージを受信できることがわかります。メッセージを受信します (つまり、メッセージの送信者自体もメッセージを受信します) が、fd 3 を持つクライアントはメッセージを受信しませんでした:

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し

Sending aブロードキャストメッセージ

ブロードキャストメッセージは、自分以外のすべてのクライアントにメッセージを送信します。

app/listener/WsConnect.php

<?php
declare (strict_types = 1);
namespace app\listener;
use \think\swoole\Websocket;
class WsTest
{
    /**
     * 事件监听处理
     *
     * @return mixed
     */
    public function handle($event,Websocket $ws)
{
        //获取当前发送消息客户端的 fd
        var_dump($ws -> getSender());
        //发送广播消息
        $ws -> broadcast() -> emit(&#39;testcallback&#39;,$event[&#39;message&#39;]);
    }
}

ログイン後にコピー

$ws ->broadcast() メソッドはブロードキャストメッセージを送信します。

ただし、ブロードキャストメッセージを自分で受信したい場合は、 $ws -> to($ws -> getSender()) -> Emit('testcallback',$event['メッセージ']); 以上です。

クライアントをシミュレートして別のクライアントにメッセージを送信する

現在の fd が 1 であるとしますが、fd 2 のクライアントを使用して fd 3 のクライアントにメッセージを送信することをシミュレートしたいとします。送信側 fd と受信側 fd を設定するだけです:

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

ログイン後にコピー

テスト後、1 はメッセージを受信しませんでしたが、2 と 3 は両方とも受信しました。

Get Swoole\WebSocket\Server

クライアントが有効なクライアントかどうか、つまりサーバーとのハンドシェイクが成功したかどうかを判断する関数が必要だとします。 Think-Swoole 拡張機能にはこの関数はありませんが、Swoole の公式ドキュメントによると、必要な機能を完了できる is確立関数があります。では、Think-Swoole を通じてネイティブ Swoole 関数を取得するにはどうすればよいでしょうか? 答えは、 Swoole\WebSocket\Server クラス。方法は 2 つあります:

1.app('swoole.server');

2.app('think\swoole\Manager') -> getServer();

インスタンス化後、次のような Swoole ネイティブメソッドを呼び出すことができます:

$manager = app(&#39;think\swoole\Manager&#39;);
$manager -> getServer() -> isEstablished(2);

ログイン後にコピー

Attachment: \think\Swoole\Websocket クラスオブジェクトメソッド:

ブロードキャスト設定送信ブロードキャストメッセージ
isBroadcast 現在のブロードキャストモードが
# であるかどうかを確認し、受信者の fd またはチャットルーム名を設定します (配列で設定できます) )
getTo 受信者の fd またはチャットルーム名を取得します
join 現在のクライアントが指定されたチャットルームに参加します (複数可能)
#leave 現在のクライアントが指定されたチャットルームから退出します (複数の可能性があります)
emit メッセージが送信されます

以上がThink-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出しの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブ メソッド呼び出し

Think-Swoole の WebSocket メッセージ、ブロードキャスト、および Swoole ネイティブメソッド呼び出し