ThinkPHP5.1フレームワークとWorkermanのGatewayWorkerフレームワークを組み合わせた事例

GatewayWorker は、Workerman に基づいて開発された、分散展開可能な TCP 長時間接続フレームワークです。特に、アプリ プッシュ サーバー、インスタント IM サーバー、ゲーム サーバー、モノのインターネット、スマート ホームなどの TCP 長時間接続アプリケーションを迅速に開発するために使用されます。お待ちください

ドキュメント アドレス: http://www.workerman.net/gatewaydoc/

1. 公式デモをテストします (Windows バージョン)

1. デモをダウンロードします (下のコメントで独自の を入手してください)

2. 任意の場所に解凍します。

D:\phpStudy\PHPTutorial\WWW\GatewayWorker

3. GatewayWorker ディレクトリに入ります

4. start_for_win.bat をダブルクリックして開始します。 (エラーが発生した場合は、ここを参照して php 環境変数を設定してください)、結果は次のようになります。

5 コマンド ラインで telnet 127.0.0.1 8282 を実行します。ウィンドウで、チャットする文字を入力します (ローカル テストではなく、127.0.0.1 を実際の IP に置き換えてください)。

#PS: 上記は、TCP 接続テストが成功したことを示しています

#2. テスト Web ソケットを変更します

1. start_gateway.php を変更する必要があります。このように、WebSocket プロトコルを指定します。

