Long polling — как сделать уведомление?

Question

[RageXL]

Необходимо сделать уведомление о количестве новых сообщения для пользователей, используя Long polling.
Что есть на данный момент:

клиент 1

$(document).ready(function getmess(){
    $.ajax({
	url:"notif.php", 
	data:{"id":id},
	type:"POST",
	timeout: 10000,
        complete:getmess,
	success:function(result){
	$("#count").html(result);
	}
	});
});

сервер:

$mysqli = new mysqli('localhost', 'root', '', 'lc');
	if (mysqli_connect_errno()) { 
		printf("Подключение к серверу MySQL невозможно. Код ошибки: %s\n", mysqli_connect_error()); 
		exit; 
	}  
session_start(); 
	

$MY_ID = $_SESSION['id'];

$newData = false;

while (true) {
$result = $mysqli->query("SELECT COUNT(*) FROM messages WHERE user_get='$MY_ID' AND status='1' ");
if (mysqli_num_rows($result)) {
while ($row = mysqli_fetch_array($result)) {
echo $row[0]."";
}
flush();
exit;
}
sleep(5);
}

Реализацию данного метода подсмотрел по этой ссылке toster.ru/q/52092
Суть в чем - мне надо отсылать запрос на сервер и ждать ответ 10 секунд, если ответа нет, то отсылать опять запрос и ждать 10 секунд ответа.

Но у меня никак не получается это сделать, - запросы отсылаются каждую секунду длиной тоже 1 секунду, при этом нарушается сам принцип Long polling. На изменения значения timeout не реагирует вообще.

Answer 1

[mayorovp]

А запрос через секунду прерывается - или же сервер что-то отвечает? Если сервер успешно отвечает - то надо и копаться в сервере, а не в клиенте.

Лично я вижу в серверном коде два подозрительных места.
1. Если в базе есть хоть одно сообщение, то оно будет выдаваться клиенту каждый раз. Нужно либо удалять его из базы - либо добавить в запрос какой-нибудь фильтр, чтобы отсечь уже прочитанное. Если поле id - автоинкремент, то можно фильтровать по нему.

2. Делать long pooling на связке "клиент-сервер" - и активных опрос на связке "сервер - база данных" - не лучший вариант. Надо вам поискать способ серверному скрипту так же уснуть до появления события, иначе весь long pooling непонятно зачем.

Comments

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

там же в коде стоит sleep на 5 секунд. А вообще можно использовать подключение через демон + pub/sub очередь какую. Причем в этом случае можно демона на node.js поднять, и воспользоваться готовыми решениями, которые используют нормальные websockets + fall back в long pooling.

[mayorovp]

Вот именно что там sleep на 5 секунд. И какая разница, где его делать - на сервере или в браузере?

Answer 2

[RageXL]

Нет запросы не прерываются, сервер отвечает. Просто длина запроса 1 секунда, а мне надо ждать ответа от сервера как минимум 10 секунд и в случае успешного ответа сразу отсылать новый запрос, так же если сервер не ответил в течении 10 секунд, т.е. в базе не было никаких изменений, то отсылать новый запрос длиной 10 секунд.
Мне нужно получать не сообщения а их число. Например в базу добавилось новое сообщение и число в блоке сразу увеличилось, т.е. просто уведомлять пользователя о новых сообщениях для него.

Comments

[mayorovp]

Тогда, для начала, передавайте на сервер старое значение числа сообщений, и отсылайте ответ клиенту только в случае его изменения.

Но, повторюсь, это все имеет смысл только в том случае, если вы найдете способ не обращаться к базе данных в цикле. Нет особо никакой разницы, делаете вы запрос к БД каждые 5 секунд - или же каждые 5 секунд вы делаете запрос на сервер, который превращается в один запрос к БД.

В отсутствии механизмов синхронизации все игры с long pooling так играми и останутся.

Answer 3

[Назар Мокринский]

У вас есть сообщение в базе - вот они и возвращаются, вы же не проверяете полученные сообщение как прочитанные, вот у вас на запрос всегда срабатывает мгновенно. Как вариант можете отправлять на сервер предыдущее количество сообщений, и если оно не отличается от текущего - ждать. А ещё вам flush(); нафиг не нужен, в следующей же строчке exit; - всё равно буфер будет сброшен.

Comments

[RageXL]

попробую сделать как вы сказали.

[mayorovp]

А мое сообщение вы как бы не читали? Тоже самое же написал...

[Назар Мокринский]

@mayorovp Не то же самое. Получение количества сообщений никак не означает что сообщения прочитаны. Тем более, что status='1' если вы читали запрос такие сообщения судя по всему и фильтрует.

Answer 4

[Виталий Желтяков]

Изначально выбрано неправильное направление.

Long polling + Сессии = зависание скриптов. Либо избавляйтесь от сессиий, либо от Long polling, либо используйте сторонние решения

Answer 5

