阅读模式:

php swoole搭建简单的聊天室

查看:2958  回复:0  类型:  来源:php自学网  标签 html5 php swoole

        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 = "<div class=\"clearfix chatmessage\">\n" +
                        "                                    <div class=\"chatnametime rrn\">\n" +
                        "                                            <span>"+cname+"</span>&nbsp;&nbsp;\n" +
                        "                                            <span>"+ctime+"</span>\n" +
                        "                                    </div>\n" +
                        "                                    <div class=\"chatimgcon\">\n" +
                        "                                        <div class=\"fr\">\n" +
                        "                                            <img src=\""+cimg+"\" />" +
                        "                                        </div>\n" +
                        "                                        <div class=\"fr chcon\">"+cmsg+"</div>\n" +
                        "                                    </div>\n" +
                        "                                </div>";
                }else{
                    html = "<div class=\"clearfix chatmessage\">\n" +
                        "                                    <div class=\"chatnametime\">\n" +
                        "                                            <span>"+cname+"</span>&nbsp;&nbsp;\n" +
                        "                                            <span>"+ctime+"</span>\n" +
                        "                                    </div>\n" +
                        "                                    <div class=\"chatimgcon\">\n" +
                        "                                        <div class=\"fl\">\n" +
                        "                                            <img src=\""+cimg+"\" />\n" +
                        "                                        </div>\n" +
                        "                                        <div class=\"fl chcon\">"+cmsg+"</div>\n" +
                        "                                    </div>\n" +
                        "                                </div>";
                }

                $('.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

//server.php
//创建websocket服务器对象,监听0.0.0.0:9501端口
$ws = new swoole_websocket_server("0.0.0.0", 9501);

$ws->set([
    'daemonize' => true,
    'worker_num' => 1,
    'heartbeat_check_interval' => 60,  //每60s检查一次心跳,遍历一次所有连接
    'heartbeat_idle_time' => 120,  //在这个时间内没有向服务器发送任何数据,此连接将被强制关闭
    'log_file' => '/usr/local/php/var/logs/swoole.log'
]);

//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {
    //var_dump($request->fd);
    //var_dump($request->get);
    //var_dump($request->server);
    //$ws->push($request->fd, $request->fd);
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    $message = '';
    $message = $frame->data;
    $person = count($ws->connections);
    foreach($ws->connections as $fd){
        if($fd == $frame->fd){
            $message = json_decode($message,true);
            $message['self'] =1;
            $message['time'] =date('Y-m-d H:i:s',time());
            $message['person'] = $person;
            $message = json_encode($message);
            $ws->push($fd,$message);
        }else{
            $message = json_decode($message,true);
            $message['self'] =0;
            $message['time'] =date('Y-m-d H:i:s',time());
            $message['person'] = $person;
            $message = json_encode($message);
            $ws->push($fd, $message);
        }
    }
    //echo "message:".$message."\n";
});

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    //echo "client-{$fd} is closed\n";
});

$ws->start();

三、php运行服务端

    nohup /usr/bin/php server.php &

[root@zixuephp /]# whereis php
php: /usr/bin/php /usr/local/php
[root@zixuephp /]# nohup /usr/bin/php server.php &
分享到:
0 0

*有问题之处烦请在评论中指出非常感谢!
不是我想要的内容,继续搜索:

扫描二维码手机查看

发布评论:


登录:
  表情:
评论话题
推荐阅读:
centos 7 修改系统屏幕分辨率   阅读:41070javascript获取两个日期间的所有日期   阅读:5901移动端js触摸touch详解(附带案例源码)   阅读:15485把php session 会话保存到redis   阅读:6600分享:淘宝技术这十年   阅读:4323Mysql在大型网站的应用架构演变   阅读:4151面试的时候回去等通知,等电话的真实意思   阅读:22286移动端js触摸touch详解(附带案例源码)   阅读:15485centos 7 安装 nginx-1.11.10   阅读:7774“米粉节”背后的故事——小米网抢购系统开发实践   阅读:3721什么是天使轮?什么是A轮融资?B轮融资?   阅读:4252centos 7 添加 redis 3.2.9 开机启动脚本   阅读:8681mysql5.7主从同步中binlog同步模式详解   阅读:5696shell脚本批量删除几天前的文件   阅读:8713php显示刚刚、几分钟前、几小时前、几天前的函数   阅读:7628php连接redis   阅读:5210解决 nginx 413 request entity too large   阅读:4035解决 nginx 413 request entity too large   阅读:4035什么是天使轮?什么是A轮融资?B轮融资?   阅读:4252“米粉节”背后的故事——小米网抢购系统开发实践   阅读:3721HTTP 1.1 协议详解   阅读:9216php 生成图片,给图片加水印   阅读:5158centos 7 安装 mysql-5.7   阅读:6235ajax+php 实现一个简单的在线聊天室功能(附带源码)   阅读:8466linux top命令详解   阅读:8537TCP的三次握手(建立连接)和四次挥手(关闭连接)   阅读:2681mysql数据一键导出到csv文件   阅读:5109php打印三角形   阅读:7852centos 7 安装 mysql-5.7   阅读:6235Mysql在大型网站的应用架构演变   阅读:4151用php从1乘到100的值   阅读:5788php 统计网页打开耗时和脚本运行内存   阅读:6253shell脚本批量删除几天前的文件   阅读:8713centos7中颁发CA证书并开启web https   阅读:6076人性漫画:打工与创业的残酷区别   阅读:4326javascript对cookie操作详细代码函数   阅读:4896centos7.3安装mongodb3.6   阅读:6737php冒泡排序法   阅读:13129最新centos7 搭建LNMP环境(centos7.2+php7+mysql5.7+nginx1.11+redis3.2)   阅读:10113HTTP 1.1 协议详解   阅读:9216nginx安装mysql和json模块   阅读:4056移动端js触摸touch详解(附带案例源码)   阅读:15485php设置cookie为HttpOnly防止XSS攻击   阅读:11656TCP的三次握手(建立连接)和四次挥手(关闭连接)   阅读:2681mysql数据库性能的基本优化   阅读:4180纯干货,程序员面试的超实用技巧   阅读:3854php压缩页面的html代码一行显示   阅读:6560最简单的Banner轮播淡入淡出效果代码及实现思路(附带源码)   阅读:12358mysql共享锁和排他锁详解   阅读:6663Nginx 配置文件详解   阅读:4243