Comet(Long polling) — php + jquery?

Question

[arcanrun]

Не могли бы вкратце объяснить, сопровождая примерами, работу comet(long polling)-приложения при помощи jquery и php? Как конкретно создать ajax-соединение, которое длится некое количество времени(за счет чего)?

Answer 1

[Сергей Протько]

js создает соединение (в опциях для ajax запроса выставляется таймаут побольше)
php принимает его и смотри что можно послать. И ждет... ждет пока не появятся данные которые можно послать.
Как только данные появляются (скажем скрипт с какой-то задержкой читает данные из базы или из очереди) то он отправляет эти данные и обрывает соединение.
js скрипт принимает данные, отдает данные на обработку и создает новое соединение.... и так до бесконечности.

По сути просто вместо того что бы опрашивать сервер раз в секунду, создается соединение, живущее только до получения данных. После получения данных соединение закрывается. После закрытия соединения (не важно пришли данные или произошла ошибка/разрыв по таймаут) так же создается новое. На практике таймаут выставляют секунд в 20-30 что бы избежать возможных проблем.

Comments

[Сергей Протько]

если данные приходят часто, то становится не выгодно каждый раз разрывать соединение. В этом случае можно серверу посылать данные по мере поступления (через ob_flush) и через js обрабатывать эти данные по мере поступления.

[arcanrun]

правильно ли я понял - соединение остается открытым благодаря $.ajax({...,timeout:30000,...}) , например?

[Сергей Протько]

http://habrahabr.ru/post/132785/

[Сергей Протько]

Хм... не помню что бы давал эту ссылку. Соединение может разорваться только если клиент, сервер или операционная система пользователя/сервера оборвет соединение по таймауту. На клиенте кроме как выставить таймаут (рекомендуется все же разрывать периодически соединения и устанавливать новые) больше делать ничего не нужно. Серверу же, что бы продлить время подключения достаточно сделать бесконечный цикл со sleep-ом, в котором он будет через определенный интервал проверять наличие данных. Профит такой: сотни запросов на сервер при коротких запросах, когда, при отсутствии данных сервер сразу же разрывает соединение заменяются десятком длинных. Опять же если данные приходят часто выгоднее юзать сокеты и tcp напрямую.

[arcanrun]

У меня не получается сразу получать новые данные - они приходят только после нового выполнения функции getmess, которая выполняется по истечению таймера, в чем может быть ошибка? function getmess(){ $.ajax({ url:"get_mess.php", type:"POST", data:{"id":id}, cahce:false, timeout:30000, async:true, success:function(result){ $("#response").html(result); setTimeout('getmess()',10000); } }); } на сервере: while(true){ $a=$_POST["id"]; $find_mess=(mysql_query("SELECT * FROM saymon WHERE id> '$a' ")); if (mysql_num_rows($find_mess)) { while($row=mysql_fetch_array($find_mess)){ echo $row['mess']."</br>"; } flush(); exit; } sleep(5); } mysql_close();

Answer 2

[arcanrun]

У меня не получается сразу получать новые данные - они приходят только после нового выполнения функции getmess, которая выполняется по истечению таймера, в чем может быть ошибка?

function getmess(){
$.ajax({
url:"get_mess.php",
type:"POST",
data:{"id":id},
cahce:false,
timeout:30000,
async:true,
success:function(result){
$("#response").html(result);
setTimeout('getmess()',10000);
}
});
}

на сервере:

while(true){
$a=$_POST["id"];
$find_mess=(mysql_query("SELECT * FROM saymon WHERE id> '$a' "));
if (mysql_num_rows($find_mess)) {
while($row=mysql_fetch_array($find_mess)){
echo $row['mess']."";
}

flush();
exit;
}

sleep(5);
}
mysql_close();

Comments

[Нур-Магомед]

PHP код можно немножко оптимизировать, например, вынести присвоение данных переменной $a из цикла. К тому же, думаю, если JS запрос завершится с ошибкой, то у вас не поставится на новый вызов функция getmess(), потому что setTimeout стоит в success.