Easy RabbitMQ Обмен сообщениями с EasyNetQ

Эта статья о EasyNetQ, библиотеке для использования RabbitMQ с .NET. На момент написания этой статьи EasyNetQ все еще была предварительной версией программного обеспечения . Несмотря на это, несколько человек использовали его в производственной среде некоторое время. Если вы используете его в производстве, это на ваш страх и риск.

В августе прошлого года я написал « Начало работы с RabbitMQ с .NET» . Это, помимо прочего, показало, как вы можете получать сообщения из очереди RabbitMQ с помощью официальной клиентской библиотеки RabbitMQ .NET.

Хотя это и прекрасно, но часто предпочтительнее использовать библиотеку более высокого уровня, которая заботится о мелких деталях и позволяет вам сосредоточиться на реальном обмене сообщениями в структурированном виде. Ну, вот почему EasyNetQ существует . С EasyNetQ вам не нужно беспокоиться о таких вещах, как сериализация, шаблоны обмена сообщениями, надежность соединения и т. Д. В оставшейся части этой статьи мы увидим, как легко отправлять и получать сообщения с помощью EasyNetQ.

Конечно, первое, что нам нужно сделать, это установить пакет EasyNetQ NuGet:

Затем давайте создадим класс, который представляет сообщения, которые мы будем отправлять. В этом примере мы представим, что отправляем позицию игрока в игре:

    public class PlayerPosition
    {
        public int X { get; set; }
        public int Y { get; set; }
    }

            using (var bus = RabbitHutch.CreateBus("host=localhost"))
            {
                bus.Subscribe<PlayerPosition>("MyGame", playerPosition =>
                    Console.WriteLine($"{playerPosition.X}, {playerPosition.Y}"));

                Console.ReadLine();
            }

            using (var bus = RabbitHutch.CreateBus("host=localhost"))
            {
                var playerPosition = new PlayerPosition() { X = 1, Y = 2 };
                bus.Publish<PlayerPosition>(playerPosition);

                Console.ReadLine();
            }