Пора ли отправлять С на свалку истории? Пишем демонов на PHP с использованием расширения libevent. - презентация

1 Пора ли отправлять С на свалку истории? Пишем демонов на PHP с использованием расширения libevent

2 Кто мы такие? Вадим Крючков [Long], руководитель группы разработки Андрей Голубев [440hz], ведущий разработчик Евгений Прудников, ведущий разработчик

3 Обычная архитектура (mem)cached

4 Наша архитектура включаем демоны

5 Демонизация. Что есть такое libevent? Предоставляет простой механизм для запуска callback функций, при наступлении определенного события на дескрипторе: – READ – WRITE – TIMEOUT – SIGNAL

6 Пишем демона

7 Пишем демона, работающего с сокетом // Создаем сокет - event вешается на дескриптор $rSocket = stream_socket_server ( 'tcp:// :666', $errno, $errstr, STREAM_SERVER_BIND | STREAM_SERVER_LISTEN ); // далем его не блокирующим, что бы позволить принимать другие коннекты stream_set_blocking ( $rSocket, 0 );

8 Пишем демона подключаем libevent // создаем событийную базу $rBaseEvent = event_base_new ( ); // создаем новое событие для сокета $rSocketEvent = event_new ( ); /** * ловим события "чтение" и после операции чтения возвращаем событие в базу * EV_READ - чтение * EV_PERSIST - вернуть событие в базу после выполнения */ event_set ( $rSocketEvent, $rSocket, EV_READ | EV_PERSIST, 'onAcceptEvent' ); // устанавливаем событие в базу событий event_base_set ( $rSocketEvent, $rBaseEvent ); // запускаем отслеживание event_add ( $rSocketEvent ); // запускаем цикл event_base_loop ( $rBaseEvent );

9 Метод обработки function onAcceptEvent ( $rSocket, $rEvent, $args ) { global $rBaseEvent; // удобнее сделать через объект ;) static $iConnect = 0; // идентификатор конекта $iConnect++; // Примем коннект $rConnection = stream_socket_accept ( $rSocket ); // далем коннект не блокирующим, что бы позволить принимать еще коннекты stream_set_blocking ( $rConnection, 0 ); // создадим буфер обмена данными $buf = event_buffer_new ( $iConnect, 'onReadEvent', 'onWriteEvent', 'onFailureEvent', $iConnect); // подключаем буфер к базе событий event_buffer_base_set ( $buf, $rBaseEvent ); // включаем буфер на события и возвращаем события назад после выполнения event_buffer_enable ( $buf, EV_READ | EV_WRITE | EV_PERSIST ); }

10 Метод чтения $iBufferReadLenght = 1024; // размер буфера чтения function onReadEvent($rStream, $args) { global $iBufferReadLenght; $tmp = ''; do { $tmp.= event_buffer_read ( $hBuffer, $this->iBufferReadLenght ); if( $iBufferReadLenght > strlen($tmp) ) { break; } } while ( true ); return $tmp; }

11 Превращаем демона в... или не документированные возможности

12 Таймеры (thnx 440hz) Стандартный таймер libevent'а не работает :( Выход есть! – событие можно повесить на «любой» дескриптор – event_add ( resource $event, int $timeout )

13 Таймеры - решение tmpfile() - открываем новый временный файл «вешаем» на этот дескриптор отложенное событие event_set( $rTimers, $rTtmpFile, 0, 'onTimer', ) ;

14 Демонстрация

15 Подводные камни Очень мало информации и примеров Следить за ресурсами, не забываем их освобождать Хитрости при чтении данных, превышающих размер буфера Входных данных много и они бывают «чужие» :) Проблемы с отслеживанием сигналов (EV_SIGNAL)

16 Даем нагрузку

17 Тестирование ботами Имитируем … пользователей в on-line: Воспользовались API Написали приложение, генерирующее ботов

18 Результаты Сервер Xeon 8х2.66GHz, RAM 8Gb: Около 2.5 тысяч запросов в секунду (не Hello, World) На 1 пользователя в online расходуется около 1Мб памяти Приложение (пока) не подвергалось жесткой оптимизации

19 Результаты Сервер Xeon 8х2.66GHz, RAM 8Gb: Около 2.5 тысяч запросов в секунду (не Hello, World) На 1 пользователя в online расходуется около 1Мб памяти Приложение (пока) не подвергалось жесткой оптимизации Память не «течет» (1 месяц публичного бета-теста не выявили)

20 Советы Научитесь «мыслить параллельно» – Процесс не завершается – Чужие данные Читайте исходники в них много полезного Если демон будет не один напишите простенький фреймворк Документируйте код + протокол взаимодействия Напишите хороший логгер - без него отлаживать приложение будет сложно – Сделайте несколько уровней логгирования

21 Выводы Выводы пока делать рано :)

22 Выводы (серьезно) Можно рекомендовать к использованию на продакшене Позволяет держать хорошие нагрузки (при этом оставляя LA в разумных пределах ) Реальные тесты придется подождать :(

23 Вопросы?