Red5: Практика работы с потоковым мультимедиа. Часть 8

Трудно привести пример какого-нибудь серьезного приложения, перед которым не стояла бы задача сохранения информации между сеансами работы. И не столь важно, где будет эта информация сохранена: то ли на локальном жестком диске компьютера, то ли на интернет-сервере. В разных приложениях могут меняться требования к объемам хранимой информации, надежности хранилища, возможности параллельной работы с данными нескольких пользователей, поддержке транзакций и т.д. Сегодняшняя статья завершит рассказ о SharedObject-ах. В частности, я расскажу о том, как можно сохранять состояние “общего объекта” в некотором хранилище в перерывах между отдельными сеансами.

Как вы помните из прошлых статей, SharedObject представляет собой “упаковку” пар “ключ и его значение”. Всякий раз, когда любой из множества клиентов, подключенных к SharedObject-у, изменяет какой-то из его атрибутов, генерируется событие, рассылаемое всем остальным пользователям. Это событие-оповещение содержит информацию о том, что же поменялось внутри SharedObject-а. И вся эта накопленная внутри SharedObject-а информация автоматически становится доступной любому новому клиенту, как только он подключится к SharedObject-у. Негативный момент в том, что SharedObject “живет” лишь до тех пор, пока от него не отключатся все клиенты. Когда это происходит, то сервер red5 уничтожает SharedObject вместе со всем его содержимым. Такое поведение мне не нравится, и я хотел бы, чтобы содержимое SharedObject-а имело более продолжительный срок жизни. Например, перед уничтожением SharedObject-а его содержимое будет сохраняться, а при создании нового SharedObject-а его содержимое будет восстанавливаться из некоего хранилища. Еще я хочу избежать проблемы, связанной с тем, что при “падении” red5-сервера содержимое всех SharedObject-ов будет утеряно (это происходит, так как SharedObject-ы хранятся в оперативной памяти). Для того чтобы экспериментировать с “persistent shared object”, я создал простенький flash-клиент, показанный на рис. 1. Как видите, состоит это flash-приложение из двух кнопок и списка. По нажатию на первую кнопку flash-клиент подключается к red5-серверу и создает SharedObject. Затем, по нажатию на вторую кнопку, будет меняться содержимое SharedObject-а. Список служит для реализации обратной связи: я буду помещать в него текущее содержимое SharedObject-а. Пример несложный, а после того как мы разберем на его основе нюансы работы с “persistent shared object”, вы сможете вернуться, например, к начатому в прошлых статьях примеру с чатом и легко добавить для него возможность сохранения истории сообщений, например, в файле или даже базе данных. Итак, первый пример кода – это mxml-разметка интерфейса flash-клиента:

<<>>
<<сайт layout="absolute">>>
<<>><<private var nc:NetConnection;
private var sharedObj:SharedObject;

private function doConnect(event:MouseEvent):void {
nc = new NetConnection();
nc.objectEncoding = ObjectEncoding.AMF0;
nc.addEventListener(NetStatusEvent.NET_STATUS, netStatus);
nc.connect('rtmp://localhost/warmodule/room');
}
private function netStatus(event:NetStatusEvent):void{
if (event.info.code == 'NetConnection.Connect.Success') {
sharedObj = SharedObject.getRemote("sharedObj", nc.uri, true);
sharedObj.addEventListener(SyncEvent.SYNC, onSync);
sharedObj.connect(nc);
} }
private function onSync(event:SyncEvent):void {
log.dataProvider = sharedObj.data.attr?sharedObj.data.attr:[];
}
private function doPut(event:MouseEvent):void {
if (!sharedObj.data.attr)
sharedObj.data.attr = ['started'];
else
sharedObj.data.attr.push('put at ' + new Date ());
sharedObj.setDirty("attr");
}
]]>>><<>>
<<>>
<<>>
<<>>
<<>>
<<>>
<<>>
<<>>
<<>>

