php使用swoole扩展搭建简单的在线实时聊天室，附带源码和界面预览。前端页面使用html5 websocket。
预览地址：http://zixuephp.net/chat.html
一、websocket
客户端完整源码查看：view-source:http://zixuephp.net/chat.html
websocket客户端：
//client.html
$(function(){
var wsname = $('.wsname1').text();
var wsimg = $('.chatheadimg').attr('src');
var wsServer = 'wss://zixuephp.net/ws';
var websocket = new WebSocket(wsServer);
websocket.onopen = function (event) {
layer.msg('聊天室连接成功！');
websocket.send('{"type":"1","name":"'+wsname+'","msg":"上线了！","self":"0","img":"'+wsimg+'"}');
};
websocket.onclose = function (event) {
//console.log("连接关闭！");
websocket.send('{"type":"3","name":"'+wsname+'","msg":"下线了！","self":"0","img":"'+wsimg+'"}');
};
websocket.onmessage = function (event) {
//console.log(event.data);
var chatmessage = JSON.parse(event.data);
if(chatmessage){
var ctype = chatmessage['type'];
var cself = chatmessage['self'];
var cname = chatmessage['name'];
var ctime = chatmessage['time'];
var cmsg = decodeURIComponent(chatmessage['msg']);
var cimg = chatmessage['img'];
var person = chatmessage['person'];
if(ctype == 1){
if( cself== 0){
layer.msg('【'+cname+'】'+cmsg);
}
$('.persion1').text(person);
}else if (ctype == 2){
var html ='';
if( cself == 1){
html = "n" +
" n" +
" "+cname+" n" +
" "+ctime+"n" +
" n" +
" n" +
" n" +
" " +
" n" +
" "+cmsg+"n" +
" n" +
" ";
}else{
html = "n" +
" n" +
" "+cname+" n" +
" "+ctime+"n" +
" n" +
" n" +
" n" +
" n" +
" n" +
" "+cmsg+"n" +
" n" +
" ";
}
$('.chatdetails').append(html);
$('.persion1').text(person);
$(".chatdetails").animate({scrollTop:$('.chatdetails')[0].scrollHeight},200);
}else if(ctype == 3){
$('.persion1').text(person);
layer.msg('【'+cname+'】'+cmsg);
}
}
};
websocket.onerror = function (event, e) {
layer.msg('聊天室错误'+event.data);
};
$(".chatsend").click(function(){
var chatcon = '';
chatcon = $('.chatcontent textarea').val();
websocket.send('{"type":"2","name":"'+wsname+'","msg":"'+encodeURIComponent(chatcon)+'","self":"0","img":"'+wsimg+'"}');
$('.chatcontent textarea').val(' ');
$('.chatcontent textarea').focus();
});
window.onunload = function() {
websocket.send('{"type":"3","name":"'+wsname+'","msg":"下线了！","self":"0","img":"'+wsimg+'"}');
}
//心跳
setTimeout(function(){
setInterval(function(){
websocket.send('{"type":"4","name":"","self":"","img":"');
},35000);
},5000);
});二、php swoole
swoole服务端：
需要安装php swoole扩展才能运行。编译安装的php如果没有swoole扩展的安装方法：http://zixuephp.net/article-430.html
set([ 'daemonize' => true, 'worker_num' => 1, 'heartbeat_check_interval' => 60, //每60s检查一次心跳，遍历一次所有连接 'heartbeat_idle_time' => 120, //在这个时间内没有向服务器发送任何数据，此连接将被强制关闭 'log_file' => '/usr/local/openresty/nginx/html/swoole.log' ]); //连接用户名映射 $ws->personList = []; //mysql连接 $ws->mysql = null; //监听WebSocket连接打开事件 $ws->on('open', function ($ws, $request) { //var_dump($request->fd); //var_dump($request->get); //var_dump($request->server); $ws->push($request->fd, '{"type":"2","name":"☺php自学网","msg":"哈喽~","self":"0","img":"/static/images/visitor.png","time":"-_-"}'); }); //监听WebSocket消息事件 $ws->on('message', function ($ws, $frame) { $message = null; $message = $frame->data; $person = count($ws->connections); file_put_contents('/usr/local/openresty/nginx/html/swoole_chat.log', date("Y-m-d H:i:s",time()) . rawurldecode($message) . "rn", FILE_APPEND); //聊天内容记录 $message = json_decode($message, true); $message['self'] = 0; $message['person'] = $person; $message['time'] = date('Y-m-d H:i:s', time()); $message['person_list'] = $ws->personList; //记录连接和人名 if (isset($message['name']) && !empty($message['name'])) { $ws->personList[$frame->fd] = $message['name']; } //下线处理 if (isset($message['type']) && $message['type'] == 3) { if (isset($ws->personList[$frame->fd])) { unset($ws->personList[$frame->fd]); } } //发送聊天消息 foreach ($ws->connections as $fd) { $message['person_list'] = $ws->personList; //返回心跳数据 if (isset($message['type']) && $message['type'] == 4) { $ws->push($frame->fd, json_encode($message)); break; } if ($fd == $frame->fd) { $message['self'] = 1; //自己 $ws->push($fd, json_encode($message)); } else { $message['self'] = 0; $ws->push($fd, json_encode($message)); } } //发送机器人消息 $msg = null; //机器人1 if (isset($message['msg']) && $message['type'] == 2) { $rebotMsg = file_get_contents('http://api.qingyunke.com/api.php?key=free&appid=0&msg=' . trim(urldecode($message['msg']))); if (!empty($rebotMsg)) { $chatCon = json_decode($rebotMsg, true); if ($chatCon['result'] == 0) { $msg = $chatCon['content']; } } } if (!empty($msg)) { foreach ($ws->connections as $fd) { $message['self'] = 0; $message['msg'] = $msg; $message['name'] = '☺菲菲-机器人'; $messageJson = json_encode($message); $ws->push($fd, $messageJson); } } $msg = null; //机器人2 if (isset($message['msg']) && $message['type'] == 2) { $rebotMsg = file_get_contents('http://www.tuling123.com/openapi/api?key=ffeabab48272433db2cdb9dd17f8bc91&info=' . trim(urldecode($message['msg']))); if (!empty($rebotMsg)) { $chatCon = json_decode($rebotMsg, true); if ($chatCon['code'] == 100000) { $msg = $chatCon['text']; } } } if (!empty($msg)) { foreach ($ws->connections as $fd) { $message['self'] = 0; $message['msg'] = $msg; $message['name'] = '☺图灵-机器人'; $messageJson = json_encode($message); $ws->push($fd, $messageJson); } } $msg = null;//机器人3 if (isset($message['msg']) && $message['type'] == 2) { $rebotMsg = file_get_contents('https://api.ownthink.com/bot?spoken=' . trim(urldecode($message['msg']))); if (!empty($rebotMsg)) { $chatCon = json_decode($rebotMsg, true); if ($chatCon['message'] == 'success') { $msg = $chatCon['data']['info']['text']; } } } if (!empty($msg)) { foreach ($ws->connections as $fd) { $message['self'] = 0; $message['msg'] = $msg; $message['name'] = '☺思知-机器人'; $messageJson = json_encode($message); $ws->push($fd, $messageJson); } } }); //监听WebSocket连接关闭事件 $ws->on('close', function ($ws, $fd) { //echo "client-{$fd} is closedn"; if (isset($ws->personList[$fd])) { unset($ws->personList[$fd]); } }); //mysql连接 function mysql_conn($ws) { $swoole_mysql = new SwooleCoroutineMySQL(); $swoole_mysql->connect([ 'host' => '127.0.0.1', 'port' => 3306, 'user' => 'root', 'password' => '123456', 'database' => 'zixuephp', ]); $ws->mysql = $swoole_mysql; } $ws->on('WorkerStart', function ($ws, $worker_id) { //防止重复执行 if ($worker_id == 0) { mysql_conn($ws); //定时器 swoole_timer_tick(60000, function () use ($ws) { $res = $ws->mysql->query("SELECt id,title,seo FROM post ORDER BY RAND() LIMIT 1"); if (!$res) { //mysql断线重连 mysql_conn($ws); } else { foreach ($ws->connections as $fd) { $json['type'] = 2; $json['name'] = '☺php自学网-主动推送-推荐阅读'; $json['msg'] = "" . $res[0]['title'] . "" . "" . $res[0]['seo'] . "
"; $json['self'] = 0; $json['img'] = "/static/images/push.png"; $json['person'] = count($ws->connections); $json['time'] = date('Y-m-d H:i:s', time()); $ws->push($fd, json_encode($json)); } } }); } }); $ws->start();
三、nginx配置代理转发
location /ws {
proxy_pass http://127.0.0.1:9501;
proxy_read_timeout 60s;
proxy_http_version 1.1;
proxy_set_header Upgrade $http_upgrade;
proxy_set_header Connection 'Upgrade';
}四、php运行服务端
nohup /usr/bin/php server.php &
[root@zixuephp /]# nohup /usr/bin/php server.php &
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）