Мы на facebook

На facebook создана страница нашего сайта.

http://www.facebook.com/pages/wcfnetru/168711206515599

Reactive TcpClient

Хочу поделиться методом создания Tcp соединения с помощью Reactive Extensions. Основным желанием при создании данного метода было максимальное упрощение работы с соединением и декларативный подход.

Чтение потокового XML с помощью Reactive Extensions - 2

Создал open-source проект с клиентом для чтения бесконечного потока xml. Последнюю версию можно взять из репозитория xp-dev: http://svn3.xp-dev.com/svn/XmlReader/

Публикация бесконечного XML потока с помощью Reactive Extensions

В догонку к статье о чтении бесконечного XML потока решил приложить простой вариант реализации сервера, публикующего такой поток.

Изменения для подразделов

Уважаемые посетители сайта wcf.net.ru.

Всвязи с требованием ru-center оплатить БЕСПЛАТНЫЕ домены, которые при регистрации выдавались бесплатно и пожизненно, и на которых хостились подразделы сайта, все подразделы перенесены на субдомены *.wcf.net.ru. В зависимости от текущих настроек DNS Вашего провайдера изменения могут распространяться от нескольких часов до нескольких дней.

--
Приношу извинения за возможные возникшие неудобства.

Чтение потокового XML с помощью Reactive Extensions.

Решил выложить пример реализации класса XmlFeed с помощью расширений Rx. XmlFeed представляет из себя реализацию интерфейса IConnectableDisposable<XmlReader>, поставляющий отдельный XmlReader для каждого фрагмента XML, полученного из входящего потока. Позволяет обрабатывать бесконечные потоки xml напрямую из сетевых соединений.
Логика работы простая - в конструктор передаем поток (Stream) и XName элементов, которые ожидаем из него получать. Затем подписываемся с помощью Subscribe() и запускаем с помощью Connect();

Шаблон проектирования CQRS (Command and Query Responsibility Segregation)

Внесены изменения на страницу "полезные ссылки". Добавлен раздел ссылок на ресурсы, связанные с шаблоном проектирования CQRS.

Большинство web-приложений имеет различный характер нагрузки при обработке запросов на изменение данных и запросов на получение данных. Простое разделение приложения на две части позволяет получить огромные плюсы в масштабировании таких приложений без необходимости двусторонней синхронизации данных между серверами баз данных. Кроме того, открываются новые возможности архитектурного плана - такие, как денормализация данных на серверах, обрабатывающих запросы на получение данных, что позволяет дополнительно увеличить производительность и значительно снизить нагрузку.