Как видите, здесь нет ничего сложного: по нажатию на кнопку “doConnect” я пробую установить соединение с red5-сервером. Затем, когда это соединение было создано, я вызываю метод “SharedObject.getRemote” для того, чтобы получить ссылку на “удаленный объект” и сохраняю ссылку на него в переменную sharedObj. Дальнейшие действия тривиальны: я привязываю свою функцию onSync к событию, рассылаемому red5 при изменении SharedObject-а. А внутри этой функции копирую содержимое переменной “attr” (значением ее является массив строк) внутрь списка log. Функция doPut служит для того, чтобы добавить к текущему содержимому массива “attr” строку с текущей датой и временем.

Для проверки того, что приведенный нами пример использования SharedObject-а действительно умеет сохранять свое состояние между сеансами flash- клиентов, сделаем так. Запустим одно единственное окно браузера и откроем в нем адрес сайт После подключения к red5- серверу несколько раз нажмите кнопку “modify shared object”, чтобы содержимое списка заполнилось сообщениями вида “put at %дата%”. Теперь закройте окно браузера, и хотя вы этого не видите, но red5 уничтожил созданный вами SharedObject вместе с его содержимым. Однако если заново открыть страничку сайт и нажать на кнопку подключения к red5-серверу, то расположенный внизу диалогового окна список “log” будет заполнен теми сообщениями, которые вы отправили в него в предыдущем сеансе. Для того чтобы этот пример заработал, я абсолютно ничего не делал и не настраивал на стороне java. Вся “магия” заработала лишь благодаря тому, что при создании SharedObject-а я указал третьим параметром функции getRemote значение “true”. Это значение говорит о том, что я хочу получить именно “persistent shared object”:

sharedObj = SharedObject.getRemote("sharedObj", nc.uri, true);

Теперь разберемся с тем, что происходит на стороне red5-сервера и где, вообще, хранятся SharedObject-ы? В терминологии red5 к каждому SharedObject-у, а также scope (комнате) присоединен специальный объект-хранилище “store”. В поставке red5 идут только два вида подобных хранилищ: “RamPersistence” и “FilePersistence”. Если мы при создании SharedObject-а явно не указали, что хотим пользоваться услугами “persistence”, то содержимое SharedObject-а будет храниться внутри “RamPersistence”. И, как это следует из его названия, информация хранится в оперативной памяти сервера, а значит, теряется при перезапусках сервера или при уничтожении SharedObject-а. “Persistent shared object” пользуется услугами хранилища “FilePersistence”, то есть хранит информацию внутри файлов. Но вот какой формат этих файлов и где они располагаются? В моем случае red5 сервер установлен в каталог “E:\Program_Files_2\Red5_0.8”, а веб-приложение называется “warmodule”. Содержимое SharedObject-а будет сохранено внутри файла, расположенного по следующему пути:

“E:\Program_Files_2\Red5_0.8\webapps\warmodule\persistence\SharedObject\room\sharedObj.red5”. Red5 создает подкаталог “persistence” внутри каталога с вашим веб-приложением. Далее red5 создает подкаталог с именем “SharedObject”, что говорит о том, информация какого типа будет в нем храниться. Следующий подкаталог “room” совпадает с именем той комнаты (room, scope), к которой мы подключались перед созданием sharedObject-а: nc.connect('rtmp://localhost/warmodule/room');

И, собственно, имя файла равно имени того SharedObject-а, что мы указали при вызове метода “SharedObject.getRemote”. Если открыть файл sharedObj.red5, то мы увидим в нем “кракозюбры”, среди которых будут просматриваться относительно понятные фрагменты, содержащие текст сообщений, которые я добавлял внутрь SharedObject-а, когда нажимал на кнопку “modify shared object”. Подсистема сохранения содержимого SharedObject-а в файл тесно связана с остальными подсистемами red5. Так, важен ответ на вопрос: умеет ли red5 сохранять SharedObject-ы, содержащие не только примитивные переменные (строки, даты, числа), но и сложные пользовательские объекты. В прошлой статье серии я показывал прием, когда создаваемый нами чат хранил историю сообщений не в виде простого массива строк, а в виде объектов класса ChatHistoryItem:

package blz.red5demo {
[RemoteClass(alias="blz.red5demo.ChatHistoryItem")]
public class ChatHistoryItem {
public var user:String;
public var date:Date;
public var message:String;
public function ChatHistoryItem() {}
}}

