首页 / PHP / php加swoole加mysql仿webqq及时聊天

php加swoole加mysql仿webqq及时聊天

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了php加swoole加mysql仿webqq及时聊天，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含16812字，纯文字阅读大概需要25分钟。

内容图文

本篇文章的内容是php加swoole加mysql 仿webqq及时聊天，现在分享给大家，有需要的朋友可以参考一下

一、效果图
php加swoole加mysql仿webqq及时聊天 - 文章图片

二、目录结构
php加swoole加mysql仿webqq及时聊天 - 文章图片

images : 存放图片
js ： js文件
swoole

|----action.php     数据库操作类
|----config.php     数据库配置文件
|----websocket.php     swoole创建websocket协议文件

index.php : 聊天首页
login.html : 登录页面
webqq.sql : SQL数据库文件

三、数据库结构
php加swoole加mysql仿webqq及时聊天 - 文章图片

四、代码部分
4.1、config.php 数据库配置文件

<?php
$database = array(
    'host'=>'127.0.0.1',
    'user'=>'root',
    'password'=>'4f54dd',
    'port'=>3306,
    'database'=>'webqq',
    'charset'=>'utf8'
);

4.2、action.php数据库操作类

<?php
class Action
{
    private $conn;
    public function __construct()
    {
        require_once (__DIR__.'/config.php');
        $this->conn = mysqli_connect($database['host'],$database['user'],$database['password'],$database['database']) or die ('Connect mysql failed ~~'.mysqli_connect_error());
    }

    //login
    public function login($nickname,$username,$password)
    {
        session_start();
        $sql = " select `id` from `users` where `username` = '{$username}' ";
        if($query = $this->conn->query($sql)) {
            $row = mysqli_fetch_assoc($query);
            $now = date('Y-m-d H:i:s');
            if($row['id']) {
                $sql = " update `users` set `nickname` = '{$nickname}' , `username` = '{$username}' ,`password` = md5('{$password}') , `login_time` = '{$now}' , `login_num` = (`login_num` + 1) where `id` = {$row['id']} ";
            } else {
                $sql = " insert into `users` (`nickname`,`username`,`password`,`login_time`,`login_num`) values ('{$nickname}' , '{$username}' , md5('{$password}') , '{$now}' ,'1')";
            }
            $this->conn->query($sql);
            $user_id = $this->conn->insert_id;
            $_SESSION['uid'] = $row['id'] ? $row['id'] :  $user_id;
            $_SESSION['nickname'] = $nickname;
            return 1;
        } else {
            return 0;
        }
    }

    //add friend
    public function addFriend($from_uid,$to_uid)
    {
        $sql = " select * from `friend` where `from_uid` = '{$from_uid}' and `to_uid` = '{$to_uid}' ";
        if($query = $this->conn->query($sql)) {
            $is_friend = mysqli_fetch_assoc($query);
            if(!$is_friend['to_uid']){
                if($from_uid == $to_uid) {
                    return 2;
                } else {
                    $sql = " select `nickname` from `users` where `id` = '{$to_uid}' ";
                    $query = $this->conn->query($sql);
                    $ret = mysqli_fetch_assoc($query);
                    $nickname = $ret['nickname'];
                    if($nickname){
                        $sql = " insert into `friend` (`from_uid`,`to_uid`,`nickname`) values ('{$from_uid}','{$to_uid}','{$nickname}') ";
                        $this->conn->query($sql);
                        return array('to_uid'=>$to_uid,'nickname'=>$nickname);
                    } else {
                        return 3;
                    }
                }
            } else {
                return 4;
            }
        } else {
            return 0;
        }
    }

    //friend lists
    public function friendLists($from_uid)
    {
        $sql = " select `id`,`nickname` from `users` where `id` != '{$from_uid}' ";
        if($query = $this->conn->query($sql)) {
            $lists = [];
            while ($row = mysqli_fetch_assoc($query)) {
                $sql_1 = " select `fd` from `fd_tmp` where `uid` = '{$row['id']}' ";
                $query_1 = $this->conn->query($sql_1);
                $ret = mysqli_fetch_assoc($query_1);
                $row['status'] = $ret['fd'] ? 'online' : 'offline' ;
                $lists[] = $row;
            }
            return $lists;
        } else {
            return 0;
        }
    }


