1

对于投票的人来说，这不是一个绝对愚蠢的真正问题。

我已经用谷歌搜索和搜索了一个多月，但我找不到一个准确的例子，它实际上可以使用 php 和 mysql 进行 ajax 长轮询。最好想找到一个使用 mysql 和 codeigniter 的示例 ajax long polling。

任何人都会遇到这个问题并有一个很好的例子，请告诉我。

任何读到这篇文章并认为他们知道我正在寻找的 ajax 长轮询的人，请给我发电子邮件或在此处告诉我。我已经使用 Codeigniter 几乎完成了聊天应用程序，但我在客户端的 jquery/ajax 长轮询部分遇到了问题。我没有发布这个聊天应用程序，因为上次我发布另一个聊天应用程序时，我在这里有另一个开发人员抱怨我发布的代码太多。我准备将此代码发送给任何可以实际提供有效的 ajax 长轮询代码的人。

非常感谢。

4

1 回答 1

5

我想您将聊天消息存储在数据库中？所以一种方法看起来像这样：

最重要的是您需要在第一时间将服务器时间传递给用户，这是获取新聊天消息的关键，所以首先，我们这样做：

var time;
$.ajax( {
     url: 'http://yoursite.com/chat/get_time',
     success: function( dataReponse ) {
         time = dataResponse;
    },
    type: 'GET'
} );

根据 url "http://yoursite.com/chat/get_time"，您需要一个控制器"chat"，其名称为 的函数"get_time"，该函数需要以毫秒为单位响应服务器时间，所以我们这样做：

function get_time() {
    echo time();
}

现在我们开始向服务器轮询新的聊天消息，我们这样做：

function getNewMsgs() {
    $.ajax( {
        url: 'http://yoursite.com/chat/get_new_msgs',
        type: 'POST',
        // send the time
        data: { time: time },
        success: function( dataResponse ) {
            try {
                dataResponse = JSON.parse( dataResponse );
                // update the time
                time = dataResponse.time;
                // show the new messages
                dataResponse.msgs.forEach( function( msg ) {
                    console.log( msg );
                } );
                        // repeat
                        setTimeout( function() {
                             getNewMsgs();
                        }, 1000 );
            } catch( e ) {
                // may fail is the connection is lost/timeout for example, so dataResponse
                // is not a valid json string, in this situation you can start this process again
            }
        }
    } );
}

comebacj 到"chat"控制器，我们需要对"get_new_msgs"函数进行编码：

function get_new_msgs() {

    $this->load->model( 'chat_msg' );
    echo json_encode( array(
        'msgs' => $this->chat_msg->start_polling(),
        // response again the server time to update the "js time variable"
        'time' => time() 
    ) );
}

在"chat_msg"模型中，我们对函数进行编码"start_polling"：

function start_polling() {
    // get the time
    $time = $this->input->post( 'time' );
    // some crappy validation
    if( !is_numeric( $time ) ) {
        return array();
    }

    $time = getdate( $time );
    // -> 2010-10-01
    $time = $time['year'] '-' + $time['mon'] + '-' + $time['mday'];

    while( true ) {

        $this->db->select( 'msg' );
        $this->db->from( 'chat_msg' );
        $this->db->where( 'time >=', $time );
        $this->db->order_by( 'posted_time', 'desc' );
        $query = $this->db->get();

        if( $query->num_rows() > 0 ) {
            $msgs = array();
            foreach( $query->result() as $row ) {
                $msgs[] = $row['msg'];
            }
            return $msgs;
        }

        sleep( 1 );
    }
}

收到警告，我在脑海中编写了这段代码，我现在没有一个网络服务器来测试这段代码。

于 2012-10-18T01:45:10.787 回答