Благодаря тому, что на стороне java и на стороне flash существуют классы ChatHistoryItem с одинаковыми именами и одинаковым устройством, red5 и flash отлично умели конвертировать java-объекты в их flash-аналоги. К счастью, механизм сохранения SharedObject-ов полностью поддерживает пользовательские java- и flash-классы. При сохранении содержимого объекта в файл red5 сохранит лишь те поля классов, которые имеют модификатор доступа public или имеют специальную пару методов get и set. К слову, если какое-то из полей java-класса вы не хотите сохранять в файл, то его нужно промаркировать аннотацией DontSerialize, например, так:

package blz.red5demo;
import org.red5.annotations.DontSerialize;
public class ChatHistoryItem {
@DontSerialize
private String user;
private java.util.Date date;
private String message;
}
На практике формат хранения данных в файле и порядок следования полей класса в нем совершенно не важен. Однако если вдруг вы захотите получить контроль над этими вещами, то в red5 реализована привычная для java-мира идея, когда класс, например наш ChatHistoryItem, реализует интерфейс IExternalizable c парой методов readExternal и writeExternal, внутри которых вы берете на себя ответственность за сохранение содержимого SharedObject-а в файл в том формате, который вам потребуется. Гораздо важнее другое: в red5, несмотря на вышеописанный набор полезных “плюшек” и средств контроля за сохранением содержимого SharedObject-а в файл, совершенно не продуман вопрос контроля за тем, где, собственно, хранить эти файлы. Смешно сказать, но логика использования для этих целей каталога “persistence” зашита глубоко внутри red5-кода, и разработчики не предусмотрели простого способа указать, что этот каталог должен быть расположен где-то еще, например, на другом жестком диске. Более того, сама идея хранения потенциально “дорогостоящей” информации в виде обычного файла “очень дурно пахнет”. Главной претензией к файлу как хранилищу информации является отсутствие развитых средств контроля за доступом к этому файлу нескольких пользователей одновременно. Для решения этой проблемы red5 использует специальную стратегию отложенного по времени сохранения содержимого SharedObject-а в файл. Если вы запустите мой пример и несколько раз нажмете на кнопку модификации “общего объекта”, то изменения в файл будут записаны не мгновенно, а через несколько секунд. То есть когда SharedObject изменяется, то он просит конкретную реализацию своего хранилища FilePersistence сохранить себя в файл. Но FilePersistence делегирует эту работу еще одному классу FilePersistenceThread. Класс FilePersistenceThread существует только в одном экземпляре и используется множеством FilePersistence-хранилищ. Поступающие запросы на сохранение информации помещаются в специальную очередь заданий. Затем каждые 10 секунд эта очередь заданий просматривается и обрабатывается. Гораздо хуже другое: часто сохранение информации внутри SharedObject-а связано с какой-то сложной бизнес-логикой, которая в свою очередь завязана на работу с другим хранилищем информации, например, базой данных oracle или mysql. То есть изменение SharedObject-а должно идти в рамках общей транзакции, затрагивающей несколько источников данных (так называемые распределенные транзакции). Например, мы делаем многопользовательскую internet-игру в стиле фэнтези. Информация об игроках, их уровне здоровья, снаряжении в виде всяческих волшебных мечей и топоров хранится в “настоящей” базе данных oracle. Однако для того, чтобы несколько игроков могли видеть характеристики друг друга и взаимодействовать, мы решаем поместить “снимок” их текущего состояния в SharedObject. Предположим, что игрок встретился в пещере со страшным Бармалеем, который убивает игрока. Как только это происходит, мы вызываем специальную процедуру, которая должна изменить содержимое базы данных, поставив напротив фамилии игрока отметку “убит”. Аналогичным образом нужно изменить и содержимое SharedObject-а (а в случаях FilePersistence нужно дождаться момента, когда содержимое SharedObject-а действительно сохранится в файл). Но если в промежуток времени между этими двумя операциями произошел сбой, то содержимое базы данных будет отличаться от содержимого SharedObject-а (после того как red5-сервер был перезапущен и прочитал содержимое SharedObject-а). Такие ситуации нужно отслеживать и иметь способ их разрешения. Отличным решением будет либо отказ от использования “persistent shared object”, либо научить его работать в паре с основным хранилищем данных и в рамках одной транзакции. Итак, главный вопрос: умеет ли red5 работать с другими реализациями хранилищ данных, кроме как RamPersistence и FilePersistence? Да, умеет, хотя разработчики red5 изо всех сил старались при этом усложнить жизнь разработчику. Так, самым простым способом подменить реализацию хранилища данных было бы поместить внутрь файла red5-web.xml следующего бина:

