網頁實時聊天之js和jQuery實現ajax長輪詢
js和jQuery實現ajax長輪詢
眾所周知,HTTP協議是無狀態的,所以一次的請求都是一個單獨的事件,和前後都沒有聯絡。所以我們在解決網頁實時聊天時就遇到一個問題,如何保證與伺服器的長時間聯絡,從而源源不段地獲取資訊。
一直以來的方式無非有這麼幾種:
1、長連線,即伺服器端不斷開聯絡,PHP伺服器端用ob系列函式來不停的讀取輸出,但是相當耗費伺服器資源。
2、Flash socket,flash的as3語言,建立一個socket伺服器用來處理資訊。
3、輪詢,顧名思義就是不停地傳送查詢訊息,一有新訊息立刻更新,但是會有多次無用請求。
4、長輪詢,是輪詢的升級版,需要伺服器端的配合。
5、websocket
JS和JQ兩種方式(其實不同就是js和jq的實現),實現AJAX長輪詢。
長輪詢的思想:
如圖:用AJAX傳送詢問資訊,伺服器在沒有資訊要返回的時候進入無限等待。由於AJAX非同步的特性,PHP在伺服器端執行等待不會影響到頁面的正常處理。一旦伺服器查詢到返回資訊,伺服器返回資訊,AJAX用回撥函式處理這條資訊,同時迅速再次傳送一個請求等待伺服器處理。
與傳統輪詢相比,長輪詢在伺服器沒的返回資訊的時候進入等待,減少了普通輪詢伺服器無數次的空回覆。可以這樣認為,長輪詢使伺服器每次的返回更有目的性,而不是盲目返回。
長輪詢的伺服器端實現:
聊天資訊儲存:
資料庫設計為資訊ID(msgid),傳送人(sender),接收人(receiver),資訊內容(content),設定senderRead和receiverRead的目的是標記資訊是否已被讀取,讀取後改變標記,以區別資訊是否已經被讀取。
createtable msg{
msgid intnotnullprimarykey auto_increment,
sender char(16) notnull,
receiver char(16) notnull,
content text, //資訊內容用text型別,儲存量可達到65535字元
senderRead
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請求。
程式擴充:
添加發送聊天視窗:
新建一個函式用來處理ajax的POST請求,用ajax將發信人,每次傳送的資訊,收信人傳送到伺服器端,並設定一個單獨的PHP指令碼處理資訊,將資訊插入資料庫。
需要注意的是,用JS原生實現POST請求傳送資訊時,要設定ajax物件的HTTP頭,模擬表單提交的操作:
xhr.setRequestHeader("Content-type","application/x-www-form-urlencoded");
聊天室訊息處理:
為了防止每次都查詢到全部資訊,我們對資料庫的查詢操作更改一下,設定idflag=0,每次查詢後,設定idflag為查詢到的資料的id,查詢時我們查詢比idflag大的ID,即,新新增進去的資訊。
這樣,一個簡單的聊天室程式就做好了。