    //load history message
    public function loadHistory($from_uid,$to_uid)
    {
        $sql = " select `from_uid`,`to_uid`,`message`,`send_time` from `chat` where  ( (`from_uid` = '{$from_uid}' and `to_uid` = '{$to_uid}') or (`to_uid` = '{$from_uid}' and `from_uid` = '{$to_uid}') ) order by `send_time` desc";
        if($query = $this->conn->query($sql)) {
            $message = [];
            while ($row = mysqli_fetch_assoc($query)) {
                $message[] = $row;
            }
            return $message;
        } else {
            return 0;
        }
    }

    //send message
    public function sendMessage($from_uid,$to_uid,$message)
    {
        $time = date('Y-m-d H:i:s');
        $sql = " insert into `chat` (`from_uid`,`to_uid`,`message`,`send_time`) values ('{$from_uid}','{$to_uid}','{$message}','{$time}') ";
        if($query = $this->conn->query($sql)) {
            $last_id = $this->conn->insert_id;
            return $last_id;
        } else {
            return 0;
        }
    }

    //get fd 
    public function getFd($uid)
    {
        $sql = " select `fd` from `fd_tmp` where `uid` = '{$uid}' ";
        if($query = $this->conn->query($sql)) {
            $row = mysqli_fetch_assoc($query);
            return $row['fd'] ? $row['fd'] : 0;
        } else {
            return 0;
        }
    }

    //bind fd 
    public function bindFd($uid,$fd)
    {
        $sql = " insert into `fd_tmp` (`fd`,`uid`) values ('{$fd}','{$uid}') ";
        if($this->conn->query($sql)) {
            return $fd;
        } else {
            return 0;
        }
    }

    //unbind fd 
    public function unbindFd($fd)
    {
        $sql = " delete from `fd_tmp` where `fd` = '{$fd}' ";
        if($this->conn->query($sql)) {
            return 1;
        } else {
            return 0;
        }
    }

    public function __destruct()
    {
        mysqli_close($this->conn);
    }
}

//process ajax request
if($_POST && isset($_POST['typ']))
{
    $action = new Action();
    switch ($_POST['typ']) {
        case 'login':
            $ret = $action->login($_POST['nickname'],$_POST['username'],$_POST['password']);
            break;
        case 'addFriend':
            $ret = $action->addFriend($_POST['from_uid'],$_POST['to_uid']);
            break;
        case 'friendLists':
            $ret = $action->friendLists($_POST['from_uid']);
            break;
        case 'loadHistory':
            $ret = $action->loadHistory($_POST['from_uid'],$_POST['to_uid']);
            break;
        case 'sendMessage':
            $ret = $action->sendMessage($_POST['from_uid'],$_POST['to_uid'],$_POST['message']);
            break;
    }
    echo json_encode(array('data'=>$ret));
}

4.3、websocket.php文件

<?php
require_once(__DIR__.'/action.php');
new Websocket();
class Websocket
{
    private $serv;
    private $action;

    public function __construct()
    {
        $this->action = new action();
        $this->serv = new swoole_websocket_server('0.0.0.0',9502);
        $this->serv->on('open',array($this,'onOpen'));
        $this->serv->on('message',array($this,'onMessage'));
        $this->serv->on('close',array($this,'onClose'));
        $this->serv->start();
    }

    public function onOpen($server,$request)
    {
        echo "Welcome {$request->fd} \n";
    }

    public function onMessage($server,$request)
    {
        $data = json_decode($request->data);
        $from_uid = $data->from_uid;
        $to_uid = $data->to_uid;
        $message = $data->message;
        $this->action->unbindFd($from_uid);
        $from_fd = $this->action->bindFd($from_uid,$request->fd);
        if($from_fd) {
            $to_fd = $this->action->getFd($to_uid);
            if($to_fd) {
                $server->push($to_fd,$message);
            } 
        } else {
            $server->push($request->fd,'bind from_fd failed ~~');
        }
    }

    public function onClose($server,$fd)
    {
        $this->action->unbindFd($fd);
        echo "Goodbye {$fd} \n";
    }
}

4.4、index.php首页聊天文件

