В этом посте мы рассмотрим возможности, которые Db4o предоставляет для поддержания технологии Клиент/Сервер (C/S). C/S подразумевает взаимодействие приложений двух видов — сервера, который инициирует обслуживание хранилища, и клиента, который работает с хранилищем через сервер. То что мы делали до сих пор никак не напоминало C/S. Приложение работало непосредственно с файлом контейнера:
objectContainer = Db4oFactory.OpenFile(config, @"D:\Test.yap");
Такой режим работы принято называть embedded — встраиваемый режим. Преимуществами embedded являются максимальное быстродействие и предельная простота. Недостаток — невозможность одновременной работы нескольких приложений с одним контейнером.
Чтобы организовать C/S, нужен сервер. Но в стандартной поставке Db4o нет никакого сервера. Взамен этого, разработчики Db4o предоставляют несколько API методов для реализации C/S. Это значит, что сервер мы должны написать самостоятельно. Сейчас мы этим и займёмся.
Тип проекта может быть любым, но я выбираю WPF из-за возможности лёгкой реализации консоли при помощи FlowDocumentScrollViewer. Если у вас есть возможность разместить новый проект на удалённом компьютере (например, при помощи удалённого рабочего стола), советую воспользоваться этим для испытания работы Db4o в сети (сеть должна поддерживать протокол TCP/IP). Если такой возможности нет, придется всё делать на одном компьютере, "эмулируя" сеть через localhost. Но, в любом случае нужно придерживаться золотого правила, о котором мы говорили раньше — каждое приложение, работающее с контейнером должно иметь доступ к сборке с описанием классов этого контейнера. Эта сборка должна быть единой для всех приложений, использующих данный контейнер. И сервер здесь не исключение. Поэтому в В Solution Explorer -- References обязательно должна быть добавлена ссылка на наше WindowsFormsApplication, которое использовалось для создания и модификации контейнера. Сделайте это так, как мы делали в посте Знакомимся с бесплатной объектной базой db4o. Запросы. Не забудьте также добавить ссылку на Db4objects.Db4o.dll.
В XAML проекта вставьте в грид такой код:
<FlowDocumentScrollViewer Name="flowDocumentScrollViewer1">
<FlowDocument Name="Reporter">
<Paragraph></Paragraph>
</FlowDocument>
</FlowDocumentScrollViewer>
В Window1.xaml.cs объявите:
using Db4objects.Db4o;
using Db4objects.Db4o.Messaging;
using WindowsFormsApplicationDB; //У вас – ваше WindowsFormsApplication
В классе Window1 создайте два поля:
string containerFile = @"D:\Test.yap";
IObjectServer server;
Назначьте событие Window_Loaded:
server = Db4oFactory.OpenServer(containerFile, 4488);
ToReporter("Запущен сервер Db4o");
ToReporter("Открыт контейнер " + containerFile);
server.GrantAccess("user1", "password1");
server.GrantAccess("user2", "password2");
ToReporter("Открыт доступ пользователям user1, user2");
и событие Window_Closed:
server.Close();
метод ToReporter нужен для стекового вывода информации на консоль:
void ToReporter(string msg)
{
Paragraph p = new Paragraph(new Run(DateTime.Now.ToString() + " -- " + msg));
Reporter.Blocks.InsertBefore(Reporter.Blocks.FirstBlock, p);
}
Для начала этого вполне достаточно. Можете запускать свой сервер.
Теперь, пора подумать о клиенте. Как вы уже догадались, клиентами будут WindowsFormsApplication и WpfApplication, которые мы создавали и модифицировали в предыдущих постах.
Начнём с нашего WindowsFormsApplication. В событии Form1_Load закомментируйте строчку:
//objectContainer = Db4oFactory.OpenFile(config, @"D:\Test.yap");
и вместо неё впишите:
objectContainer = Db4oFactory.OpenClient(config, "server", 4488, "user1", "password1");
где "server" — имя или IP адрес компьютера, на котором запущен сервер, если всё делается на одном компьютере, напишите "localhost".
Приятным фактом является то, что клиент реализует интерфейс IObjectContainer, поэтому всё что мы дописывали в ObjectContainerExtend или могли бы реализовать в классе-обёртке остаётся в силе. Это вовсе не означает, что принцип построения приложений embedded и C/S одинаков, в этом мы скоро убедимся. Но в построенную нами объектную модель никаких изменений вносить не надо.
Теперь вы можете запустить несколько копий приложения WindowsFormsApplication. Внесите изменения в одной копии и нажмите кнопку Save. Нажмите Load в другой копии и... увидите, что ничего не изменилось. Для того, чтобы понять, почему данные не обновляются, нужно иметь представление о механизме транзакций в C/S приложениях. Если у вас есть познания о транзакциях, реализуемых RDBMS, этого вполне достаточно, Db4o здесь не предлагает ничего нового. Первая транзакция начинается при открытии клиента и завершается методами Commit() или Rollback(), которые начинают следующую транзакцию. Commit утверждает изменения, внесённые в контейнер в течение завершаемой транзакции (после чего эти изменения могут видеть другие приложения), Rollback отвергает изменения, выполняя "откат" на начало завершаемой транзакции. Commint выполняется также методом IObjectContainer.Close(); В Db4o нет понятия аutocommit, хотя ничто не мешает вам реализовать это, перегрузив методы Set и Delete.
Итак, если мы хотим видеть внесённые в контейнер изменения из другой копии приложения, нужно завершать транзакцию в событиях toolStripButtonSave_Click и toolStripButtonSave2_Click. Для этого допишите там строчку:
objectContainer.Commit();
Давайте ещё раз попробуем внести изменения в одной копии приложения и увидеть их в другой. И опять вы будете разочарованы. Несмотря на то, что транзакция завершилась и все изменения в контейнере утверждены, вторая копия, скорее всего их не отобразит. Виною тому — кэш. Логика кзширования объектов в Db4o приблизительно такова — если объект уже есть в оперативной памяти, зачем его тянуть туда ещё раз? В этом случае объект не извлекается из контейнера, а запросу передается ссылка на существующий объект. При помощи такого подхода развивается максимальная скорость обмена данными с контейнером. В embedded это не вызывает особых проблем, кроме проблемы активации, которую мы подробно рассмотрели в прошлом посте. Но в C/S возникает проблема — так называемое "старение объектов". Находящийся в контейнере, объект может в любой момент измениться, в то время, как копии этого объекта в памяти клиентов остаются неизменными (стареют). В конечном итоге может возникнуть ситуация, которая в OOBD называется несоответствием моделей, когда модель, отображаемая вашим компьютером критически отличается от модели в хранилище. Для борьбы с этим явлением существует два различных подхода. Первый подход состоит в принудительном обновлении объектов, не зависимо от их наличия в оперативной памяти. Это несколько снизит производительность, но увеличит надёжность вашего приложения. В Db4o для этого существует специальный метод Refresh. Чтобы обновление в нашем WindowsFormsApplication осуществлялось без проблем, измените метод RefreshGrid1:
bindingSource1.DataSource = new EditList<Country>(objectContainer.Query<Country>().ToList());
foreach( var obj in ((EditList<Country>)bindingSource1.DataSource)) objectContainer.Ext().Refresh(obj, int.MaxValue);
bindingSource1.ResetBindings(false);
и метод RefreshGrid2:
if (country==null) bindingSource2.DataSource = new EditList<Region>(objectContainer.Query<Region>().ToList());
else bindingSource2.DataSource = new EditList<Region>(country);
foreach (var obj in ((EditList<Region>)bindingSource2.DataSource)) objectContainer.Ext().Refresh(obj, int.MaxValue);
bindingSource2.ResetBindings(false);
Второй подход состоит в открытии клиента только на время операций чтения-записи, с последующим его закрытием, после чего кеш сбрасывается автоматически. Этот подход мы чуть позже используем в нашем WpfApplication, с которым мы работали в прошлом посте.
А сейчас давайте рассмотрим ещё одну возможность, которую Db4o предоставляет для поддержания C/S технологии. Это работа сервера в режиме RECIPIENT — когда сервер может принимать сообщения от клиентов (Out-of-band signalling). Для демонстрации этой возможности мы будем передавать в консоль сервера данные о клиенте. Дополним наше WindowsFormsApplication:
В файле Entities.cs создадим новый класс:
public class ConnectInfo
{
public ConnectInfo(string userName, bool connect)
{
User = userName;
ConnectStatus = connect;
}
public string User;
public bool ConnectStatus;
public string AppName;
public string Host;
public string Address;
}
Теперь дополним класс ObjectContainerExtend ещё одним методом:
public static void ConnectMessage(this IObjectContainer container, string user, bool status)
{
Db4objects.Db4o.Messaging.IMessageSender sender = container.Ext().Configure().ClientServer().GetMessageSender();
ConnectInfo ci = new ConnectInfo(user, status);
ci.Host = System.Net.Dns.GetHostName();
ci.Address = System.Net.Dns.GetHostAddresses(System.Net.Dns.GetHostName())[0].ToString();
ci.AppName = System.Reflection.Assembly.GetEntryAssembly().GetName().Name;
sender.Send(ci);
}
Использовать этот метод будем после открытия клиента в событии Form1_Load:
..............
objectContainer = Db4oFactory.OpenClient(config, "server", 4488, "user1", "password1");
objectContainer.ConnectMessage("user1", true);
..............
и перед закрытием клиента в событии Form1_FormClosed:
objectContainer.ConnectMessage("user1", false);
objectContainer.Close();
Конечно, это не очень удобно, лучше было бы перегрузить методы OpenClient и Close в классе-обёртке.
Для того, чтобы сообщения принимались сервером, необходимо "настроить" сервер в режиме recipient. Откройте проект сервера и допишите в событие Window_Loaded строку:
server.Ext().Configure().ClientServer().SetMessageRecipient(this);
где — this это любой класс, реализующий интерфейс ImessageRecipient. В нашем случае, был использован класс Window1:
public partial class Window1 : Window, IMessageRecipient
Интерфейс IMessageRecipient требует реализации всего лишь одного метода void ProcessMessage(IObjectContainer container, object message). Этот метод будет вызываться каждый раз, когда кто-нибудь из клиентов отошлёт сообщение. В нашем случае он будет выглядеть так:
ConnectInfo ci = message as ConnectInfo;
if (ci == null) return;
Action InvokeMethod = () =>
{
string msginfo = "клиент " + ci.User + "; Приложение " + ci.AppName + "; Компьютер " + ci.Host + "; IP адрес " + ci.Address;
ToReporter((ci.ConnectStatus ? "Подключен " : "Отключен ") + msginfo);
};
Dispatcher.BeginInvoke(System.Windows.Threading.DispatcherPriority.Background, InvokeMethod);
Откомпилируйте проект и запустите сервер. Теперь запустите своё WindowsFormsApplication.
И в заключении "переведём на C/S" наше WpfApplication, которое мы использовали в прошлом посте. Для этого заккоментируйте везде, где это встречается (flowDocumentScrollViewer1_Loaded, Window_Closed, button1_Click) строки открывающие контейнер:
//objectContainer = Db4oFactory.OpenFile(@"D:\Test.yap");
и закрывающие контейнер:
//objectContainer.Close();
В начале события button1_Click впишите:
objectContainer = Db4oFactory.OpenClient("server", 4488, "user2", "password2");
objectContainer.ConnectMessage("user2", true);
и завершите это событие строками:
objectContainer.ConnectMessage("user2", false);
objectContainer.Close();
Теперь запустите сервер и два клиентских приложения: WindowsFormsApplication и WpfApplication. Вносите изменения в WindowsFormsApplication и смотрите, как "отрабатывает" Query в WpfApplication.