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

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

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
            }
        });
    }
);