На днях опубликовал свой класс для развёртывания веб-сокет сервера.
Веб-сокеты — это технология, позволяющая устанавливать непрерывное соединение между клиентом и сервером. Особенность такой системы также в том, что сервер может по своей инициативе отправлять данные одному или нескольким клиентам. Это позволяет создавать real-time мессенджеры, онлайн-игры и прочие проекты.
PHP, казалось бы, не подходит для такой цели. Он обычно используется для создания динамических веб-страниц и работает по принципу «открыл-ответил-закрыл». Что же, стереотипы пора ломать.
Данный класс избавляет вас от необходимости скачивания сторонних демонов или написания сервера самостоятельно. Всё, что вам потребуется — подключить класс и написать функции приёма сообщений, при желании ещё и сердцебиения.
Чтобы использовать класс, просто включите его в ваш скрипт
require_once('../src/websocket.class.php'); Сразу должен предупредить, что запускаться сервер будет не через браузер, как вы привыкли, а через консоль. В репозиторий на GitHub я включил примеры BAT и SH файлов для исполнения.
Поскольку сервер работает неограниченное время, крайне желательно перед запуском сервера отключить буферизацию вывода и убрать лимит по времени.
Чтобы уберечь сервер от падений, напишите данный код:
error_reporting(E_ERROR); set_time_limit(0); ob_implicit_flush(); Для начала нужно создать экземпляр данного класса:
$socket = new WebSocket('tcp://', '127.0.0.1', '7777'); Как видите, во время создания надо указать протокол, IP и порт будущего сервера. Обязательно убедитесь, что данный порт открыт и IP правильный.
При желании можете записывать логи в файл:
$socket->setOutput('ws-log.txt'); Дальше надо создать обработчик сообщений клиента. Сразу обязан предупредить, что javascript-программисты сейчас возрадуются, а к остальным просто просьба не брать близко к сердцу.
$socket->handler = function($connection, $data) { fwrite($connection, WebSocket::encode($data)); }; Наследуя добрые традиции JS, вы должны записать в переменную handler анонимную функцию. Она будет вызываться каждый раз, когда клиент отправит сообщение серверу. Если вы собираетесь прямо оттуда отправлять ответ, не забывайте кодировать данные при помощи статической функции WebSocket::encode.
Немножко отклонений. Соединение — это ресурс. Его можно читать и дополнять так же, как и обычный открытый файл — при помощи fwrite и fread.
Теперь о функции «сердцебиения». Данная функция будет вызываться во время каждой итерации (чаще, чем раз в секунду).
$socket->hearthbeat = function($connects) { } Во время вызова функции в первом аргументе будет содержаться массив со всеми установленными соединениями. «Сердцебиение» может использоваться для регулярных проверок и других подобных целей.
Последнее, что нам пригодится — собственно запустить сервер. Делается это при помощи метода runServer:
$socket->runServer(); После этого будет запущен вечный цикл. Ваш веб-сокет сервер готов.
Буду очень благодарен любым отзывам или предложениям. Скрипт будет дополняться по мере возможности.
ссылка на оригинал статьи http://habrahabr.ru/post/266931/
Добавить комментарий