PHP实现服务器推送第一种方案

86 阅读 0 评论 57 点赞

我是靠谱客的博主甜甜唇膏，最近开发中收集的这篇文章主要介绍PHP实现服务器推送第一种方案，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

PHP实现服务器推送第一种方案

ps：本人亲测，阿里云2核4G5M的服务器性价比很高，新用户一块多一天，老用户三块多一天，最高可以买三年，感兴趣的可以戳一下：阿里云折扣服务器

1、PHP页面内容
<?php
    //开启session
    session_start();
    //引入数据库查询类
    require('../model/talking.class.php');
    //实例化一个类
    $obj=new talking_msg();
    //如果传入的time为空值，则退出
    if(empty($_POST['time'])){
        exit();
    }
    //前一次查询的结果条数
    $msg_count1=$_POST['msg_count1'];
    //设置脚本最大执行时间，单位为秒，如果为零，则没有时间限制
    set_time_limit(0);
    $i=0;
    //当前用户ID
    $cid=$_SESSION['userid'];
    //建立无限循环
    while(true){
        //设置下面的代码延迟执行时间0.5秒，单位微秒
        usleep(500000);
        $i++;
        //执行查询，看是否有数据更新
        $res2=$obj->tk_msg_up($cid,$msg_count1);
        $msg_count2=$res2->num_rows;
        //如果有数据更新，则直接返回给客户端,并结束本次请求
        if($msg_count2!=0){
            $row2=$res2->fetch_assoc();
            $arry=array('bid'=>$row2['bid'],'msg'=>$row2['msg'],'msg_time'=>$row2['msg_time']);
            echo json_encode($arry);
            exit();
        }
        //如果没有数据更新，服务器$_POST['time']*0.5秒之后告诉客户端无数据
        if($i==$_POST['time']){
            $arry=array('bid'=>"0",'msg'=>"0",'msg_time'=>"0");
            echo json_encode($arry);
            exit();
        }
    }
?>

2、JQ内容
$(document).ready(function(){
        var msg_count1=$("#msg_count1").val();
        stop=$.ajax({
            async:true,
            url:"control/do_talking_select.php",
            type:"post",
            //timeout:20000,  //设置请求超时时间为8秒，单位为毫秒
            dataType:"json",
            data:{"time":20,"msg_count1":msg_count1},
            global:false,
            success:function(data){
                var a=data.bid;
                alert(a);
                //程序未完成，还需要设置JS的定时任务（轮询）setInterval
            }
        });
    }
);