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

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

  // Этот программный код на серверном JavaScript предназначен для выполнения
  // под управлением NodeJS. Он реализует очень простую, полностью анонимную комнату чата.
  // Для отправки новых сообщений в чат следует использовать POST-запросы к URL /chat,
  // а для получения текста/потока-событий сообщений следует использовать GET-запросы
// к тому же URL. При выполнении GET-запроса к / возвращается простой HTML-файл,
  // содержащий пользовательский интерфейс чата для клиента.
  var http = require('http'); // Реализация API HTTP-сервера в NodeJS
  // HTML-файл для клиента чата. Используется ниже.
  var clientui = require('fs').readFileSync( "chatclient.html");
  var emulation = require( fs').readFileSync("EventSourceEmulation.js");
  // Массив объектов ServerResponse, который будет использоваться для отправки событий
  var clients = [];

  // Отправлять комментарий клиентам каждые 20 секунд, чтобы предотвратить
  // закрытие соединения с последующими попытками восстановить его
  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);
   // Если запрошен URL "/", отправить пользовательский интерфейс чата,
   if (url.pathname === "/") { // Запрошен пользовательский интерфейс чата
   response.writeHead(200, {"Content-Type": "text/html"});
   response.write("<script>" + emulation + "</script>");
   response.write(clientui);
   response.end;
   return;
   }
   // Если запрошен любой другой URL, кроме "/chat", отправить код 404
   else
   if (url.pathname !== "/chat") {
   response.writeHead(404);
   response.end;
   return;
   }

// Если был выполнен POST-запрос - клиент отправил новое сообщение
   if (request.method === "POST") {
   request.setEncoding("utf8");
   var body = "";
   // При получении фрагмента данных добавить его в переменную body

request.on("data", function(chunk) { body += chunk; });

   // По завершении запроса отправить пустой ответ
   // и широковещательное сообщение всем клиентам,
   request.on("end", function {
   response.writeHead(200); // Ответ на запрос
   response.end;

   // Преобразовать сообщение в формат текст/поток-событий.
   // Убедиться, что все строки начинаются с префикса "data:"
   // и само сообщение завершается двумя символами перевода строки,
   message = 'data: ' + body, replace('\n’, '\ndata: ') + "\r\n\r\n";

   // Отправить сообщение всем клиентам
   clients.forEach(function(client) { client.write(message); });
   });
   }

   // Если иначе, клиент запросил поток сообщений
   else {
   // Установить тип содержимого и отправить начальное событие message
   response.writeHead(200, {'Content-Type': "text/event-stream" });
   response.write("data: Connected\n\n");

   // Если клиент закрыл соединение, удалить соответствующий
   // объект response из массива активных клиентов
   request.connection.on("end", function {
   clients.splice(clients.index0f(response), 1);