旗下导航:搜·么
当前位置:网站首页 > PHP教程 > 正文

ThinkPHP5.1框架与Workerman之GatewayWorker框架连系案例【php教程】

作者:搜搜PHP网发布时间:2019-11-26分类:PHP教程浏览:118


导读:GatewayWorker是基于Workerman开辟的一个可分布式布置的TCP长衔接框架,特地用于疾速开辟TCP长衔接运用,比方app推送效劳端、立即IM效劳端、游戏效劳端、物联...
GatewayWorker是基于Workerman开辟的一个可分布式布置的TCP长衔接框架,特地用于疾速开辟TCP长衔接运用,比方app推送效劳端、立即IM效劳端、游戏效劳端、物联网、智能家居等等

文档地点:http://www.workerman.net/gatewaydoc/

一、测试官方DEMO(Windows 版本)

1、下载demo(在下方批评中自取

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衔接测试胜利

二、修正测试websocket

1、须要修正 start_gateway.php 指定websocket协定,像如许

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

2、重新启动 start_for_win.bat

3、测试js

小结:只须要修改一个文件( start_gateway.php)的协定和端口即可,别的不需用修改。

三、与ThinkPHP5.1框架连系

(一)效劳端主动推送音讯到客户端

准绳:

1、TP5.1框架项目与GatewayWorker自力布置互不滋扰

2、一切的营业逻辑都由网站(websocket衔接的)页面以post/get要求到TP5.1框架的控制器中完成

3、GatewayWorker不吸收客户端发来的数据,即GatewayWorker不处置惩罚任何营业逻辑,GatewayWorker仅仅当作一个单向的推送通道

4、仅当TP5.1框架须要向浏览器主动推送数据时才在TP5.1框架中挪用Gateway的API(GatewayClient)完成推送

细致完成步骤

1、网站页面竖立与GatewayWorker的websocket衔接

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

2、GatewayWorker发现有页面提议衔接时,将对应衔接的client_id发给网站页面

Event.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));
}

index.html 内容

<!DOCTYPE html>
<html>
<head>
    <meta charset="UTF-8">
    <title>GatewayWorker的websocket衔接</title>
</head>
<body>
<h1>GatewayWorker的websocket衔接</h1>
<script src="https://cdn.bootcss.com/jquery/3.3.1/jquery.min.js"></script>
<script type="text/javascript">
    ws = new WebSocket("ws://127.0.0.1:7272");
    // 效劳端主动推送音讯时会触发这里的onmessage
    ws.onmessage = function(e){
        // json数据转换成js对象
        var data = JSON.parse(e.data);
        console.log(data);
        var type = data.type || '';
        switch(type){
            // Events.php中返回的init范例的音讯,将client_id发给背景举行uid绑定
            case 'init':
                // 应用jquery提议ajax要求,将client_id发给后端举行uid绑定
                $.post(
                    "{:url('index/chat_room/bind')}",
                    {client_id: data.client_id},
                    function(data)
                    {
                        console.log(data);
                    },
                    'json'
                );
                break;
            case  'say':
                console.log('TP5 msg'+e.data);
                break;
            // 当mvc框架挪用GatewayClient发音讯时直接alert出来
            default :
                alert(e.data);
        }
    };
</script>
</body>
</html>

3、网站页面收到client_id后触发一个ajax要求(index/chat_room/bind)将client_id发到TP5.0后端,bind要领

/*
 * 用户登录后初始化以及绑定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、后端收到client_id后应用GatewayClient挪用Gateway::bindUid($client_id, $uid)将client_id与当前uid(用户id或许客户端唯一标识)绑定。假如有群组、群发功用,也能够应用Gateway::joinGroup($client_id, $group_id)将client_id到场到对应分组

衔接胜利后返回值

PS:以上返回值为 GatewayWorker效劳 衔接胜利后返回的json数据

5、页面提议的一切要求都直接post/get到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 等发送即可

经由过程浏览器接见sendMessage操纵,测试效果

PS:以上的音讯是TP5.0 经由过程 GatewayClient\Gateway 发送写音讯,和GatewayWorker效劳没有直接关系

以上为 效劳端主动推送音讯到客户端

注重辨别:

1、效劳端主动推送音讯到客户端

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>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 = 'L06777';
    var userId = 4840043;
    var userName = 'Tinywan' + 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 || '';
        switch (type) {
            case 'init':
                // 把当新链接的客户端到场到当前直播间
                console.log('-------init--------' + data);
                websocket.send(JSON.stringify(joinContent));
                writeToScreen('<span style="color: blue;">RESPONSE: ' + evt.data + '</span>');
                break;
            case 'join':
                console.log('-------join--------' + data);
                writeToScreen(
                    '<span style="color: blue;"> ' + ' 新用户: ' + '</span>' +
                    '<span style="color: red;"> ' + data.userName + '</span>' +
                    '<span style="color: green;"> ' + data.joinTime + '</span>' +
                    '<span style="color: black;"> ' + data.msg + '</span>'
                );
                break;
            case 'say':
                console.log('say======' + data);
                writeToScreen(
                    '<span style="color: blue;"> ' + ' Chat: ' + '</span>' +
                    '<span style="color: red;"> ' + data.userName + '</span>' +
                    '<span style="color: #D2691E;"> ' + data.commentTime + '</span>' +
                    '<span style="color: black;"> ' + data.content + '</span>'
                );
                break;
            default :
                console.log(data);
                break;
        }
    }
 
    function onError(evt) {
        console.log('<span style="color: red;">ERROR:</span> ' + 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('data').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> 

重启开启效劳

测试效果

扩大:

能够把音讯存储的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框架连系案例的细致内容,更多请关注ki4网别的相干文章!

标签:ThinkPHP5.1WorkermanGatewayWorker