// При получении данных обрабатывает их и вызывает обработчик onmessage.
// Эта функция реализует работу с протоколом Server-Sent Events
function processData {
if (!type) { // Проверить тип ответа, если это еще не сделано
type = xhr.getResponseHeader(’Content-Type’);
if (type !== "text/event-stream") {
aborted = true;
xhr.abort;
return;
}
}
// Запомнить полученный объем данных и извлечь только ту часть ответа,
// которая еще не была обработана,
var chunk = xhr.responseText.substring(charsReceived);
charsReceived = xhr.responseText.length;
// Разбить текст на строки и обойти их в цикле.
var lines = chunk.replace(/(\r\n|\r|\n)$/,"").split(/\r\n|\r|\n/);
for(var і = 0; і < lines.length; i++) {
var line = lines[i], pos = line.indexOf(":"), name.value="";
if (pos == 0) continue; // Игнорировать комментарии
if (pos > 0) { // поле name:value
name = line.substring(0,pos);
value = line.substring(pos+1);
if (value.charAt(O) == " ") value = value.substrings);
}
else name = line; // только поле name
switch(name) {
case "event": eventName = value; break;
case "data": data += value + "\n"; break;
case "id": lastEventld = value; break;
case "retry": retrydelay = parselnt(value) || 1000; break;
default: break; // Игнорировать любые другие строки
}
if (line === "") { // Пустая строка означает отправку события
if (evtsrc.onmessage && data !== "") {
// Отсечь завершающий символ перевода строки
if (data.charAt(data.length-1) == "\n")
data = data.substrings, data.length-1);
evtsrc.onmessage({ // Имитация объекта Event
type: eventName, // тип события
data: data, // данные
origin: url // происхождение данных
});
}
data = "";
continue;
}
}
}
};
}
Завершим описание архитектуры Comet примером серверного сценария. В примере 18.17 приводится реализация HTTP-сервера на серверном JavaScript, который выполняется под управлением интерпретатора Node (раздел 12.2). Когда клиент обращается к корневому URL «/», сервер отправляет ему реализацию клиента чата, представленную в примере 18.15, и реализацию имитации, представленную в примере 18.16. Когда клиент выполняет GET-запрос по URL-адресу «/chat», сервер сохраняет поток ответа в массиве и поддерживает соединение открытым. А когда клиент выполняет POST-запрос к адресу «/chat», сервер интерпретирует тело запроса как текст сообщения и добавляет префикс «data:», как того требует протокол Server-Sent Events, во все открытые потоки сообщений. Если вы установите интерпретатор Node, вы сможете запустить этот пример сервера локально. Он прослушивает порт 8000, поэтому после запуска сервера в броузере необходимо будет указать адресчтобы соединиться с сервером и начать общение с самим собой.