<?php
session_start();
if(!$_SESSION['nickname'] && !$_SESSION['uid']){
    echo '<script>window.location.href="login.html";</script>';
}
?>
<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
    <meta name="apple-mobile-web-app-capable" content="yes" />
    <meta name="apple-touch-fullscreen" content="yes" />
    <meta name="format-detection" content="telephone=no"/>
    <meta name="apple-mobile-web-app-status-bar-style" content="black" />
    <META HTTP-EQUIV="pragma" CONTENT="no-cache"> 
<META HTTP-EQUIV="Cache-Control" CONTENT="no-cache, must-revalidate"> 
<META HTTP-EQUIV="expires" CONTENT="0">
    <meta name="format-detection" content="telephone=no" />
    <meta name="msapplication-tap-highlight" content="no" />
    <meta name="viewport" content="initial-scale=1,maximum-scale=1,minimum-scale=1" />
    <title>webqq----swoole</title>
    <script type="text/javascript" src="js/jquery.js"></script>
    <style type="text/css">
    html,body{margin:0;padding: 0;background-color: #eee;background-image: url("./images/1.jpg") }
    .userlists{width:280px;height: 620px;border:1px #222 solid;box-shadow:3px 3px 10px #222;border-radius:5px;margin:100px 0px 0px 100px;background-color: #fff}
    .userlists-title{background-color: #222;color:#fff;height: 50px;padding-top:10px;text-align: center;border-radius: 5px 5px 0px 0px;position: relative;}
    .lists_left{height: 500px;overflow-y:scroll;}
    .lists_left::-webkit-scrollbar {display:none}
    .lists_left ul,li{margin:0px;padding:0px;list-style: none}
    .lists_left li{border-bottom:  1px #666 solid;height: 35px;line-height: 35px;}
    .lists_left li a{text-decoration: none;color:#000;height: 100%;display: block;padding-left: 10px}
    .tools{border-radius: 0px 0px 5px 5px;}
    .h10{height: 10px;}
    .h30{height: 500px}
    .circular{height: 30px;width: 30px;border-radius: 30px;background-color: #fff;margin:0 auto;}
    .find{height: 40px;line-height:40px;text-align:center;background-color: #ccc}
    .find input{outline: none}
    .dialogue{width: 600px;height: 600px;background-color: #fff;position: absolute;top:100px;left: 450px;border-radius: 5px；border:1px #222 solid;box-shadow:3px 5px 5px #222;border-radius:5px;display: none;}
    .close{border:1px #fff solid;border-radius:5px;display: inline-block;width: 50px;height: 25px;line-height: 25px;position: absolute;right: 15px;top:12px;}
    .send{height: 50px;line-height: 50px;background-color: #222;border-radius: 0px 0px 5px 5px;text-align: center; }
    .send input[name='content']{height: 30px;width:480px;padding:0px 5px;outline: none}
    .send input[name='sendBtn']{height: 34px;width:80px;display: inline-block;}
    .chat-line{width:360px;border-radius: 10px;margin:10px;padding: 10px;word-wrap:break-word}
    .from{border:1px red solid;float: right;}
    .to{border:1px green solid;float: left;}
    .all{position: absolute;top:0;right: 100px}
    .scroll_box{position: relative;overflow-y:scroll;height: 500px};
    .scroll_box::-webkit-scrollbar {display:none}
    .lists  {position: absolute;left: 0;top: 0;}

    </style>
</head>
<body>
    <p class="userlists">
        <p class="userlists-title"><?php echo $_SESSION['nickname'];?><br>好友列表</p>
        <p class="lists_left">
            <ul id="friend_lists">
            </ul>
        </p>
        <p class="userlists-title tools"><p class="h10"></p><p class="circular"></p></p>
    </p>

    <p class="dialogue">
        <p class="userlists-title">正在与 <t id="uname">.....</t> 聊天 <span class="close">关闭</span></p>
        <p class="scroll_box">
            <p class="lists " id="chat-box">
            </p>
        </p>
        <p class="send">
            <input type="hidden" name="to_uid" >
            <input type="text" name="content" placeholder="发送内容">
            <input type="button" name="sendBtn" id="sendMessage" value="发送">
        </p>
    </p>



    <script type="text/javascript">
        $(function(){
            $.post("./swoole/action.php",{from_uid:<?php echo $_SESSION['uid'];?>,typ:'friendLists'},function(res){
                var r = eval("(" + res + ")");
                if(r.data) {
                    var h = "";
                    for(var i = 0; i< r.data.length; i++) {
                        var status = r.data[i].status =="offline" ? "离线" : "在线" ; 
                        h += '<li><a data-id="' + r.data[i].id + '" data-nickname="' + r.data[i].nickname + '" class="friend" href="javascript:;">' +  r.data[i].nickname + " &nbsp;( " + status +' ) </a></li>';
                    }
                    $("#friend_lists").html(h);
                }
            });


            $("#friend_lists").on("click",".friend",function(){
                var to_uid = $(this).attr("data-id");
                var nickname = $(this).attr("data-nickname");
                $("#uname").html(nickname);
                $("input[name='to_uid']").val(to_uid);
                $.post("./swoole/action.php",{from_uid:<?php echo $_SESSION['uid'];?>,to_uid:to_uid,typ:"loadHistory"},function(res){
                    var r = eval("(" + res + ")");
                    if(r.data) {
                        var h = "";
                        for (var i = r.data.length - 1; i >= 0; i--) {
                            if(r.data[i].from_uid == <?php echo $_SESSION['uid'];?>) {
                                h += '<p class="chat-line from">' + r.data[i].message + '</p>';
                            } else {
                                h += '<p class="chat-line to">' + r.data[i].message + '</p>';
                            }
                        }
                        $("#chat-box").html(h);
                        srcollBox()
                    }
                });
                $(".dialogue").show();
                

            });

            $("#sendMessage").on("click",function(){
                if($("input[name='content']").val()) {
                    srcollBox()
                    sendMessage();

                } else {
                    alert("please input your message~");
                }
                
            });
            $(document).keyup(function(evt){
                if(evt.keyCode == 13) {
                    if($("input[name='content']").val()) {
                        srcollBox()
                        sendMessage();
                    } else {
                        alert("please input your message~");
                    }
                }
            });

            $(".close").on("click",function(){
                $(".dialogue").hide();
            });
            function srcollBox(){
                var h = $(".lists").height();
                $(".scroll_box").scrollTop(h,4000)
            }
            srcollBox();

            if(window.WebSocket){
                var ws = new WebSocket("ws://192.168.0.140:9502");
                ws.onopen = function(evt){
                    console.log("Connect WebSocket succuess ~~ \n");
                }
                ws.onmessage = function(evt){
                    $("#chat-box").append('<p class="chat-line to">' + evt.data + '</p>');
                    srcollBox();
                    console.log("message on server : " + evt.data + "\n");
                }
                ws.onclose = function(evt){
                    console.log("WebSocket closed ~~\n");
                }
                ws.onerror = function(evt){
                    console.log("Connect WebSocket failed ~~\n");
                }
                function sendMessage(){
                    var params = {
                        from_uid : <?php echo $_SESSION['uid'];?>,
                        to_uid : $("input[name='to_uid']").val(),
                        message : $("input[name='content']").val(),
                        typ : "sendMessage"
                    };
                    var msg = JSON.stringify(params);
                    $("#chat-box").append('<p class="chat-line from">' + $("input[name='content']").val() + '</p>');
                    srcollBox();
                    $.post("./swoole/action.php",params,function(res){
                        var r = eval("(" + res + ")");
                        if(r.data) {
                            ws.send(msg);
                        } else {
                            alert("send message failed , insert mysql failed~~\n");
                        }
                    });
                    
                }
            } else {
                alert("Your browser does not support WebSocket !");
            }
        });
    </script>
</body>
</html>

4.5、login.html 登录文件

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <meta http-equiv="X-UA-Compatible" content="IE=edge" />
    <meta name="apple-mobile-web-app-capable" content="yes" />
    <meta name="apple-touch-fullscreen" content="yes" />
    <meta name="format-detection" content="telephone=no"/>
    <meta name="apple-mobile-web-app-status-bar-style" content="black" />
    <meta name="format-detection" content="telephone=no" />
    <meta name="msapplication-tap-highlight" content="no" />
    <meta name="viewport" content="initial-scale=1,maximum-scale=1,minimum-scale=1" />
    <title>webqq----swoole</title>
    <script type="text/javascript" src="./js/jquery.js"></script>
    <style type="text/css">
    html,body{margin:0;padding: 0;background-color: #eee}
    .login-form{background-color: #fff;width: 500px;height: 500px;margin:100px auto;border:1px #ccc solid;border-radius: 5px;box-shadow: 3px 3px 3px #666}
    h3{text-align: center;margin-top: 100px}
    .container{text-align: center;margin-top: 30px;}
    .container label{display: inline-block;width: 50px;}
    .container input{display: inline-block;height: 25px;line-height: 25px;padding: 0px 5px;width: 300px;outline: none}
    input[name='login']{background-color: #5aba1f;color:#fff;border:none;width: 150px;height: 30px;line-height: 30px;border-radius: 5px;margin-top: 30px;cursor: pointer;}
    .warning{border:2px #f00 solid;}
    </style>
</head>
<body>

    <form method="post" action="" class="login-form">
        <h3>WebQQ</h3>
        <p class="container"><label>昵称:</label><input type="text" name="nickname" placeholder="昵称" ></p>
        <p class="container"><label>帐号:</label><input type="text" name="username" placeholder="用户"></p>
        <p class="container"><label>密码:</label><input type="password" name="password" placeholder="密码"></p>
        <p class="container"><input type="button" name="login" value="登录"></p>
    </form>
    <script type="text/javascript">
        $(function(){
            $("input[name='login']").click(function(){
                var nickname = $("input[name='nickname']").val();
                var username = $("input[name='username']").val();
                var password = $("input[name='password']").val();
                if(nickname == ""){
                    alert("请设置昵称");
                    $("input[name='nickname']").focus();
                    $("input[name='nickname']").addClass("warning");
                    $("input[name='username']").removeClass("warning");
                    $("input[name='password']").removeClass("warning");
                } else if(username == "") {
                    alert("请输入帐号");
                    $("input[name='username']").focus();
                    $("input[name='nickname']").removeClass("warning");
                    $("input[name='username']").addClass("warning");
                    $("input[name='password']").removeClass("warning");
                } else if(password == "") {
                    alert("请输入密码");
                    $("input[name='password']").focus();
                    $("input[name='nickname']").removeClass("warning");
                    $("input[name='username']").removeClass("warning");
                    $("input[name='password']").addClass("warning");
                } else {
                    $("input[name='nickname']").removeClass("warning");
                    $("input[name='username']").removeClass("warning");
                    $("input[name='password']").removeClass("warning");
                    $.post("./swoole/action.php",{nickname:nickname,username:username,password:password,typ:'login'},function(res){
                        var r = eval("(" + res + ")");
                        if(r.data == "1"){
                            window.location.href="index.php";
                        } else {
                            alert("failed~~");
                        }
                    });
                }
            });
        });
    </script>
</body>
</html>

4.6、webqq.sql 数据结构文件

-- Adminer 4.1.0 MySQL dump

SET NAMES utf8;
SET time_zone = '+00:00';
SET foreign_key_checks = 0;
SET sql_mode = 'NO_AUTO_VALUE_ON_ZERO';

DROP TABLE IF EXISTS `chat`;
CREATE TABLE `chat` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `from_uid` int(10) unsigned NOT NULL,
  `to_uid` int(10) unsigned NOT NULL,
  `message` varchar(255) COLLATE utf8_unicode_ci NOT NULL,
  `send_time` timestamp NOT NULL DEFAULT '0000-00-00 00:00:00' ON UPDATE CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;


DROP TABLE IF EXISTS `fd_tmp`;
CREATE TABLE `fd_tmp` (
  `fd` int(10) unsigned NOT NULL,
  `uid` int(10) unsigned NOT NULL
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='FD值与用户ID绑定';


DROP TABLE IF EXISTS `friend`;
CREATE TABLE `friend` (
  `from_uid` int(10) unsigned DEFAULT NULL,
  `to_uid` int(10) unsigned NOT NULL,
  `nickname` varchar(45) COLLATE utf8_unicode_ci NOT NULL
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='好友列表';


DROP TABLE IF EXISTS `users`;
CREATE TABLE `users` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',
  `nickname` varchar(45) COLLATE utf8_unicode_ci NOT NULL COMMENT '昵称',
  `username` varchar(45) COLLATE utf8_unicode_ci NOT NULL COMMENT '登陆名称',
  `password` char(32) COLLATE utf8_unicode_ci NOT NULL COMMENT '登陆密码',
  `login_time` datetime NOT NULL COMMENT '最后登陆时间',
  `login_num` int(10) unsigned DEFAULT '0' COMMENT '登陆次数',
  PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci COMMENT='用户列表';


-- 2018-03-27 10:05:35

4.7、服务器环境centos7 + mariadb + swoole + apache + php7
注意事项：须安装swoole扩展，Linux服务器，PHP7+版本以上
进行项目根目录使用: php websocket.php 执行该文件

源码下载地址：https://pan.baidu.com/s/1sWY-...

以上就是php加swoole加mysql 仿webqq及时聊天的详细内容，更多请关注Gxl网其它相关文章！

内容总结

以上是互联网集市为您收集整理的php加swoole加mysql仿webqq及时聊天全部内容，希望文章能够帮你解决php加swoole加mysql仿webqq及时聊天所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/138058.html

来源：【匿名】

【上一篇】PHP与Sybase数据库的连接与使用【下一篇】PHP 5 数据对象 (PDO) 抽象层与 Oracle

更多 ►

【php加swoole加mysql仿webqq及时聊天】教程文章相关的互联网学习教程文章

为什么 PHP 程序员应该学习使用 Swoole【代码】【图】

最近两个月一直在研究 Swoole，研究成果即将在6.21正式开源发布，这段时间没有来水文章，趁着今天放假来水水吧。借助这篇文章，我希望能够把 Swoole 安利给更多人。虽然 Swoole 可能目前定位是一些高级 phper 的玩具，让中低级望而生畏，可能对一些应用场景也一脸懵逼，但其实没这么难的。在 Swoole 官网的自我介绍是“面向生产环境的 PHP 异步网络通信引擎”，首先 Swoole 它是一个网络应用的开发工具，它支持 Http、TCP、UDP、We...

php swoole 安装与使用【代码】

swoole 安装用的是centOS php安装目录：/usr/local/php php.ini配置文件路径：/usr/local/php/etc/php.ini 1、安装swoole cd /usr/local/src wget https://github.com/swoole/swoole-src/archive/v1.9.1-stable.tar.gz #版本不一样 https://github.com/swoole/swoole-src/releases tar zxvf v1.9.1-stable.tar.gz cd swoole-src-1.9.1-stable /usr/local/php/bin/phpize　　　　　　　　　　　　　　　　#查找对应的php-confi...

php安装swoole扩展【代码】

编译安装Swoole扩展是按照php标准扩展构建的。使用phpize来生成php编译配置，./configure来做编译配置检测，make进行编译，make install进行安装。请下载releases版本的swoole，直接从github主干上拉取最新代码可能会编译不过如果当前用户不是root，可能没有php目录的写权限，安装时需要sudo或者su如果是在git分支上直接git pull更新代码，重新编译前务必要执行make clean安装准备安装swoole前必须保证系统已经安装了下列软件php-5...

PHP swoole TCP服务端和客户端【代码】

服务端<?php $server = new swoole_server(‘127.0.0.1‘,9501,SWOOLE_PROCESS,SWOOLE_SOCK_TCP); $server->set(array(‘woker_num‘=>4,‘max_request‘=>1000 )); $server->on(‘connect‘,function($serv,$fd,$reactor_id) {echo "接收到来自$reactor_id"."的连接符$fd\n"; }); $server->on(‘receive‘,function ($serv,$fd,$reactor_id,$data) {echo "收到{$reactor_id}----{$fd}"."发来的数据$data\n";$serv->send($fd,"{$re...

PHP 当Swoole 遇上 ThinkPHP5【代码】

本文假设你已经有了 Linux 操作系统的 PHP 环境，强烈推荐使用 Vagrant 来搭建开发环境安装 Swoole PECL 拓展可以通过 pecl 命令或者通过源码包编译安装，本文采用 pecl 命令来安装 Swoole在命令行输入$ > pecl install swoole 安装 Swoole PECL 拓展，执行命令后通过php -m命令来检查 Swoole 是否安装成功，如果返回的拓展列表中包含swoole则表明已经安装成功，也可以通过phpinfo来检查 Swoole 是否安装成功。安装 ThinkPHP5 框架...

swoole和rabbitmq的区别【图】

RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。（推荐学习： swoole视频教程）RabbitMQ是一套开源（MPL）的消息队列服务软件，是由 LShift 提供的一个 Advanced Message Queuing Protocol (AMQP) 的开源实现，由以高性能、健壮以...

基于RabbitMQ和Swoole实现的一个完整的异步任务系统【图】

从最开始的使用http://www.gxlcms.com/wiki/1504.html" target="_blank">redis实现的单进程消费的异步任务系统到加入swoole的多进程消费模式，现在，我们的异步任务系统终于又能迈进一步。因为有了前面两个简单系统的经验，这回基于RabbitMQ的异步任务系统设计的的更加完善，包括多进程消费，异常重试等。系统介绍消费端架构图从图中可以看到，我们这个系统是一个基于事件的异步任务系统。就是说当一个事件产生时，生产者将事件抛给...

swoole日志记录NotdefinedError

swoole的系统日志，/tmp/swoole.log，总是记录Not defined Error，没有记录产生时间，也没有换行符。这种情况是怎么产生的？回复内容：swoole的系统日志，/tmp/swoole.log，总是记录Not defined Error，没有记录产生时间，也没有换行符。这种情况是怎么产生的？

swoole-1.8.1已发布，增加PSR-4命名空间类名

swoole-1.8.1 版本已发布，此版本是一个BUG修复版本，主要修复1.8.0版本存在的一些BUG，此外1.8.1版本增加了PSR-4命名空间风格的类名。命名空间示例：使用命名空间类风格，需要修改php.ini，增加swoole.use_namespace=On开启。使用命名空间类名后，旧式的下划线风格类名将不可用。 use Swoole\Http\Server;use Swoole\Http\Request;use Swoole\Http\Response;$serv = new Server(127.0.0.1, 9501);$serv...

Go,PHP,Swoole 并发测试详解【代码】【图】

Gopackage mainimport ("fmt"_ "fmt""net/http"_ "os")func main() {http.HandleFunc("/", handle)http.ListenAndServe("0.0.0.0:8082",nil)}func handle(w http.ResponseWriter,r *http.Request) {fmt.Fprint(w,"URL=",r.URL.Path)fmt.Println(r.RequestURI)}相关学习推荐：PHP编程从入门到精通PHP内置服务echo 1;Swoole$http = new Swoole\Http\Server("0.0.0.0", 9501);$http->on(request, function ($request, $response) {ech...

php使用swoole的应用场景有哪些？【代码】【图】

php使用swoole的应用场景有：1、实时收集定位数据实时输出，需要将所有的定位设备实时的接收，将实时的轨迹记录显示在地图上；2、只收集定位设备入库，需要把所有的定位设备上传的数据入库。php使用swoole的应用场景有：场景1 - 实时收集定位数据实时输出（例滴滴司机行驶轨迹）说明：需要将所有的定位设备实时的接收，将实时的轨迹记录显示在地图上注意点：第一点：web1服务器连接的用户1,2,3，web1广播信息时只能广播用户1，2，...

PHP Swoole 基本使用【代码】

背景项目中使用的PHP，但由于长耗时的任务，前端提交以后，需要服务端异步响应。服务器异步有多种方案，包括MQ，fsocket，Swoole等。Swoole 使用纯 C 语言编写，提供了 PHP 语言的异步多线程服务器，异步 TCP/UDP 网络客户端，异步 MySQL，异步 Redis，数据库连接池，AsyncTask，消息队列，毫秒定时器，异步文件读写，异步DNS查询。 Swoole内置了Http/WebSocket服务器端/客户端、Http2.0服务器端。最重要的是，完美支持PHP语言。于...

php为什么要使用swoole【图】

首先我们要知道Swoole是一个网络应用的开发工具，它支持 Http、TCP、UDP、WebSocket。使用理由如下：1、常驻内存，避免重复加载带来的性能损耗，提升海量性能。2、协程异步，提高对 I/O 密集型场景并发处理能力（如：微信开发、支付、登录等）。3、方便地开发 Http、WebSocket、TCP、UDP 等应用，可以与硬件通信。4、PHP 高性能微服务架构成为现实。（免费学习视频教程分享：php视频教程）常驻内存目前传统 PHP框架，在处理每个请...

php7如何安装swoole【代码】【图】

编译&安装cd swoole-src-2.0.6/ 下,1.使用phpize来生成php编译配置2.使用./configure 来做编译配置检测3.make进行编译，make install进行安装命令执行如下：[root@php7 swoole-src-2.0.6]# phpize [root@php7 swoole-src-2.0.6]# ./configure [root@php7 swoole-src-2.0.6]# make && make install4.make install后，如果正确，会出现以下内容[root@php7 swoole-src-2.0.6]# make install Installing shared extensions: /usr/l...

PHP - 技术教程分类

PHP 教程 PHP 简介 PHP 安装 PHP 语法 PHP 变量 PHP echo/print PHP EOF(heredoc) PHP 数据类型 PHP 类型比较 PHP 常量 PHP 字符串 PHP 运算符 PHP If...Else PHP Switch PHP 数组 PHP 数组排序 PHP 超级全局变量 PHP While 循环 PHP For 循环 PHP 函数 PHP 魔术常量 PHP 命名空间 PHP 面向对象 PHP 测验 PHP 表单 PHP 表单验证 PHP 表单 - 必需字段 PHP 完整表单实例 PHP $_GET 变量 PHP $_POST 变量 PHP 多维数组 PHP 日期 PHP 包含 PHP 文件 PHP 文件上传 PHP Cookie PHP Session PHP E-mail PHP Error PHP Exception PHP 过滤器 PHP 7 新特性 PHP MySQL 简介 PHP MySQL 连接 PHP MySQL 创建数据库 PHP MySQL 创建数据表 PHP MySQL 插入数据 PHP MySQL 插入多条数据 PHP MySQL 预处理语句 PHP MySQL 读取数据 PHP MySQL Where PHP MySQL Order By PHP MySQL Update PHP MySQL Delete PHP ODBC AJAX 简介 AJAX PHP AJAX 数据库 AJAX 实时搜索 AJAX 投票 PHP Array PHP Calendar PHP cURL PHP Date PHP Directory PHP Error PHP Filesystem PHP Filter PHP FTP PHP HTTP PHP Mail PHP Math PHP Misc PHP MySQLi PHP PDO PHP String PHP Zip PHP Timezones PHP 图像处理 PHP RESTful PHP PCRE PHP 可用的函数 PHP Composer php 全部

PHP - 最热教程

php如何取出数组的前几个元素 PHP变量什么时候释放 PHP如何实现在数据库随机获取几条记录如何解决php base64解码乱码 php主要用于哪些领域 Laravel 批量插入(insert)数据六款国内优秀免费wordpress主题推荐 React如何从后端获取数据并渲染到前端？纯PHP实现定时器任务（Timer），php实现...php该如何安装pdo_mysql扩展

首页 / PHP / php加swoole加mysql仿webqq及时聊天

php加swoole加mysql仿webqq及时聊天

内容导读

内容图文

内容总结

内容备注

内容手机端

【php加swoole加mysql仿webqq及时聊天】教程文章相关的互联网学习教程文章

推荐个好东西swoole，php如虎添翼

为什么 PHP 程序员应该学习使用 Swoole【代码】【图】

php swoole 安装与使用【代码】

php安装swoole扩展【代码】

PHP swoole TCP服务端和客户端【代码】

PHP 当Swoole 遇上 ThinkPHP5【代码】

swoole和rabbitmq的区别【图】

基于RabbitMQ和Swoole实现的一个完整的异步任务系统【图】

swoole日志记录NotdefinedError

swoole-1.8.1已发布，增加PSR-4命名空间类名

Go,PHP,Swoole 并发测试详解【代码】【图】

php使用swoole的应用场景有哪些？【代码】【图】

PHP Swoole 基本使用【代码】

php为什么要使用swoole【图】

php7如何安装swoole【代码】【图】

MYSQL - 相关标签

PHP - 相关标签

WEB - 相关标签

PHP - 技术教程分类

PHP - 最新教程

PHP - 最热教程