PHP框架实现WebSocket在线聊天通讯系统_PHP教程

当前位置：测速网 > PHP教程 > 发布时间：2024-02-09 21:00 文章来源于网友投稿，仅供参考！

PHP框架实现WebSocket在线聊天通讯系统

ThinkPHP使用Swoole需要安装 think-swoole Composer包，前提系统已经安装好了Swoole PECL 拓展

tp5的项目根目录下执行composer命令安装think-swoole：

composer require topthink/think-swoole

话不多说，直接上代码：

新建WebSocket.php控制器：

（监听端口要确认服务器放行，宝塔环境还需要添加安全组规则）

<?php
namespace apphomecontroller;
use thinkswooleServer;
class WebSocket extends Server
{
protected $host = '0.0.0.0'; //监听所有地址
protected $port = 9501; //监听9501端口
protected $serverType = 'socket';
protected $option = [
  'worker_num'=> 4, //设置启动的Worker进程数
  'daemonize' => false, //守护进程化（上线改为true）
  'backlog' => 128, //Listen队列长度
  'dispatch_mode' => 2, //固定模式，保证同一个连接发来的数据只会被同一个worker处理
  //心跳检测：每60秒遍历所有连接，强制关闭10分钟内没有向服务器发送任何数据的连接
  'heartbeat_check_interval' => 60,
  'heartbeat_idle_time' => 600
];
//建立连接时回调函数
public function onOpen($server,$req)
{
  $fd = $req->fd;//客户端标识
  $uid = $req->get['uid'];//客户端传递的用户id
  $token = $req->get['token'];//客户端传递的用户登录token
  //省略token验证逻辑......
  if (!$token) {
   $arr = array('status'=>2,'message'=>'token已过期');
   $server->push($fd, json_encode($arr));
   $server->close($fd);
   return;
  }
  //省略给用户绑定fd逻辑......
  echo "用户{$uid}建立了连接,标识为{$fd} ";
}
//接收数据时回调函数
public function onMessage($server,$frame)
{
  $fd = $frame->fd;
  $message = $frame->data;
  //省略通过fd查询用户uid逻辑......
  $uid = 666;
  $data['uid'] = $uid;
  $data['message'] = '用户'.$uid.'发送了:'.$message;
  $data['post_time'] = date("m/d H:i",time());
  $arr = array('status'=>1,'message'=>'success','data'=>$data);
  //仅推送给当前连接用户
  //$server->push($fd, json_encode($arr));
  //推送给全部连接用户
  foreach($server->connections as $fd) {
   $server->push($fd, json_encode($arr));
  }
}
//连接关闭时回调函数
public function onClose($server,$fd)
{
  echo "标识{$fd}关闭了连接 ";
}
}

前端演示页面：

（省略控制器判断登录状态、分配数据逻辑......）

<!DOCTYPE html>

<head>

</head>

<body>

</header>

</div>

</body>

</html>

$(function () {

var uid = 666;//当前用户id

var token = 'abcdefg';//用户token

//判断浏览器是否支持WebSocket

var supportsWebSockets = 'WebSocket' in window || 'MozWebSocket' in window;

if (supportsWebSockets) {

//建立WebSocket连接（ip地址换成自己主机ip）

var ws = new WebSocket("ws://127.0.0.1:9501?uid="+uid+"&token="+token);

ws.onopen = function () {

layer.msg('服务器连接成功',{shade:0.1,icon:1,time:600});

};

ws.onerror = function () {

layer.msg('服务器连接失败',{shade:0.1,icon:2,time:600});

};

ws.onmessage = function (evt) {

var data = $.parseJSON(evt.data);

//错误提示

if(data.status != 1){

layer.alert(datassage,{icon:2});

return;

}

//消息返回

if (data.status==1 && data.datassage!='') {

var html = "";

if (data.data.uid == uid) {

html += "<div style='word-break:break-all' class="show"><div class="time">"+data.data.post_time+"</div><div class="msg"><img src=""+data.data.head_img+"" alt="" /><p><i clas="msg_input"></i>"+data.datassage+"</p></div></div>";

}else{

html += "<div style='word-break:break-all' class="send"><div class="time">"+data.data.post_time+"</div><div class="msg"><img src=""+data.data.head_img+"" alt="" /><p><i clas="msg_input"></i>"+data.datassage+"</p></div></div>";

}

$("ssage").append(html);

setTimeout(function () {

($('ssage').children("div:last-child")[0]).scrollIntoView();//向上滚动

},100);

};

ws.onclose = function (res) {

};

//按钮发送

$("#sendBtn").click(function () {

var contents = $("#msg").val().trim();

if(contents == null || contents == ""){

layer.msg('内容为空',{shade:0.1,icon:2,time:600});

return false;

}else{

ws.send(contents);

$("#msg").val("");

}

});

//回车发送

$("#msg").keydown(function (evel) {

var that = $(this);

if (evel.keyCode == 13) {

evel.cancelBubble = true;

evel.preventDefault();

evel.stopPropagation();

var contents = that.val().trim();

if(contents == null || contents == ""){

layer.msg('内容为空',{shade:0.1,icon:2,time:600});

return false;

}else{

ws.send(contents);

that.val("");

}

});

}else{

layer.alert("您的浏览器不支持 WebSocket!");

}

});

</script>

服务器移到项目根目录开启服务：

php public/index.php Websocket/start

这里的路径，是因为我绑定了home模块为默认模块，tp5默认情况是：php public/index.php index/Websocket/start）

开启成功，查看端口已经被监听：

lsof -i:9501

很多PHPer在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向感，不知道该从那里入手去提升，对此我整理了一些资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家，需要请戳这里

总结

以上所述是小编给大家介绍的PHP框架实现WebSocket在线聊天通讯系统，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！

上一篇：laravel框架中表单请求类型和CSRF防护实例分析

下一篇：php pdo连接数据库操作示例

winlogins.exe是什么文件？winlogins.exe是不是病毒 winsock2.6.exe是什么文件？winsock2.6.exe是不是病毒 WinDefendor.dll是什么文件？WinDefendor.dll是不是病毒系统目录是什么文件？系统目录是不是病毒 wholove.exe是什么文件？wholove.exe是不是病毒 winn.ini是什么文件？winn.ini是不是病毒 w6oou.dll是什么文件？w6oou.dll是不是病毒 winduxzawb.exe是什么文件？winduxzawb.exe是不是病毒 wuammgr32.exe是什么文件？wuammgr32.exe是不是病毒 windiws.exe是什么文件？windiws.exe是不是病毒