Мы используем
сеансы, когда хотим сохранить определенные данные при последующих обращениях. PHP позволяет нам использовать разные обработчики, когда мы используем сеансы. По умолчанию используется файловая система, но мы можем изменить ее с помощью
session.save_handler в php.ini. session.save_handler определяет имя обработчика, который используется для хранения и извлечения данных, связанных с сеансом. Мы также можем создать наш собственный обработчик для управления сессиями. В этом посте мы собираемся создать собственный обработчик для хранения сеансов в сервисе node.js. Давайте начнем:
Представьте, что у нас есть следующий скрипт php:
session_start(); if (!isset($_SESSION["gonzalo"])) $_SESSION["gonzalo"] = 0; $_SESSION["gonzalo"]++; $_SESSION["arr"] = array('key' => uniqid()); var_dump($_SESSION);
Простое использование сессий с PHP. Если мы перезагрузим страницу, наш счетчик будет увеличен на единицу. Мы используем обработчик сессии по умолчанию. Работает без проблем.
Идея состоит в том, чтобы создать собственный обработчик для использования сервера с node.js для хранения информации о сеансе вместо файловой системы. Для создания пользовательских обработчиков нам нужно использовать функцию PHP: session_set_save_handler и переписать обратные вызовы для: open, close, read, write, destroy и gc. Документация PHP великолепна. Мое предложение следующее:
Наш пользовательский обработчик:
class NodeSession { const NODE_DEF_HOST = '127.0.0.1'; const NODE_DEF_PORT = 5672; static function start($host = self::NODE_DEF_HOST, $port = self::NODE_DEF_PORT) { $obj = new self($host, $port); session_set_save_handler( array($obj, "open"), array($obj, "close"), array($obj, "read"), array($obj, "write"), array($obj, "destroy"), array($obj, "gc")); session_start(); return $obj; } private function unserializeSession($data) { if( strlen( $data) == 0) { return array(); } // match all the session keys and offsets preg_match_all('/(^|;|\})([a-zA-Z0-9_]+)\|/i', $data, $matchesarray, PREG_OFFSET_CAPTURE); $returnArray = array(); $lastOffset = null; $currentKey = ''; foreach ( $matchesarray[2] as $value ) { $offset = $value[1]; if(!is_null( $lastOffset)) { $valueText = substr($data, $lastOffset, $offset - $lastOffset ); $returnArray[$currentKey] = unserialize($valueText); } $currentKey = $value[0]; $lastOffset = $offset + strlen( $currentKey )+1; } $valueText = substr($data, $lastOffset ); $returnArray[$currentKey] = unserialize($valueText); return $returnArray; } function __construct($host = self::NODE_DEF_HOST, $port = self::NODE_DEF_PORT) { $this->_host = $host; $this->_port = $port; } function open($save_path, $session_name) { return true; } function close() { return true; } public function read($id) { return (string) $this->send(__FUNCTION__, array('id' => $id)); } public function write($id, $data) { try { $this->send(__FUNCTION__, array( 'id' => $id, 'data' => $data, 'time' => time(), 'dataJSON' => json_encode($this->unserializeSession($data)))); return true; } catch (Exception $e) { return false; } } public function destroy($id) { try { $this->send(__FUNCTION__, array('id' => $id)); } catch (Exception $e) { return false; } return true; } function gc($maxlifetime) { try { $this->send(__FUNCTION__, array('maxlifetime' => $maxlifetime, 'time' => time())); } catch (Exception $e) { return false; } return true; } private function send($action, $params) { $params = array('action' => $action) + $params; return file_get_contents("http://{$this->_host}:{$this->_port}?" . http_build_query($params)); } }
Наш сервер node.js:
var http = require('http'), url = require('url'), session = require('nodePhpSessions').SessionHandler; var sessionHandler = new session(); var server = http.createServer(function (req, res) { var parsedUrl = url.parse(req.url, true).query; res.writeHead(200, {'Content-Type': 'text/plain'}); res.end(sessionHandler.run(parsedUrl)); }); server.listen(5672, "127.0.0.1", function() { var address = server.address(); console.log("opened server on %j", address); });
Как мы видим, нам нужен модуль node.js nodePhpSessions. Вы можете легко установить с:
npm install nodePhpSessions
Вы можете увидеть библиотеку nodePhpSessions здесь .
Библиотека протестирована с узлом узла. Без TDD очень сложно проверить такие вещи, как сборщик мусора.
var session = require('nodePhpSessions').SessionHandler; var sessionHandler = new session(); var parsedUrl; exports["testReadUndefinedSession"] = function(test){ parsedUrl = { action: 'read', id: 'ts49vmf0p732iafr25mdu8gvg2' }; test.equal(sessionHandler.run(parsedUrl), undefined); test.done(); }; exports["oneSessionShouldReturns1"] = function(test){ parsedUrl = { action: 'write', id: 'ts49vmf0p732iafr25mdu8gvg2', data: 'gonzalo|i:1;arr|a:1:{s:3:"key";s:13:"4e2b1a40d136a";}', time: '1311447616', dataJSON: '{"gonzalo":1,"arr":{"key":"4e2b1a40d136a"}}' }; sessionHandler.run(parsedUrl); parsedUrl = { action: 'readAsArray', id: 'ts49vmf0p732iafr25mdu8gvg2' }; test.equal(sessionHandler.run(parsedUrl).gonzalo, 1); test.done(); }; exports["oneSessionShouldReturns2"] = function(test){ parsedUrl = { action: 'write', id: 'ts49vmf0p732iafr25mdu8gvg2', data: 'gonzalo|i:2;arr|a:1:{s:3:"key";s:13:"4e2b1a40d136a";}', time: '1311447616', dataJSON: '{"gonzalo":2,"arr":{"key":"4e2b1a40d136a"}}' }; sessionHandler.run(parsedUrl); parsedUrl = { action: 'readAsArray', id: 'ts49vmf0p732iafr25mdu8gvg2' }; test.equal(sessionHandler.run(parsedUrl).gonzalo, 2); test.done(); }; exports["destroySession"] = function(test){ parsedUrl = { action: 'destroy', id: 'ts49vmf0p732iafr25mdu8gvg2'}; sessionHandler.run(parsedUrl); parsedUrl = { action: 'readAsArray', id: 'ts49vmf0p732iafr25mdu8gvg2' }; test.equal(sessionHandler.run(parsedUrl), undefined); test.done(); }; exports["garbageColector"] = function(test){ parsedUrl = { action: 'write', id: 'session1', data: 'gonzalo|i:1;arr|a:1:{s:3:"key";s:13:"4e2b1a40d136a";}', time: '1111111200', dataJSON: '{"gonzalo":1,"arr":{"key":"4e2b1a40d136a"}}' }; sessionHandler.run(parsedUrl); parsedUrl = { action: 'write', id: 'session2', data: 'gonzalo|i:1;arr|a:1:{s:3:"key";s:13:"4e2b1a40d136a";}', time: '1111111100', dataJSON: '{"gonzalo":1,"arr":{"key":"4e2b1a40d136a"}}' }; sessionHandler.run(parsedUrl); parsedUrl = { action: 'gc', maxlifetime: '100', time: '1111111210'}; sessionHandler.run(parsedUrl); parsedUrl = { action: 'readAsArray', id: 'session2' }; test.equal(sessionHandler.run(parsedUrl), undefined); parsedUrl = { action: 'readAsArray', id: 'session1' }; test.equal(sessionHandler.run(parsedUrl).gonzalo, 1); test.done(); };
Здесь вы можете увидеть результаты тестов:
nodeunit testNodeSessions.js testNodeSessions.js ✔ testReadUndefinedSession ✔ oneSessionShouldReturns1 ✔ oneSessionShouldReturns2 ✔ destroySession ✔ garbageColector OK: 6 assertions (5ms)
Теперь мы изменим оригинальный PHP-скрипт на:
include_once 'NodeSessions.php'; NodeSession::start(); if (!isset($_SESSION["gonzalo"])) $_SESSION["gonzalo"] = 0; $_SESSION["gonzalo"]++; $_SESSION["arr"] = array('key' => uniqid()); var_dump($_SESSION);
Запускаем сервер node.js:
node serverSessions.js
Теперь, если мы перезагрузим наш скрипт в браузере, мы увидим то же самое поведение, но теперь наши сеансы хранятся на сервере node.js.
array(2) { ["gonzalo"]=> int(16) ["arr"]=> array(1) { ["key"]=> string(13) "4e2a9f6a966f4" } }
Этот вид техники хорош при кластеризации PHP-приложений .
Полный код доступен на github (сервер узла, PHP-обработчик, тесты и примеры) здесь .