$gateway = new Gateway(websocket://0.0.0.0:7272);

2. start_for_win.bat

# を再起動します。3. js

## をテストします。

#要約: 1 つのファイル (start_gateway.php) のプロトコルとポートを変更するだけで、他は何も変更する必要はありません。

3. ThinkPHP5.1 フレームワークとの統合

(1) サーバーは積極的にメッセージをクライアントにプッシュします

原則：

1. TP5.1 フレームワーク プロジェクトと GatewayWorker の独立したデプロイメントは相互に干渉しません

2. すべてのビジネス ロジックは Web サイト (WebSocket 接続) ページから TP5 にリクエストされますpost/get を通じて 1 フレームワークのコントローラーで完了

3. GatewayWorker はクライアントから送信されたデータを受け入れません、つまり、GatewayWorker はビジネス ロジックを処理せず、GatewayWorker はビジネス ロジックとしてのみ使用されます。 -way プッシュ チャネル

#4. TP5.1 フレームワークがブラウザにデータをアクティブにプッシュする必要がある場合にのみ、ゲートウェイの API (GatewayClient) が TP5.1 フレームワークで呼び出され、プッシュを完了します

具体的な実装手順

1. Web サイトのページは、GatewayWorker との WebSocket 接続を確立します

ws = new WebSocket("ws://127.0.0.1:7272");

2. GatewayWorker は、ページが接続を開始したことを検出すると、対応する接続​​の client_id を Web サイトに送信します。 page

Event.php content

public static function onConnect($client_id)
{
    $resData = [
        'type' => 'init',
        'client_id' => $client_id,
        'msg' => 'connect is success' // 初始化房间信息
    ];
    Gateway::sendToClient($client_id, json_encode($resData));
}

#index.html Content

    
    


GatewayWorker的websocket连接

3. Web サイトのページは client_id を受信した後、ajax リクエスト (index/chat_room/bind) をトリガーして client_id を TP5.0 バックエンドのバインド メソッド

/*
 * 用户登录后初始化以及绑定client_id
 */
public function bind()
{
    // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值
    Gateway::$registerAddress = '127.0.0.1:1238';
    $uid = $this->userId;
    $group_id = $this->groupId;
    $client_id = request()->param('client_id');
    // client_id与uid绑定
    Gateway::bindUid($client_id, $uid);
    // 加入某个群组（可调用多次加入多个群组）
    Gateway::joinGroup($client_id, $group_id);
}

4 に送信します。バックエンドは GatewayClient を使用して Gateway::bindUid($client_id, $uid) を呼び出し、 client_id と現在の uid (ユーザー ID またはクライアントの一意識別子) バインディングを結合します。グループまたはグループ送信関数がある場合は、Gateway::joinGroup($client_id, $group_id) を使用して client_id を対応するグループに追加することもできます

接続成功後の戻り値

PS: 上記の戻り値は、GatewayWorker サービスが正常に接続した後に返される json データです。

5. ページによって開始されたすべてのリクエストは、メッセージの送信を含む統合処理のための mvc フレームワーク

sendMessage を通じてメッセージを送信します (サーバーはメッセージをクライアントに積極的にプッシュします)

// mvc后端发消息 利用GatewayClient发送 Events.php
public function sendMessage()
{
    // stream_socket_client(): unable to connect to tcp://127.0.0.1:1236
    $uid = $this->userId;
    $group = $this->groupId;
    $message = json_encode([
      'type'=>'say',
      'msg'=>'Hello ThinkPHP5'
    ]);
    // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值
    Gateway::$registerAddress = '127.0.0.1:1238';
    // 向任意uid的网站页面发送数据
    Gateway::sendToUid($uid, $message);
    // 向任意群组的网站页面发送数据，如果开启，则会向页面发送两条一样的消息
    //Gateway::sendToGroup($group, $message);
}

6. mvc フレームワークが特定の uid にデータを送信する必要がある場合または業務処理中にグループを直接呼び出す GatewayClient のインターフェイス Gateway::sendToUid Gateway::sendToGroup は待機後に送信できます。

#PS: 上記のメッセージ GatewayClient\Gateway 経由で書き込みメッセージを送信するのは TP5.0 であり、GatewayWorker サービスとは直接の関係はありません。

上記は、サーバーがアクティブにメッセージをclient

区別に注意してください:

1 、サーバーはメッセージをクライアントにアクティブにプッシュします

2、クライアントはメッセージをクライアントにプッシュします

(2) クライアントがクライアントにメッセージをプッシュする

クライアントからクライアントへのメッセージの送受信を修正する 以下のGatewayWorkerのEvents.phpを修正する(開発者はこのファイルに注意するだけで良い)

public static function onConnect($client_id)
{
    $resData = [
        'type' => 'init',
        'client_id' => $client_id,
        'msg' => 'connect is success' // 初始化房间信息
    ];
    Gateway::sendToClient($client_id, json_encode($resData));
}
 
/**
 * 当客户端发来消息时触发
 * @param int $client_id 连接id
 * @param mixed $message 具体消息
 */
public static function onMessage($client_id, $message)
{
    // 服务端console输出
    //echo "msg : $message \r\n";
 
    // 解析数据
    $resData = json_decode($message, true);
    $type = $resData['type'];
    $roomId = $resData['roomId'];
    $userId = $resData['userId']; // 未登录，则传递一个随机
    $userName = $resData['userName']; // 未登录，则传递一个随机
    $content = isset($resData['content']) ? $resData['content'] : 'default content';
     
    //将时间全部置为服务器时间
    $serverTime = date('Y-m-d H:i:s', time());
 
    switch ($type) {
        case 'join':  // 用户进入直播间
            //将客户端加入到某一直播间
            Gateway::joinGroup($client_id, $roomId);
            $resData = [
                'type' => 'join',
                'roomId' => $roomId,
                'userName' => $userName,
                'msg' => "enters the Room", // 发送给客户端的消息，而不是聊天发送的内容
                'joinTime' => $serverTime // 加入时间                   
            ];
 
            // 广播给直播间内所有人，谁？什么时候？加入了那个房间？
            Gateway::sendToGroup($roomId, json_encode($resData));
            break;
        case 'say':  // 用户发表评论
            $resData = [
                'type' => 'say',
                'roomId' => $roomId,
                'userName' => $userName,
                'content' => $content,
                'commentTime' => $serverTime // 发表评论时间
            ];
            // 广播给直播间内所有人
            Gateway::sendToGroup($roomId, json_encode($resData));
            break;
        case 'pong':
            break; // 接收心跳
        default:
            //Gateway::sendToAll($client_id,$json_encode($resData));
            break;
    }
}

index.html チャット ルーム ページ

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>GatewayWorker的websocket连接</title>
</head>
<body>
<h1 id="GatewayWorker的websocket连接">GatewayWorker的websocket连接</h1>
<div>
    websocket send content：<input type="text" style="height: 50px; width: 100%;" name="data" id="data">
    <p></p>
    <button id="submit" onclick="sub()">send info</button>
    <p></p>
    <div id="output"></div>
</div>
<script src="https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js"></script>
<script src="https://cdn.bootcss.com/reconnecting-websocket/1.0.0/reconnecting-websocket.min.js"></script>
<script language="javascript" type="text/javascript">
    var wsUri = "ws://notes.env:7272/";
    var outputContent;
    var roomId = &#39;L06777&#39;;
    var userId = 4840043;
    var userName = &#39;Tinywan&#39; + Math.random();
 
    // 把当新链接的客户端加入到当前直播间,消息类型：{"type":"join","roomId":"1002","userId":"88","userName":"userName"}
    var joinContent = {
        "type": "join",
        "roomId": roomId,
        "userId": userId,
        "userName": userName
    };
 
    // 初始化页面操作
    function init() {
        outputContent = document.getElementById("output");
        initWebSocket();
    }
 
    function initWebSocket() {
        websocket = new ReconnectingWebSocket(wsUri);
        websocket.onopen = function (evt) {
            onOpen(evt)
        };
        websocket.onclose = function (evt) {
            onClose(evt)
        };
        websocket.onmessage = function (evt) {
            onMessage(evt)
        };
        websocket.onerror = function (evt) {
            onError(evt)
        };
    }
 
    function onOpen(evt) {
        console.log("CONNECTED");
    }
 
    // 接收数据
    function onMessage(evt) {
        var data = eval("(" + evt.data + ")");
        var type = data.type || &#39;&#39;;
        switch (type) {
            case &#39;init&#39;:
                // 把当新链接的客户端加入到当前直播间
                console.log(&#39;-------init--------&#39; + data);
                websocket.send(JSON.stringify(joinContent));
                writeToScreen(&#39;<span style="color: blue;">RESPONSE: &#39; + evt.data + &#39;</span>&#39;);
                break;
            case &#39;join&#39;:
                console.log(&#39;-------join--------&#39; + data);
                writeToScreen(
                    &#39;<span style="color: blue;"> &#39; + &#39; 新用户: &#39; + &#39;</span>&#39; +
                    &#39;<span style="color: red;"> &#39; + data.userName + &#39;</span>&#39; +
                    &#39;<span style="color: green;"> &#39; + data.joinTime + &#39;</span>&#39; +
                    &#39;<span style="color: black;"> &#39; + data.msg + &#39;</span>&#39;
                );
                break;
            case &#39;say&#39;:
                console.log(&#39;say======&#39; + data);
                writeToScreen(
                    &#39;<span style="color: blue;"> &#39; + &#39; Chat: &#39; + &#39;</span>&#39; +
                    &#39;<span style="color: red;"> &#39; + data.userName + &#39;</span>&#39; +
                    &#39;<span style="color: #D2691E;"> &#39; + data.commentTime + &#39;</span>&#39; +
                    &#39;<span style="color: black;"> &#39; + data.content + &#39;</span>&#39;
                );
                break;
            default :
                console.log(data);
                break;
        }
    }
 
    function onError(evt) {
        console.log(&#39;<span style="color: red;">ERROR:</span> &#39; + evt.data);
    }
 
    function onClose(evt) {
        console.log("DISCONNECTED");
    }
 
    function writeToScreen(message) {
        var pre = document.createElement("p");
        pre.style.wordWrap = "break-word";
        pre.innerHTML = message;
        outputContent.appendChild(pre);
    }
 
    function sub() {
        var text = document.getElementById(&#39;data&#39;).value;
        // {"type":"say",,"msg":"Welcome 111111111111Live Room"}
        var sayContent = {
            "type": "say",
            "roomId": roomId,
            "userId": userId,
            "userName": userName,
            "content": text
        };
        websocket.send(JSON.stringify(sayContent));
    }
    window.addEventListener("load", init, false);
</script>
</body>
</html>　

サービスを再起動

テスト結果

#Extension:

メッセージを保存できる Redis では、Redis 経由でライブ ブロードキャスト ルームの PV

をカウントします

$redis = new \Redis;
$redis->connect('127.0.0.1',6379);
$key = "PV:ROOM:".$roomId;
$field = "ROOM_TOTAL_PV";
// 进入房间的人数增长，自增 ，增加PV统计
$redis->hIncrBy($key,$field,1);

相关推荐：《PHP教程》

以上がThinkPHP5.1フレームワークとWorkermanのGatewayWorkerフレームワークを組み合わせた事例の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。