Thinkphp AJAX长轮询实现PC和APP推送

发表于 2017年07月31日
PHP

逻辑：某个操作（比如新建一条公告）后，触发同时推送消息给APP或是移动WEB的所有用户或指定用户。

不论性能，总还是有人会用到吧，实现如下（基于Thinkphp5消息推送）：

/*
     * long轮询 API查询接口
     */
    public function id_log()
    {
        if (request()->isPost()) {
            $id = $this->param['id'];

            set_time_limit(0);
            $id_log = Db::name('table')->alias('c')
                ->join('table cc', 'c.youname=cc.youname', 'left')
                ->join('table a', 'cc.youname =a.youname ', 'left')
                ->join('table u', 'c.youname =u.youname ', 'left')
                ->field('')
                ->where('', $id)
                ->order('log_time desc')
                ->limit(1)
                ->select();

            while (true) {
                if ($id_log) {
                    $id_log_set = Db::name('table2')
                        ->where('', $id)
                        ->limit(1)
                        ->setField('log_flag', '1');
                    $this->response($id_log);
                }
                $this->wrong(404100);
                usleep(2000);
            }

        };
    }

* long轮询 API查询接口

public function id_log()

{

if (request()->isPost()) {

$id = $this->param['id'];

set_time_limit(0);

$id_log = Db::name('table')->alias('c')

->join('table cc', 'c.youname=cc.youname', 'left')

->join('table a', 'cc.youname =a.youname ', 'left')

->join('table u', 'c.youname =u.youname ', 'left')

->field('')

->where('', $id)

->order('log_time desc')

->limit(1)

->select();

while (true) {

if ($id_log) {

$id_log_set = Db::name('table2')

->where('', $id)

->limit(1)

->setField('log_flag', '1');

$this->response($id_log);

}

$this->wrong(404100);

usleep(2000);

}

};

}

换上你自己的表和相关的关联字段。

/**
 * 创建消息日志 触发操作方法
 * @param  string $log_content 日志内容
 * @param  string $log_type 日志类型
 * @param  int $log_c_id A用户ID
 * @param  string $log_user B用户ID
 * @param  string $log_admin PC
 * @param  string $log_status
 * @return array
 */
function createLog($log_c_id, $log_type, $log_content, $log_admin, $log_user,$log_status)
{
    $data = [
        'log_c_id' => $log_c_id,
        'log_ip' => get_client_ip(),
        'log_admin' => $log_admin,
        'log_time' => date("Y-m-d H:i:s", time()),
        'log_url' => get_url(),
        'log_type' => $log_type,
        'log_content' => $log_content,
        'log_user' => $log_user,
        'log_status'=>$log_status
    ];
    $logadd = \think\Db::name('table')->insertGetId($data);
    return $logadd;
}

/**

* 创建消息日志触发操作方法

* @param string $log_content 日志内容

* @param string $log_type 日志类型

* @param int $log_c_id A用户ID

* @param string $log_user B用户ID

* @param string $log_admin PC

* @param string $log_status

* @return array

function createLog($log_c_id, $log_type, $log_content, $log_admin, $log_user,$log_status)

{

$data = [

'log_c_id' => $log_c_id,

'log_ip' => get_client_ip(),

'log_admin' => $log_admin,

'log_time' => date("Y-m-d H:i:s", time()),

'log_url' => get_url(),

'log_type' => $log_type,

'log_content' => $log_content,

'log_user' => $log_user,

'log_status'=>$log_status

];

$logadd = \think\Db::name('table')->insertGetId($data);

return $logadd;

}

采用数据库存消息并检测和设计flag的形式推，不然离线消息就没法推了，同样的要修改成你自己的数据结构！

    var getting = {
        url: '{:url("youapi/url")}',
        dataType: 'json',
        success: function (res) {
            $(".count").text($('.llt').children().size());
            $(".llt").remove();
            if(res.length!=null){
                $.each(res, function (index, item) {
                    $(".notification").append('<li class="llt" data-ccid="' + item.id + '"><a href="{:url("admin/carloan/edit")}?id='+item.log_c_id+'"><span class="label label-info"><i class="icon-bullhorn"></i></span><span class="message">' + item.u_name + '：' + item.log_content + '</span><span class="time"><span class="liveTime">' + item.log_time + '</span></span></a></li>');
                });
            }else{

            }

        }
    };
    //关键在这里，Ajax定时访问服务端，不断获取数据 ，这里是1秒请求一次。
    window.setInterval(function () {
        $.ajax(getting)
    }, 1000);

var getting = {

url: '{:url("youapi/url")}',

dataType: 'json',

success: function (res) {

$(".count").text($('.llt').children().size());

$(".llt").remove();

if(res.length!=null){

$.each(res, function (index, item) {

$(".notification").append('<li class="llt" data-ccid="' + item.id + '"><a href="{:url("admin/carloan/edit")}?id='+item.log_c_id+'">' + item.u_name + '：' + item.log_content + '' + item.log_time + '</a></li>');

});

}else{

}

};

//关键在这里，Ajax定时访问服务端，不断获取数据，这里是1秒请求一次。

window.setInterval(function () {

$.ajax(getting)

}, 1000);

好了，大概就这样，之前写过相关的文章：

Comet 反Ajax: 基于jQuery与PHP实现Ajax长轮询(LongPoll)

PHP网络通信引擎的选择