【黄啊码】如何使用thinkphp结合wokerman实现分组群聊
【黄啊码】如何使用thinkphp结合wokerman实现分组群聊
大家好，我是黄啊码，关于php的课程咱们好像停更了一小段时间了，今天继续，讲讲怎么使用wokerman实现分组群聊，不知道怎么用tp搭建wokerman的，请看下边链接，我不会再做阐述：【黄啊码】windows如何使用tp5.1配置workerman和gateway（不要看官方文档，不要抄网友文档，OK？）_tp5.1 workerman_黄啊码的博客-CSDN博客【黄啊码】windows如何使用tp5.1配置workerman和gateway（不要看官方文档，不要抄网友文档，OK？）
https://blog.csdn.net/TiaoZhanJi_Xian/article/details/128837525
目录
实现原理：
1. 与MVC系统整合的原则：
2. 实现步骤：
三、实现—配置和开启Gateway：
四、实现-服务端开发
五、实现-客户端连接与发送/接收：
实现原理：
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
*/
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 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" 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 -->温馨提示：以上代码是另外的项目提取出来，跟我之前的博文不是相互衔接的，在此只提供思路，不提供源码，感谢理解。
好了，今天的分享就这里，有问题的留个言，别忘了一键三连，下次我们还会再见！
我是黄啊码，码字的码，退。。。退。。。退。。。朝