<<>>
<<>>
<<>>

Как видите, свойство “persistenceClassName” должно быть равно имени класса, реализующего интерфейс “IPersistenceStore”. Правда, этот способ не всегда работает, что связано с особенностями работы java-загрузчика классов. То есть класс “blz.red5demo.MyPersistence” должен быть не частью java-классов создаваемого вами приложения, а частью классов самого сервера. Подробно останавливаться на этом варианте я не буду, но если он вас заинтересует, то вы всегда можете уточнить у меня детали по почте. Второй способ подмены хранилища данных предполагает “ручное” создание SharedObject-а с настройкой используемого им Store. Напомню, что есть два вида SharedObject-ов в зависимости от того, кто инициирует их создание: клиент или сервер (см. прошлую статью серии об этом виде SharedObject-ов). Упомянутый первым способ (с модификацией файла “red5- web.xml”) отлично работает для обоих этих вариантов. А второй способ (пример с которым я сейчас приведу) предполагает, что вы сами внутри расположенного на java-стороне метода “запуск комнаты” создаете SharedObject и подготавливаете его для дальнейшей работы:

public boolean roomStart(IScope room) {
if (!super.roomStart(room))
return false;
Object oldStore = room.getAttribute(IPersistable.TRANSIENT_PREFIX + "_SO_PERSISTENCE_STORE_");
try {
DbStore store = new DbStore(room);
room.setAttribute(IPersistable.TRANSIENT_PREFIX + "_SO_PERSISTENCE_STORE_", store);
ISharedObject chat = getSharedObject(room, "sharedObj", true);
return true;
} finally {
room.setAttribute(IPersistable.TRANSIENT_PREFIX + "_SO_PERSISTENCE_STORE_", oldStore);
}
}

Каждая комната (room) содержит специальный атрибут с именем IPersistable.TRANSIENT_PREFIX + "_SO_PERSISTENCE_STORE_", значением которого является ссылка на используемое данной комнатой хранилище данных. Которое, в свою очередь, присоединяется ко всякому SharedObject-у, созданному внутри этой комнаты. То есть я сохранил старое значение хранилища комнаты в переменную oldStore. Затем создал новое хранилище DbStore и привязал его к комнате. После чего я вызвал метод getSharedObject, который и создал новый “persistent shared object” с именем “sharedObj”, привязанный к моей реализации хранилища DbStore. Важно не забыть по завершению метода roomStart вернуть назад настройки комнаты (что и делается внутри секции finally). Что касается исходного кода класса DbStore, то я его специально не привожу, так как он хотя и велик по размеру, но никаких сложностей в реализации не представляет: все сводится к реализации пары методов save и load, вызываемых тогда, когда нужно загрузить и восстановить содержимое SharedObject-а в базе данных. А что касается конкретной стратегии сохранения SharedObject-а, то обычно все сводится к “примитивному” копированию двоичного представления SharedObject-а в специальное BLOB поле (один в один, как это делал FilePersistence, но только не в файл, а в базу данных). Создавать же какой-то сложный и “умный” анализатор содержимого SharedObject-а с последующей раскладкой этой информации по отдельным нормализованным таблицам глупо, так как содержимое SharedObject-а должно быть подчиненным по отношению к главной информации, а не создавать дублирующуюся структуру.

На этом я завершаю большой раздел, посвященный задачам общения между flash и java, задачам передачи информации в обоих направлениях и задачам работы с SharedObject-ами. В следующей статье я перейду к завершающей части для всей серии статей – задаче захвата flash-клиентом видео- и аудиопотоков с помощью микрофона и веб-камеры с последующей передачей этой информации на red5-сервер.

black-zorro@tut.by black-zorro.com