Workerman은 그룹 채팅을 어떻게 구현하나요?

1. 기본 w 1. Workerman
Workerman은 중국 사람들이 개발한 양심적이고 고성능 PHP 소켓 서버 프레임워크입니다. 둘 다 4K 이상을 가지고 있으므로 얼마나 멋진지 상상할 수 있습니다.

단독으로 배포하거나 MVC 프레임워크(TP, laravel 등)에 통합할 수 있으며 매우 실용적이며 동시성 효과가 좋습니다.

공식 홈페이지 주소: http://www.workerman.net/workerman

gayhub 주소:

https://github.com/walkor/workerman/

2.gateway-worker

gateway - Worker(이하 게이트웨이)는 Workerman을 기반으로 개발된 TCP Long Connection Framework로, TCP Long Connection 애플리케이션을 빠르게 개발하는데 사용됩니다.

온라인 채팅은 일반적으로 통신을 유지하기 위해 긴 연결을 사용합니다. 워커맨을 사용하면 동일한 효과를 얻을 수 있지만 게이트웨이가 더 편리하고 빠릅니다.

(폴링으로 만든 채팅방도 없어졌네요..)

gayhub 주소 :

https://github.com/walkor/GatewayWorker

3.gatewayClient

gateClient를 사용합니다. 작업자나 게이트웨이가 사용자를 그룹화하고 사용자에게 정보를 전송하는 데 도움을 주는 동시에 원본 시스템의 uid와 clientid를 빠르고 쉽게 바인딩할 수 있습니다.

gayhub 주소:

https://github.com/walkor/GatewayClient

2. 이론:

1. MVC 시스템과의 통합 원리:

·

Exist ing mvc 프레임워크 프로젝트와 GatewayWorker의 독립적 배포는 서로 간섭하지 않습니다.

·

모든 비즈니스 로직은 웹사이트 페이지에서 mvc 프레임워크로의 게시/가져오기로 완료됩니다. 즉, GatewayWorker는 비즈니스 로직을 처리하지 않으며 GatewayWorker는 단방향 푸시 채널로만 사용됩니다.

·mvc 프레임워크가 데이터를 적극적으로 푸시해야 하는 경우에만. 브라우저에서 게이트웨이 API(GatewayClient)가 mvc 프레임워크에서 호출됨)가 푸시를 완료합니다.

2. 구현 단계: (1) 웹사이트 페이지는 GatewayWorker와 웹소켓 연결을 설정합니다.

(2) GatewayWorker는 페이지가 연결을 시작하는 것을 발견하면 해당 연결의 client_id를 보냅니다.

(3) 웹 사이트 페이지는 client_id를 수신한 후 ajax 요청을 트리거하고(bind.php라고 가정) client_id를 mvc 백엔드로 보냅니다. (4) mvc 백엔드 바인드 후. php는 client_id를 수신하고 GatewayClient를 사용하여 Gateway::bindUid($ client_id, $uid)를 호출하고 client_id를 현재 uid(사용자 ID 또는 클라이언트 고유 식별자)에 바인딩합니다. 그룹 또는 그룹 전송 기능이 있는 경우 Gateway::joinGroup($client_id, $group_id)을 사용하여 해당 그룹에 client_id를 추가할 수도 있습니다.

(5) 페이지에서 시작된 모든 요청은 직접 게시/가져오기됩니다. 통합 처리를 위해 mvc 프레임워크에 메시지 보내기 포함

(6) mvc 프레임워크가 비즈니스 처리 중에 특정 uid 또는 특정 그룹에 데이터를 보내야 하는 경우 GatewayClient 인터페이스 Gateway::sendToUid Gateway::sendToGroup을 직접 호출합니다. 등.

3. 구현 - 게이트웨이 구성 및 열기:

1. 게이트웨이 다운로드 및 사용

은 단독으로 사용하거나 프레임워크의 공개 디렉토리에 배치할 수 있습니다.

2. start.php 편집

·

start.php는 php 명령줄을 사용하여 실행해야 합니다.

·

require_once

ini_set('display_errors', 'on');
use Workerman\Worker;
if(strpos(strtolower(PHP_OS), 'win') === 0)
{
    exit("start.php not support windows, please use start_for_win.bat\n");
}
// 检查扩展
if(!extension_loaded('pcntl'))
{
    exit("Please install pcntl extension.See http://doc3.workerman.net/appendices/install-extension.html\n");
}
if(!extension_loaded('posix'))
{
    exit("Please install posix extension.See http://doc3.workerman.net/appendices/install-extension.html\n");
}
// 标记是全局启动
define('GLOBAL_START', 1);
// 注意这里的路径
require_once '../vendor/autoload.php';
// 加载所有Applications/*/start.php，以便启动所有服务
foreach(glob(__DIR__.'/Applications/*/start*.php') as $start_file)
{
    require_once $start_file;
}
// 运行所有服务
Worker::runAll();

