MassTransit.DataBusService 1.0.11-alpha

Сервис передачи данных для работы с RabbitMq

Эта библиотека предназначена для работы с очередью сообщений RabbitMq и основана на фреймворке MassTransit. По сути это просто обертка, которая скрывает некоторые механизмы настройки и упрощает работу с фреймворком MassTransit. Однако, базовые знания для работы с RabbitMq необходимы.

Начало работы

Для начала необходимо установить пакет

install-package MassTransit.DataBusService

Основной класс - это класс DataBus, который очень простой и умеет по сути только запустить/остановить сервис и публиковать сообщения. Все остальное делается в настройках и описывается в конфигурационном файле приложения. Для этого во время установки пакета в конфигурационном файле создается секция rabbitmq,

  <rabbitmq>
  ...
  </rabbitmq>

здесь описываются различные параметры настройки, строки подключения, настройки очередей и обработчиков сообщений.

Пример создания объекта и публикации сообщения:

    //Message handler definition
    public class Message1Handler: BaseMessageHandler<Message1>
    {
        public override Task MessageHandle(Message1 message)
        {
            return Console.Out.WriteLineAsync(message.Message);
        }
    }

    //Message definition
    public interface Message1
    {
        string Message { get; set; }
    }

    var dataBus = new DataBus();
    dataBus.Start(); //or StartAsync()
    Console.WriteLine("Bus started");
    dataBus.Publish<Message1>(new {Message = "Hello World!"});
    Console.ReadLine();
    dataBus.Stop(); //or StopAsync()

    /*Output
    Bus started
    Hello World!
    */

Параметры настроек

Этот параметр называется busSettings.
Пример:

<busSettings>
    <add key="workMode" value="RabbitMq">
</busSettings>

На данный момент для предусмотрен один параметр workMode, который может принимать одно из двух значений InMemory и RabbitMq. По названию понятно, что этот параметр задает режим работы библиотеки.

Строка подключения

Задает настройки подключения к серверу RabbitMq.
Пример:

<connections>
    <add name="connection1" url="rabbitmq://localhost/" user="admin" password="admin" />
</connections>

Настройки очередей

Здесь можно указать то, как должна обрабатывать сообщения определенная очередь. При этом название очереди должно совпадать с наименованием одной из очереди указанной в настройках обработчиков сообщений.
Например, для обработчика сообщения

    <add type="MassTransit_Saga.CreateNewBook.Message1Handler, MassTransit_Saga.CreateNewBook" queue="message1_queue" />

указана очередь message1_queue, тогда настройка для этой очередь должна иметь примерно такой вид:

<queues>
    <add name="message1_queue" threadCount="8" prefetchCountToThread="1" threadsByCoreCount="false" />
</queues>

где, name - имя очереди, threadCount - количество потоков обрабатывающих сообщения (значение по умолчанию 1), prefetchCount - количество предварительно выбранных сообщений для одного потока, которые шина забирает из очереди за один раз перед их обработкой (значение по умолчанию 1), threadsByCoreCount - флаг, указывающий, что количество потоков должно равняться количеству ядер процессора системы, этот параметр переопределяет параметр threadCount.

Обработчики сообщений

Здесь описываются какие объекты должны участвовать в обработке сообщений. Эти объекты должны напрямую наследоваться от базового класса обработчика сообщений.
Пример:

namespace Examples.MessageHandlers
{
    //Message definition
    public interface Message1
    {
        string Message { get; set; }
    }

    //Message handler definition
    public class Message1Handler : BaseMessageHandler<Message1>
    {
        public override Task MessageHandle(Message1 message)
        {
            return Console.Out.WriteLineAsync(message.Message);
        }
    }
}

Пример настройки в конфигурационном файле:

<mqhandlers>
    <add type="Examples.MessageHandlers.Message1Handler, Examples" queue="message1_queue"/>
</mqhandlers>

Здесь для дополнительной настройки очереди нужно создать запись с именем message1_queue в секции queues.

Удачи в работе!