hi,你好!欢迎访问本站!登录
本站由简数采集腾讯云宝塔系统阿里云强势驱动
当前位置:首页 - PHP框架 - Workerman - 正文 请牢记本站网址www.sosophp.cn

workerman怎样完成分组群聊【workerman】,workerman,分组,群聊

2019-12-12Workerman搜搜PHP网49°c
A+ A-

一、基本

1. workerman

workerman是国人开发的良知高性能的PHP socket 效劳器框架,在环球最大同性结交平台gayHub的star都4K多,可以想象是何等的牛X。

可以零丁布置,也可以整合进MVC的框架(TP,laravel等),可以说异常有用,并发结果也好。

官网地点:

http://www.workerman.net/workerman

gayhub地点:

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

2. gateway-worker

gateway-worker(背面直接称gateway)是基于 workerman开发的TCP长衔接框架,用于疾速开发TCP长衔接运用。

在线谈天平常都是有用长衔接坚持通讯,运用 workerman虽然可以做到一样的结果,然则gateway越发的方便快捷。

(轮询构建的谈天室已OUT了,实在是太...)

gayhub地点:

https://github.com/walkor/GatewayWorker

3. gatewayClient

gateClient是用来辅佐 workerman或许是gateway举行用户分组以及向用户发送信息的组件,同时,可以疾速便利的将原有体系的uid和clientid绑定起来。

gayhub地点:

https://github.com/walkor/GatewayClient

二、理论:

1. 与MVC体系整合的准绳:

·现有mvc框架项目与GatewayWorker自力布置互不滋扰;

·一切的营业逻辑都由网站页面post/get到mvc框架中完成;

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

·仅当mvc框架须要向浏览器主动推送数据时才在mvc框架中挪用Gateway的API(GatewayClient)完成推送。

2. 完成步骤:

(1)网站页面竖立与GatewayWorker的websocket衔接;

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

(3)网站页面收到client_id后触发一个ajax要求(假设是bind.php)将client_id发到mvc后端;

(4)mvc后端bind.php收到client_id后应用GatewayClient挪用Gateway::bindUid($client_id, $uid)将client_id与当前uid(用户id或许客户端唯一标识)绑定。假如有群组、群发功用,也可以应用Gateway::joinGroup($client_id, $group_id)将client_id到场到对应分组;

(5)页面提议的一切要求都直接post/get到mvc框架一致处置惩罚,包含发送音讯;

(6)mvc框架处置惩罚营业过程当中须要向某个uid或许某个群组发送数据时,直接挪用GatewayClient的接口Gateway::sendToUid Gateway::sendToGroup 等发送即可。

三、完成—设置和开启Gateway:

1.下载和运用gateway

可以零丁运用,也可以放在框架的public目录下。

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_register.php

·须要注重start_register.php 中$register必需是text协定,同时须要注重端口

// register 效劳必需是text协定
$register = new Register('text://192.168.124.125:1238');

5. 设置好后,开启start.php

$ php start.php start

四、完成-效劳端开发

上面提到了,用户只要在触发衔接的时刻才经由gateway的onConnect($client_id),而一切的营业操纵都应当在web体系中完成。

因而我创建了一个GatewatServer.php的controller,负责处置惩罚这些营业

<?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('loginuser');
        $roomId=intval(trimAll($request->post('room')));
        $clientId=trimAll($request->post('client_id'));
        // 吸收到上面的三个参数,举行分组操纵
        Gateway::$registerAddress = '192.168.124.125:1238';
        // client_id与uid绑定
        // Gateway::bindUid($clientId, $userGuid);
        // 到场某个群组(可挪用屡次到场多个群组) 将clientid到场roomid分组中
        Gateway::joinGroup($clientId, $roomId);
        // 返回ajax json信息
        $dataArr=[
            'code'=>$userGuid,
            'status'=>true,
            'message'=>'Group Success'
        ];
        return json()->data($dataArr);
    }
    // 吸收用户的信息 而且发送
    public function send(Request $request){
        Gateway::$registerAddress = '192.168.124.125:1238';
        // 取得数据
        $userGuid=Session::get('loginuser');
        $roomId=intval(trimAll($request->post('room')));
        $message=trim($request->post('message'));
        // 取得用户的称谓
        $userInfo=Cache::get($userGuid);
        // 将用户的昵称以及用户的message举行拼接
        $nickname=$userInfo['nickname'];
        $message=$nickname." : ".$message;
        // 发送信息应当发送json数据,同时应当返回发送的用户的guid,用于客户端举行推断运用
        $dataArr=json_encode(array(
            'message' => $message,
            'user'=>$userGuid
        ));
        // 向roomId的分组发送数据
        Gateway::sendToGroup($roomId,$dataArr);
    }
}

五、完成-客户端衔接与发送/吸收:

开启了gateway以后,就可以监听而且守候浏览器接入了。

客户端这里运用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+='<p><font color="'+color+'">'+message+'</p>';
        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 -->

六、结果:

结果很明显:

·体系提醒是零丁的色彩

·本人宣布的,是本身可以区分的橙色

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

·看其他人宣布的就是一般的色彩

ki4网,有大批免费的workerman入门教程,迎接人人进修!

以上就是workerman怎样完成分组群聊的细致内容,更多请关注ki4网别的相干文章!

  选择打赏方式
微信赞助

打赏

QQ钱包

打赏

支付宝赞助

打赏

  选择分享方式
  移步手机端
workerman怎样完成分组群聊【workerman】,workerman,分组,群聊

1、打开你手机的二维码扫描APP
2、扫描左则的二维码
3、点击扫描获得的网址
4、可以在手机端阅读此文章