3.start_gateway.php

·

의 경로에 주의하세요.ApplicationsYourAppstart_gateway.php

// 部分文件内容
//将$gateway改成websocket协议,demo中是text协议
$gateway = new Gateway("websocket://0.0.0.0:8282");

4.start_reg에서 편집할 수 있습니다 ter.php

·

start_register.php의 $register는 텍스트 프로토콜이어야 하며 포트는

// register 服务必须是text协议
$register = new Register('text://192.168.124.125:1238');

5여야 합니다. 구성 후 start.php

$ php start.php start

를 엽니다. side development

위에서 언급했듯이 사용자는 연결이 발생할 때만 게이트웨이의 onConnect($client_id)를 거치며 모든 비즈니스 작업은 웹 시스템에서 구현되어야 합니다.

그래서 이러한 서비스를 처리하기 위해 GatewayServer.php의 컨트롤러를 만들었습니다

<?php
/**
 * Author: root
 * Date  : 17-3-27
 * time  : 上午12:32
 */
namespace app\index\controller;
use GatewayClient\Gateway;
use think\Cache;
use think\Controller;
use think\Request;
use think\Session;
class GatewayServer extends Controller
{
    public function _initialize(){
    }
    public function bind(Request $request)
    {
        // 用户连接websocket之后,绑定uid和clientid,同时进行分组,根据接收到的roomid进行分组操作
        $userGuid=Session::get(&#39;loginuser&#39;);
        $roomId=intval(trimAll($request->post(&#39;room&#39;)));
        $clientId=trimAll($request->post(&#39;client_id&#39;));
        // 接受到上面的三个参数,进行分组操作
        Gateway::$registerAddress = &#39;192.168.124.125:1238&#39;;
        // client_id与uid绑定
        // Gateway::bindUid($clientId, $userGuid);
        // 加入某个群组（可调用多次加入多个群组） 将clientid加入roomid分组中
        Gateway::joinGroup($clientId, $roomId);
        // 返回ajax json信息
        $dataArr=[
            &#39;code&#39;=>$userGuid,
            &#39;status&#39;=>true,
            &#39;message&#39;=>&#39;Group Success&#39;
        ];
        return json()->data($dataArr);
    }
    // 接受用户的信息 并且发送
    public function send(Request $request){
        Gateway::$registerAddress = &#39;192.168.124.125:1238&#39;;
        // 获得数据
        $userGuid=Session::get(&#39;loginuser&#39;);
        $roomId=intval(trimAll($request->post(&#39;room&#39;)));
        $message=trim($request->post(&#39;message&#39;));
        // 获得用户的称呼
        $userInfo=Cache::get($userGuid);
        // 将用户的昵称以及用户的message进行拼接
        $nickname=$userInfo[&#39;nickname&#39;];
        $message=$nickname." : ".$message;
        // 发送信息应当发送json数据,同时应该返回发送的用户的guid,用于客户端进行判断使用
        $dataArr=json_encode(array(
            &#39;message&#39; => $message,
            &#39;user&#39;=>$userGuid
        ));
        // 向roomId的分组发送数据
        Gateway::sendToGroup($roomId,$dataArr);
    }
}

5. 구현 - 클라이언트 연결 및 보내기/받기:

게이트웨이를 연 후 브라우저가 액세스할 때까지 듣고 기다릴 수 있습니다.

클라이언트는 여기에서 js를 사용하여 websocket을 듣습니다.

1. websocket에 대한 클라이언트 연결을 처리하고 메시지를 수신하는 데 사용됩니다.

// 这个示例和gateway官网的示例是一样的
    // 监听端口
    ws = new WebSocket("ws://192.168.124.125:8282");
    // 绑定分组的ajaxURL
    var ajaxUrl="{:url('/gateway/bind')}";
    // 发送消息的ajaxURL
    var ajaxMsgUrl="{:url('/gateway/send')}";
    // 通过房间号进行分组
    var roomId="{$roomInfo.guid}";
    // 获取当前登录用户的guid，用于标识是自己发送的信息
    var loginUser="{$userLoginInfo.guid}";
    // 获取当前房间号的主播的uid，用于标识是主播发送的信息
    var roomUser="{$roomInfo.uid}";
    // 服务端主动推送消息时会触发这里的onmessage
    ws.onmessage = function(e){
        // console.log(e.data);
        // json数据转换成js对象
        var data = eval("("+e.data+")");
        var type = data.type || '';
        switch(type){
            // Events.php中返回的init类型的消息，将client_id发给后台进行uid绑定
            case 'init':
                // 利用jquery发起ajax请求，将client_id发给后端进行uid绑定
                $.post(ajaxUrl, {client_id: data.client_id,room:roomId}, function(data){
                    // console.log(data);
                }, 'json');
                break;
            // 当mvc框架调用GatewayClient发消息时直接alert出来
            default :
                // 如果登陆用户的guid和数据发送者的guid一样，则使用不同的颜色（只能自己看到）
                if(loginUser == data.user){
                    addMsgToHtml(data.message,'#F37B1D');
                    break;
                // 如果发送者的guid和主播uid一样，则对所有的显示都增加一个[主播标识]
                }else if(data.user==roomUser){
                    addMsgToHtml("[主播] "+data.message,'#0e90d2');
                    break;
                }else{
                // 其他的就正常发送消息
                    addMsgToHtml(data.message,'#333');
                }
                break;
        }
    };

2 수신된 메시지를 표시하기 위해 div에 추가하는 데 사용됩니다.

// 向面板中增加新接收到的消息
    // 其中message是消息，color是显示的颜色，主要为了区分主播以及自己发送的消息和系统提示
    function addMsgToHtml(message,color) {
        if(message.length==0){
            return false;
        }
        // 获取html,并且增加html
        var obj=$("#room-viedo-chat");
        var html=obj.html();
        // 
        html+=&#39;<p><font color="&#39;+color+&#39;">&#39;+message+&#39;</p>&#39;;
        obj.html(html);
        // 将滚动条滚动到底部
        obj.scrollTop(obj[0].scrollHeight);
    }

3. 메시지를 보내는 데 사용됩니다

// 发送聊天消息
    function sendMsg(){
        // 去掉onclick属性,使得3秒之内无法发送信息
        $("#sendMsgBox").attr('onclick','');
        var btnObj=$("#sendMsgBtn");
        var tmpNum=3;
        var tmpMsg=tmpNum+' S';
        btnObj.text(tmpMsg);
        var int =setInterval(function () {
            // 3秒之内不能发送信息,3秒之后,回复onclick属性以及文字
            if(tmpNum==0){
                tmpMsg="发送";
                clearInterval(int);
                btnObj.text("发送");
                $("#sendMsgBox").attr('onclick','sendMsg()');
            }
            btnObj.text(tmpMsg);
            tmpNum-=1;
            tmpMsg=tmpNum+' S';
        },1000);
        var message=$("#chattext").val().trim();
        var obj=$("#room-viedo-chat");
        var html=obj.html();
        if(message.length>=140){
            // 获取html,并且增加html
            addMsgToHtml("系统提示: 不能超过140个字符","#8b0000");
            return false;
        }
        if(message.length==0){
            // 获取html,并且增加html
            addMsgToHtml("系统提示: 不能发送空消息","#8b0000");
            return false;
        }
        // 向server端发送ajax请求
        $.post(ajaxMsgUrl,{room:roomId,message:message},function (data) {
        },'json');
        return false;
    }

4. 약간의 HTML 코드

<!--chat box start -->
    <div class=" am-u-md-12 am-u-lg-12 room-viedo-chat" id="room-viedo-chat" style="font-size:14px;">
    </div>
    <div class="am-u-md-12 am-u-lg-12 room-viedo-chat-button-box">
        <div class="left-div">
            <textarea name="chattext" id="chattext" placeholder="输入聊天内容..."></textarea>
        </div>
        <div class="am-btn am-btn-default right-div am-text-center"onclick="sendMsg();"id="sendMsgBox">
            <span class="" id="sendMsgBtn">
                发送
            </span>
        </div>
    </div>
    <!--chat box end -->

六、效果：

效果很明显：

·系统提示是单独的颜色

·本人发布的，是自己能够分辨的橙色

·主播发布的是蓝色，同时前面有[主播]标识

·看其他人发布的就是普通的颜色

PHP中文网，有大量免费的workerman入门教程，欢迎大家学习！

위 내용은 Workerman은 그룹 채팅을 어떻게 구현하나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!