本文实例讲述了thinkphp5.0框架结合swoole开发实现websocket在线聊天案例。分享给大家供大家参考，具体如下：
thinkphp使用swoole需要安装 think-swoole composer包，前提系统已经安装好了swoole pecl 拓展（相关文章：linux下源码包安装使用swoole扩展）
在tp5的项目根目录下执行composer命令安装think-swoole：
composer require topthink/think-swoole
安装成功：
话不多说，直接上代码：
新建websocket.php控制器：
（监听端口要确认服务器放行，宝塔环境还需要添加安全组规则）
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}\n";
}
//接收数据时回调函数
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}关闭了连接\n";
}
}
前端演示页面：
（省略控制器判断登录状态、分配数据逻辑......）
chat 在线聊天
发送
服务器移到项目根目录开启服务：
php public/index.php websocket/start
（这里的路径，是因为我绑定了home模块为默认模块，tp5默认情况是：php public/index.php index/websocket/start）
开启成功，查看端口已经被监听：
lsof -i:9501
演示效果如下：
服务器监听如下：
用户每刷新重连一次，fd标识都会改变。
更多关于thinkphp相关内容感兴趣的读者可查看本站专题：《thinkphp入门教程》、《thinkphp模板操作技巧总结》、《thinkphp常用方法总结》、《codeigniter入门教程》、《ci(codeigniter)框架进阶教程》、《zend framework框架入门教程》及《php模板技术总结》。
希望本文所述对大家基于thinkphp框架的php程序设计有所帮助。
