如何利用swoole搭建一個簡易聊天室
程序员文章站
2022-04-15 15:17:56
server = new swoole_websocket_server(self::HOST, self::PART); //监听连接事件 $this->server->on('open', [$this, 'onOpen']); //监听接收消息事件 $this->server->on('mes... ......
<?php
class chat
{
const host = '0.0.0.0';//ip地址 0.0.0.0代表接受所有ip的访问
const part = 82;//端口号
private $server = null;//单例存放websocket_server对象
private $connectlist = [];//客户端的id集合
public function __construct()
{
//实例化swoole_websocket_server并存储在我们chat类中的属性上，达到单例的设计
$this->server = new swoole_websocket_server(self::host, self::part);
//监听连接事件
$this->server->on('open', [$this, 'onopen']);
//监听接收消息事件
$this->server->on('message', [$this, 'onmessage']);
//监听关闭事件
$this->server->on('close', [$this, 'onclose']);
//设置允许访问静态文件
//$this->server->set([
// 'document_root' => '/grx/swoole/public',//这里传入静态文件的目录
// 'enable_static_handler' => true//允许访问静态文件
//]);
//开启服务
$this->server->start();
}
/**
* 连接成功回调函数
* @param $server
* @param $request
*/
public function onopen($server, $request)
{
echo $request->fd . '连接了' . php_eol;//打印到我们终端
$this->connectlist[] = $request->fd;//将请求对象上的fd，也就是客户端的唯一标识，可以把它理解为客户端id，存入集合中
}
/**
* 接收到信息的回调函数
* @param $server
* @param $frame
*/
public function onmessage($server, $frame)
{
echo $frame->fd . '来了，说：' . $frame->data . php_eol;//打印到我们终端
//将这个用户的信息存入集合
foreach ($this->connectlist as $fd) {//遍历客户端的集合，拿到每个在线的客户端id
//将客户端发来的消息，推送给所有用户，也可以叫广播给所有在线客户端
$server->push($fd, json_encode(['no' => $frame->fd, 'msg' => $frame->data]));
}
}
/**
* 断开连接回调函数
* @param $server
* @param $fd
*/
public function onclose($server, $fd)
{
echo $fd . '走了' . php_eol;//打印到我们终端
$this->connectlist = array_diff($this->connectlist, [$fd]);//将断开了的客户端id，清除出集合
}
}
$obj = new chat();
<!doctype html>
<html>
<head>
<meta charset="utf-8">
<title>聊天室</title>
<script src="http://libs.baidu.com/jquery/1.9.1/jquery.min.js"></script>
</head>
<body>
<textarea class="log" style="width: 100%; height: 500px;">
=======聊天室======
</textarea>
<input type="button" value="连接" onclick="link()">
<input type="button" value="断开" onclick="dis()">
<input type="text" id="text">
<input type="button" value="发送" onclick="send()">
<script>
function link(){
var url='ws://148.70.98.236:82';
socket=new websocket(url);
socket.onopen=function(){log1('连接成功')}
socket.onmessage=function(msg){log(msg.data);console.log(msg);}
socket.onclose=function(){log1('断开连接')}
}
function dis(){
socket.close();
socket=null;
}
function log1(var1) {
$('.log').append(var1+'\r\n');
}
function log(var1){
var v=$.parsejson(var1)
$('.log').append('用户'+v['no']+'说:'+v['msg']+'\r\n');
}
function send(){
var text=$('#text').val();
socket.send(text);
}
function send2(){
var json = json.stringify({'type':'php','msg':$('#text2').attr('value')})
socket.send(json);
}
</script>
</body>
</html>