@@ -307,6 +307,11 @@ + +ngx_http_js_module + + + ngx_http_limit_conn_module @@ -519,6 +524,11 @@ + +ngx_stream_js_module + + + ngx_stream_limit_conn_module diff -r db848aaa123a -r 3492eb9b8138 xml/ru/docs/stream/ngx_stream_js_module.xml --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/xml/ru/docs/stream/ngx_stream_js_module.xml Mon Nov 28 21:29:02 2016 +0300 @@ -0,0 +1,325 @@ + + + + + + + + +

+ + +Модуль ngx_stream_js_module позволяет задавать +обработчики на JavaScript. + + + +По умолчанию этот модуль не собирается, его необходимо собрать с +модулем nginx JavaScript с помощью конфигурационного параметра +--add_module: + +./configure --add-module=path-to-njs/nginx + +Репозиторий +модуля nginx JavaScript можно клонировать следующей командой +(необходим клиент Mercurial): + +hg clone http://hg.nginx.org/njs + +Модуль также можно собрать как +динамический: + +./configure --add-dynamic_module=path-to-njs/nginx + + + +

+ + +

+ + +Модуль экспериментальный, поэтому возможно всё. + + +

+ + +

+ + + +stream { + js_include stream.js; + + server { + listen 12345; + + js_preread qux; + + js_set $foo foo; + js_set $bar bar; + + return foo; + } + + server { + listen 12346; + + js_access xyz; + proxy_pass 127.0.0.1:8000; + js_filter baz; + } +} + +http { + server { + listen 8000; + location / { + return 200 $http_foo\n; + } + } +} + + + + +Файл stream.js: + +var req = ''; +var matched = 0; +var line = ''; + +function qux(s) { + n = s.buffer.indexOf('\n'); + if (n == -1) { + return s.AGAIN; + } + + line = s.buffer.substr(0, n); +} + +function foo(s) { + return line; +} + +function bar(s) { + var v = s.variables; + s.log("hello from bar() handler!"); + return "foo-var" + v.remote_port + "; pid=" + v.pid; +} + +// Фильтр обрабатывает один буфер за вызов. +// Буфер недоступен в s.buffer для +// чтения и записи. Вызывается в обоих направлениях. + +function baz(s) { + if (s.fromUpstream || matched) { + return; + } + + // Отключение определённых адресов. + + if (s.remoteAddress.match('^192.*')) { + return s.ERROR; + } + + // Чтение строки HTTP-запроса. + // Получение байт в 'req' до того как + // будет прочитана строка запроса. Очистка текущего буфера + // для отключения вывода. + + req = req + s.buffer; + s.buffer = ''; + + n = req.search('\n'); + + if (n != -1) { + // Вставка нового HTTP-заголовка. + var rest = req.substr(n + 1); + req = req.substr(0, n + 1); + + addr = s.remoteAddress; + + s.log('req:' + req); + s.log('rest:' + rest); + + // Вывод результата и пропуск дальнейшей + // обработки. + + s.buffer = req + 'Foo: addr_' + addr + '\r\n' + rest; + matched = 1; + } +} + +function xyz(s) { + if (s.remoteAddress.match('^192.*')) { + return s.ABORT; + } +} + + + +

+ + +

+ + +функция + +stream +server + + +Задаёт функцию JavaScript, которая будет вызываться в +access-фазе. + + + + + + +функция + +stream +server + + +Задаёт фильтр данных. + + + + + + +файл + +stream +server + + +Задаёт файл, который позволяет +задавать обработчики server и переменных на JavaScript. + + + + + + +функция + +stream +server + + +Задаёт функцию JavaScript, которая будет вызываться в +preread-фазе. + + + + + + + +$переменная функция + +stream +server + + +Задаёт функцию JavaScript для указанной переменной. + + + + +

+ + +

+ +Каждый stream-обработчик JavaScript получает один аргумент: +объект stream-сессии. + + + +Объект сессии имеет следующие свойства: + + + +remoteAddress + +адрес клиента, только чтение + + +eof + +логическое свойство, +true, если текущий буфер является последним буфером, +только чтение + + +fromUpstream + +логическое свойство, +true, если текущий буфер является буфером от проксируемого сервера к клиенту, +только чтение + + +buffer + +текущий буфер, доступен для записи + + +variables{} + +объект переменных nginx, только чтение + + +OK + +код OK + + +DECLINED + +код DECLINED + + +AGAIN + +код AGAIN + + +ERROR + +код ERROR + + +ABORT + +код ABORT + + + + + +Объект сессии имеет следующие методы: + + + +log(строка) + +записывает отправленную строку в лог-файл ошибок + + + + +

+ +