JavaScript. Подробное руководство, 6-е издание, стр. 292

 case "data": data += value + "\n"; break;

 case "id": lastEventld = value; break;

 case "retry": retrydelay = parselnt(value) || 1000; break;

 default: break; // Игнорировать любые другие строки 

 } 

<b>        if (line === &quot;&quot;) { // Пустая строка означает отправку события</b>

 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, поэтому после запуска сервера в броузере необходимо будет указать адрес http://localhost:8000, чтобы соединиться с сервером и начать общение с самим собой.

Пример 18.17. Сервер чата, поддерживающий протокол Server-Sent Events

<b>// Этот программный код на серверном JavaScript предназначен для выполнения</b>

<b>// под управлением NodeJS. Он реализует очень простую, полностью анонимную комнату чата.</b>

<b>// Для отправки новых сообщений в чат следует использовать POST-запросы к URL /chat,</b>

<b>// а для получения текста/потока-событий сообщений следует использовать GET-запросы</b>

<b>// к тому же URL. При выполнении GET-запроса к / возвращается простой HTML-файл,</b>

// содержащий пользовательский интерфейс чата для клиента.

var http = require('http'); // Реализация API HTTP-сервера в NodeJS

// HTML-файл для клиента чата. Используется ниже.

var clientui = require('fs').readFileSync( "chatclient.html");

var emulation = require( fs').readFileSync("EventSourceEmulation.js");

<b>// Массив объектов ServerResponse, который будет использоваться для отправки событий </b>

var clients = [];

<b>// Отправлять комментарий клиентам каждые 20 секунд, чтобы предотвратить</b>

<b>// закрытие соединения с последующими попытками восстановить его </b>

setInterval(function() {

 clients.forEach(function(client) {

 client. write('': ping\n");

 });

}, 20000);

// Создать новый сервер

var server = new http.Server();

// Когда сервер получит новый запрос, он вызовет эту функцию 

server.on( "request", function (request, response) {

 // Проанализировать запрошенный URL

 var url = require(’url').parse(request.url);

<b>  // Если запрошен URL &quot;/&quot;, отправить пользовательский интерфейс чата,</b>

<b>  if (url.pathname === &quot;/&quot;) { // Запрошен пользовательский интерфейс чата</b>

 response.writeHead(200, {"Content-Type": "text/html"});

 response.write("<script>" + emulation + "</script>");

 response.write(clientui);

 response.end();

 return;

 }

<b>  // Если запрошен любой другой URL, кроме &quot;/chat&quot;, отправить код 404</b>