基于HTTP長連接的"服務(wù)器推"技術(shù)的php 簡易聊天室
更新時(shí)間:2009年10月31日 00:19:16 作者:
關(guān)于HTTP長連接的“服務(wù)器推”技術(shù)原理可以查看IBM的這篇文章,我簡單的做了個(gè)DEMO.
首先是首頁,包含一個(gè)文本輸入和一個(gè)顯示聊天內(nèi)容的iframe,還有一個(gè)隱藏iframe用來提交form表單:
<?php
//chat.php
header('cache-control: private');
header('Content-Type: text/html; charset=utf-8');
?>
<html>
<script type="text/javascript">
function submitChat(obj) {
obj.submit();
document.getElementsByName('content')[0].value = '';
}
</script>
<iframe src="./chat_content.php" height="300" width="100%"></iframe>
<iframe name="say" height="0" width="0"></iframe>
<form method="POST" target="say" action="./say.php" onsubmit="submitChat(this)">
<input type="text" size="30" name="content" /> <input type="button" value="say" onclick="submitChat(this.form)" />
</form>
</html>
另外一個(gè)就是保存用戶提交的聊天內(nèi)容了,我簡單的寫一下文本,而且沒有做什么鎖定,這個(gè)只是簡易版本:
<?php
$content = trim($_POST['content']);
if ($content) {
$fp = fopen('./chat.txt', 'a');
fwrite($fp, $content . "\n");
fclose($fp);
clearstatcache();
}
?>
接下來看主要的HTTP長連接部分,也就是chat_content.php文件:
<?php
header('cache-control: private');
header('Content-Type: text/html; charset=utf-8');
//測試設(shè)置30秒超時(shí),一般會設(shè)置比較長時(shí)間。
set_time_limit(30);
//這一行是為了搞定IE這個(gè)BT
echo str_repeat(' ', 256);
ob_flush();
flush();
$fp = new SplFileObject('./chat.txt', 'r+');
$line = 0;
$totalLine = 0;
while (!$fp->eof()) {
$fp->current();
$totalLine++;
$fp->next();
}
$fp->seek($totalLine);
$i = $totalLine - 1;
while (true) {
if (!$fp->eof()) {
if ($content = trim($fp->current())) {
echo '<div>';
echo htmlspecialchars($content);
echo "</div>";
flush();
$fp->next();
$i++;
}
} else {
$fp->seek($i - 1);
$fp->next();
}
{
//這里可以添加心跳檢測后退出循環(huán)
}
usleep(1000);
}
?>
我一行行解釋一下,其實(shí)也比較容易理解:
06. 設(shè)置一個(gè)超時(shí)時(shí)間,由于要保持HTTP長連接,這個(gè)時(shí)間肯定要比較長,可能要幾個(gè)小時(shí)吧,上面提到的文章里也有說明,這種HTTP長連接只能打開兩個(gè),由于瀏覽器的限制。另外其實(shí)即使你設(shè)置了一個(gè)永不超時(shí),其實(shí)上服務(wù)器部分(如Apache)的配置文件也可能對HTTP請求設(shè)置了最長等待時(shí)間,所以也可能效果會不是你想的,一般默認(rèn)可能都是15分鐘超時(shí)。如果有興趣可以自己嘗試修改。
09. 這里輸出了一段空白,主要是手冊上已經(jīng)說明了,IE瀏覽器在前面256個(gè)字符是不會直接輸出的,所以我們先隨便輸出些空白,以便讓后面的內(nèi)容輸出來,可能其他瀏覽器也有其他瀏覽器的設(shè)置,具體可以查看PHP手冊的frush函數(shù)的說明。接下去11、12行就是強(qiáng)制把這些空白符丟給瀏覽器輸出。
13. ~ 20. 這里主要是為了計(jì)算文件行數(shù),以便從這一行后面開始讀內(nèi)容。
接下去的while循環(huán)就是一個(gè)死循環(huán)了,就是循環(huán)輸出文件內(nèi)容,每次判斷是否到達(dá)文件末尾,如果有用戶寫入文件,則當(dāng)前檢測肯定不是文件末尾,就將該行讀取出來輸出,否則將指針往前移動一行,繼續(xù)循環(huán),每次等待1000微秒,
39. 如果一直保持長連接,那么即使客戶端斷開,服務(wù)端也不一定能知道客戶端已經(jīng)斷開,所以這里可能還需要做一些心跳記錄,比如每個(gè)用戶保持一個(gè)心跳flag,每格幾秒更新一下最后心跳時(shí)間,當(dāng)檢測最后時(shí)間很久沒更新后,推出這個(gè)死循環(huán),關(guān)閉這個(gè)HTTP連接。
OK,基本上原理就是這樣了,當(dāng)然這個(gè)性能不清楚,有興趣的自己試試,歡迎交流。
復(fù)制代碼 代碼如下:
<?php
//chat.php
header('cache-control: private');
header('Content-Type: text/html; charset=utf-8');
?>
<html>
<script type="text/javascript">
function submitChat(obj) {
obj.submit();
document.getElementsByName('content')[0].value = '';
}
</script>
<iframe src="./chat_content.php" height="300" width="100%"></iframe>
<iframe name="say" height="0" width="0"></iframe>
<form method="POST" target="say" action="./say.php" onsubmit="submitChat(this)">
<input type="text" size="30" name="content" /> <input type="button" value="say" onclick="submitChat(this.form)" />
</form>
</html>
另外一個(gè)就是保存用戶提交的聊天內(nèi)容了,我簡單的寫一下文本,而且沒有做什么鎖定,這個(gè)只是簡易版本:
復(fù)制代碼 代碼如下:
<?php
$content = trim($_POST['content']);
if ($content) {
$fp = fopen('./chat.txt', 'a');
fwrite($fp, $content . "\n");
fclose($fp);
clearstatcache();
}
?>
接下來看主要的HTTP長連接部分,也就是chat_content.php文件:
復(fù)制代碼 代碼如下:
<?php
header('cache-control: private');
header('Content-Type: text/html; charset=utf-8');
//測試設(shè)置30秒超時(shí),一般會設(shè)置比較長時(shí)間。
set_time_limit(30);
//這一行是為了搞定IE這個(gè)BT
echo str_repeat(' ', 256);
ob_flush();
flush();
$fp = new SplFileObject('./chat.txt', 'r+');
$line = 0;
$totalLine = 0;
while (!$fp->eof()) {
$fp->current();
$totalLine++;
$fp->next();
}
$fp->seek($totalLine);
$i = $totalLine - 1;
while (true) {
if (!$fp->eof()) {
if ($content = trim($fp->current())) {
echo '<div>';
echo htmlspecialchars($content);
echo "</div>";
flush();
$fp->next();
$i++;
}
} else {
$fp->seek($i - 1);
$fp->next();
}
{
//這里可以添加心跳檢測后退出循環(huán)
}
usleep(1000);
}
?>
我一行行解釋一下,其實(shí)也比較容易理解:
06. 設(shè)置一個(gè)超時(shí)時(shí)間,由于要保持HTTP長連接,這個(gè)時(shí)間肯定要比較長,可能要幾個(gè)小時(shí)吧,上面提到的文章里也有說明,這種HTTP長連接只能打開兩個(gè),由于瀏覽器的限制。另外其實(shí)即使你設(shè)置了一個(gè)永不超時(shí),其實(shí)上服務(wù)器部分(如Apache)的配置文件也可能對HTTP請求設(shè)置了最長等待時(shí)間,所以也可能效果會不是你想的,一般默認(rèn)可能都是15分鐘超時(shí)。如果有興趣可以自己嘗試修改。
09. 這里輸出了一段空白,主要是手冊上已經(jīng)說明了,IE瀏覽器在前面256個(gè)字符是不會直接輸出的,所以我們先隨便輸出些空白,以便讓后面的內(nèi)容輸出來,可能其他瀏覽器也有其他瀏覽器的設(shè)置,具體可以查看PHP手冊的frush函數(shù)的說明。接下去11、12行就是強(qiáng)制把這些空白符丟給瀏覽器輸出。
13. ~ 20. 這里主要是為了計(jì)算文件行數(shù),以便從這一行后面開始讀內(nèi)容。
接下去的while循環(huán)就是一個(gè)死循環(huán)了,就是循環(huán)輸出文件內(nèi)容,每次判斷是否到達(dá)文件末尾,如果有用戶寫入文件,則當(dāng)前檢測肯定不是文件末尾,就將該行讀取出來輸出,否則將指針往前移動一行,繼續(xù)循環(huán),每次等待1000微秒,
39. 如果一直保持長連接,那么即使客戶端斷開,服務(wù)端也不一定能知道客戶端已經(jīng)斷開,所以這里可能還需要做一些心跳記錄,比如每個(gè)用戶保持一個(gè)心跳flag,每格幾秒更新一下最后心跳時(shí)間,當(dāng)檢測最后時(shí)間很久沒更新后,推出這個(gè)死循環(huán),關(guān)閉這個(gè)HTTP連接。
OK,基本上原理就是這樣了,當(dāng)然這個(gè)性能不清楚,有興趣的自己試試,歡迎交流。
相關(guān)文章
Yii2實(shí)現(xiàn)跨mysql數(shù)據(jù)庫關(guān)聯(lián)查詢排序功能代碼
本篇文章主要介紹了Yii2實(shí)現(xiàn)跨mysql數(shù)據(jù)庫關(guān)聯(lián)查詢排序功能示例,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下。2017-02-02Zend Framework入門教程之Zend_Config組件用法詳解
這篇文章主要介紹了Zend Framework入門教程之Zend_Config組件用法,結(jié)合實(shí)例形式分析了Zend_Config組件針對各種類型配置文件操作的相關(guān)技巧,需要的朋友可以參考下2016-12-12smarty中改進(jìn)truncate使其支持中文的方法
這篇文章主要介紹了smarty中改進(jìn)truncate使其支持中文的方法,涉及針對Smarty源碼中truncate源文件進(jìn)行函數(shù)功能擴(kuò)展的相關(guān)技巧,需要的朋友可以參考下2016-05-05