1. 程式人生 > >網頁實時聊天之js和jQuery實現ajax長輪詢

網頁實時聊天之js和jQuery實現ajax長輪詢

jsjQuery實現ajax長輪詢

眾所周知,HTTP協議是無狀態的,所以一次的請求都是一個單獨的事件,和前後都沒有聯絡。所以我們在解決網頁實時聊天時就遇到一個問題,如何保證與伺服器的長時間聯絡,從而源源不段地獲取資訊。

一直以來的方式無非有這麼幾種:

1、長連線,即伺服器端不斷開聯絡,PHP伺服器端用ob系列函式來不停的讀取輸出,但是相當耗費伺服器資源。

2、Flash socket,flash的as3語言,建立一個socket伺服器用來處理資訊。

3、輪詢,顧名思義就是不停地傳送查詢訊息,一有新訊息立刻更新,但是會有多次無用請求。

4、長輪詢,是輪詢的升級版,需要伺服器端的配合。

5、websocket

,HTML5的通訊功能,建立一個與伺服器端的專用介面ws協議來進行通訊,相容可能成為問題,改天研究一下這個。

JSJQ兩種方式(其實不同就是jsjq的實現),實現AJAX長輪詢。

長輪詢的思想:

如圖:用AJAX傳送詢問資訊,伺服器在沒有資訊要返回的時候進入無限等待。由於AJAX非同步的特性,PHP在伺服器端執行等待不會影響到頁面的正常處理。一旦伺服器查詢到返回資訊,伺服器返回資訊,AJAX用回撥函式處理這條資訊,同時迅速再次傳送一個請求等待伺服器處理。

與傳統輪詢相比,長輪詢在伺服器沒的返回資訊的時候進入等待,減少了普通輪詢伺服器無數次的空回覆。可以這樣認為,長輪詢使伺服器每次的返回更有目的性,而不是盲目返回。

長輪詢的伺服器端實現:

聊天資訊儲存:

資料庫設計為資訊ID(msgid),傳送人(sender),接收人(receiver),資訊內容(content),設定senderReadreceiverRead的目的是標記資訊是否已被讀取,讀取後改變標記,以區別資訊是否已經被讀取。

createtable msg{

  msgid intnotnullprimarykey auto_increment,

  sender char(16) notnull,

  receiver char(16) notnull,

  content text,     //資訊內容用text型別,儲存量可達到65535字元

  senderRead

tinyint enum(0,1) default0,

  receiverRead tinyint enum(0,1) default0//設定一個是否已讀的flag標記

}

PHP指令碼:

指令碼的主要目的是處理來自ajax的每次詢問,ajax每次詢問就查詢一下資料庫,看有沒有新的資訊,如果沒有,剛用usleep()函式等待一秒後再次查詢,直到有新資訊插入資料庫並被查到,指令碼返回查詢到的資料,並退出無限迴圈,結束指令碼。

set_time_limit(0);//設定指令碼超時時間為無限,不然在過了超時時間後腳本會自動關閉,輪詢失敗。

$link=newmysqli("host","user","password","database");

$search="selectsender,receiver,content from msg where receiverRead=0 limit 1";//限制每次讀出一條資料,便於修改其已讀flag

$change="update chatset receiverRead=1 where receiverRead=0 limit 1";

while (true) {    //進入無限迴圈

$res=$link->query($sql);  //查詢結果

if($res->num_rows!=0){  //當有未讀資訊時讀取資訊

$link->query($change);//將資訊的已讀flag設為1

$msg=$res->fetch_assoc();

$jsonstr=json_encode($msg);//取到資訊,將資訊用轉碼為json格式,返回給JS

echo$jsonstr;

break;//輸出資訊後退出while迴圈,結束當前指令碼

    }

usleep(1000);//如果沒有資訊不會進入if塊,但會執行一下等待1秒,防止PHP因迴圈假死。

}

客戶端實現:

客戶端的主要任務是設定一個ajax請求函式,每次查詢時被呼叫,當沒有資訊返回時,伺服器端被擱置,當前頁面正常執行;當有資訊返回時,函式處理返回的資料,並迅速再次呼叫此函式傳送一次請求。

用原生JS

function link(){

var xhr=null;//先設定xhr為空,為了輪詢時再次呼叫函式對xhr重用,引發錯誤

xhr=newXMLHttpRequest();

xhr.open('GET','serviceback.php',true);//第三個引數一定要設定為true,非同步不阻塞,不會影響到後面JS的執行。

xhr.send();

xhr.onreadystatechange=function(){

if (xhr.readyState==4) { 嚴密也可加使用(xhr.readyState==4 && xhr.status ==200)限定伺服器響應碼為200時才進行處理。

if(xhr.responseText!=''){

        process...  //伺服器端返回資訊,且返回資訊不為空,則開始處理返回資訊。

      }

  setTimeout("link()",300);

//遞迴再次呼叫link()函式,用setTimeOut()設定延時是因為伺服器端進行sql操作時會耗時,當有新資訊時,在伺服器將要置已讀flag為1還未成功時,AJAX可能已經又發出多條查詢資訊了,會導致一條資訊多次返回。

  }

};

}

jQuery外掛實現:

var link={ //jQuery的AJAX執行的配置物件

type:"GET",//設定請求方式,預設為GET

async:true,//設定是否非同步,預設為非同步

url:"customback.php",

dataType:"json",//設定期望的返回格式,因伺服器返回json格式,這裡將資料作為json格式對待

success:function(msg){

   process...

  setTimeout("link()",300);

}//成功時的回撥函式,處理返回資料,並且延時建立新的請求連線

}

$.ajax(link);//執行ajax請求。

程式擴充:

添加發送聊天視窗:

新建一個函式用來處理ajaxPOST請求,用ajax將發信人,每次傳送的資訊,收信人傳送到伺服器端,並設定一個單獨的PHP指令碼處理資訊,將資訊插入資料庫。

需要注意的是,用JS原生實現POST請求傳送資訊時,要設定ajax物件的HTTP,模擬表單提交的操作:

xhr.setRequestHeader("Content-type","application/x-www-form-urlencoded");

聊天室訊息處理:

為了防止每次都查詢到全部資訊,我們對資料庫的查詢操作更改一下,設定idflag=0,每次查詢後,設定idflag為查詢到的資料的id,查詢時我們查詢比idflag大的ID,即,新新增進去的資訊。

這樣,一個簡單的聊天室程式就做好了。