[RageXL]

Чего то я не пойму, как отослать на сервер уже имеющееся число сообщений ?
Допустим на странице есть такая выборка

$result = $mysqli->query("SELECT COUNT(*) FROM messages WHERE user_get='$MY_ID'");
		$row = $result->fetch_row();
		$totalm = $row[0]; // всего записей
	$result->close();

А как потом в тот же ajax скрипте реализовать отправку данных о количестве сообщений на php ?

Comments

[mayorovp]

Простите, а вы вообще программировать умеете?

var lastcount = -1;
$(document).ready(function getmess(){
$.ajax({
url:"notif.php",
data:{id:id, lastcount: lastcount},
type:"POST",
timeout: 10000,
complete:getmess,
success:function(result){
lastcount = //и тут распарсить то, что вернул сервер.
$("#count").html(result);
}
});
});

Но если это вам так трудно - можно lastcount положить в сессию.

Answer 6

[German Zvonchuk]

Я бы на вашем месте установил на сервере NodeJS, он бы ежесекундно обращался к БД и проверял, есть ли новые записи или обновления для данного клиента или нет, если есть, то отсылал бы об этом информацию клиенту.

NodeJS позволяет держать соединение открытым, сервер при желании может засылать туда при нужде данные, а JS-код в браузере будет получать ответы и совершать нужные действия.

Comments

[mayorovp]

...и в чем отличие от сценария с PHP?

[German Zvonchuk]

@mayorovp я думаю что самое главное отличие в том, что клиенты не будуд долбать сервер спрашивая каждые 10 секунд есть ли новые данные. когда 500 человек в онлайне будут, то эти долбания за ДДОС сойдут.. в том плане что апаче скорее всего ляжет.

NodeJS практически мнгновенно не загружая сервер позволяет доставлять данные пользователю.

[mayorovp]

Правильно, клиенты будут долбать каждые 10 секунд ноду, не так ли? Нода, конечно, не ляжет, но изучать новый язык для такой мелкой задачки...

Чем этот вариант лучше варианта nginx+php+отказ от лонг пулинга?

[mayorovp]

Да и, сдается мне, лечь тут может уже база данных.

[RageXL]

Была у меня мысль реализовать все это на node.js, однако не все получилось. Позже выложу свой код на node.js

[German Zvonchuk]

@mayorovp если стоит NGINX, то в приниципе можно и на нем реализовать Long Polling. Тут надо смотреть и выбирать что проще.

[mayorovp]

@inside22 проблема long pooling в том, что он постоянно занимает один из процессов пула php. В то же время запросы каждые 5 секунд от браузера такого недостатка не имеют - и размер пула можно выбрать меньше.

[German Zvonchuk]

@mayorovp а если сделать на NodeJS, то будет по одному подключению на каждого активного пользователя :-)

Только вот для того, чтобы NodeJS узнал, что для какого то пользователя есть новое сообщение ему(NodeJS) надо будет подключится к MySQL и ежесекундно проверять данные в БД.

К примеру:

В онлайне 1000 человек.
У NodeJS 1000 активных подключений.
Ежесекундно в БД идут 1000 Select-ов

Наверное в этой схеме узким местом будет MySQL. Хотя 1000 Select-ов это совсем не много. Думаю на любом DDS-сервере эта схема будет на УРА работать.

[mayorovp]

@inside22 при чем тут число подключений? NodeJS что, как-то по-особому с браузером общается?

Кроме того, вот вы сами признали, что узкое место - база. Так зачем весь этот огород-то? Нода, лонг пулинг... Ни один из этих инструментов не уменьшает нагрузку на базу.

[German Zvonchuk]

@mayorovp я не настаиваю на том, что предложенный мой вариант лучше, я лишь пытаюсь понять чем ваш вариант лучше.

я использую NodeJS в двух проектах:
1) Windows Application пишет в MySQL данные по котировках, NodeJS читает из БД и каждые 0,7 секунд отдает одинаковые данные всем пользователям.

2) NodeJS получает ИД-клиента из куки, и для каждого клиента из БД читает данные.

В обоих случаях узвое место MySQL. Данные меняются очень часто, за секунду несколько раз... В идеале я хотел бы и в WEB суметь добится этого эффекта. В моем случае пока что ежесекундное обновления данных :=)

[mayorovp]

Мой вариант лучше за счет меньших трудозатрат. А для ваших целей я бы посоветовал выкинуть нафиг базу данных - или оставить ее только для хранения архивов котировок.

Данные в таких задачах надо отдавать не из базы, а из переменной, хранящейся в памяти самой ноды.

[German Zvonchuk]

@mayorovp вопрос: как загонять данные в память ноды? данные по котировкам могу получать только в Windows.

[Александр Кубинцев]

вместо node.js можно использовать ReactPHP или Ratchet,если нужны websockets

[mayorovp]

@inside22 веб-запросом их загнать туда, очевидно же.