2.6.6 RabbitMQ -- Masstransit 介紹

Masstransit 是什么
Quickstart
消息 Message

Masstransit 是什么

Masstransit 是一個 .NET 免費開源的分布式應用框架

集成多種消息中間件（Rabbitmq, Azure, Service Bus, ActiveMQ, Kafka, In-Memory）
強大且完整的消息模式（發布與訂閱，saga，event-driven state machine，最終一致性支持）
端到端解決方案（消息路由，異常，重試，並發控制，連接與消費生命周期管理）
使用簡單
單元測試友好
內置監控

Quickstart

新建控制台程序 mt-001，引入 Masstransit 包

namespace mt_001
{
    class Program
    {
        static async Task Main(string[] args)
        {
            var bus = Bus.Factory.CreateUsingInMemory(sbc =>
            {
                sbc.ReceiveEndpoint("test_queue", ep =>
                {
                    ep.Handler<Message>(context => Console.Out.WriteLineAsync($"Received: {context.Message.Text}"));
                });
            });

            await bus.StartAsync();// This is important !

            await bus.Publish(new Message { Text = "Hi" });

            Console.WriteLine("Please input your message with enter:");
            string message = Console.ReadLine();

            while (message != "EXIT")
            {
                await bus.Publish(new Message() {Text = message});
                message = Console.ReadLine();
            }

            await bus.StopAsync();

            Console.WriteLine("Hello World!");
        }
    }

    public class Message
    {
        public string Text { get; set; }
    }
}

啟動程序，收發消息

新建控制台程序 mt-002，引入 MassTransit.RabbitMQ 包

方法改為 CreateUsingRabbitMq，並且添加 rabbitmq host

var bus = Bus.Factory.CreateUsingRabbitMq(sbc =>
{
    sbc.Host("rabbitmq://localhost");

    sbc.ReceiveEndpoint("test_queue", ep =>
    {
        ep.Handler<Message>(context => Console.Out.WriteLineAsync($"Received: {context.Message.Text}"));
    });
});

啟動兩個客戶端，消息是輪詢接收的

消息 Message

消息
消息類型
消息頭
最佳實踐

消息

MassTransit 使用 C# 強類型來定義，一個消息可以被定義為接口，通常我們也稱之為消息契約

消息分為 command 命令與 event 事件，分別對應 send 和 publish 方法

在不同項目里面創建類來消費消息時確保命名空間一致，否則消費不到

命名空間：Company.Application.Contracts

namespace Company.Application.Contracts
{
	using System;

	public interface UpdateCustomerAddress
	{
		Guid CommandId { get; }
		DateTime Timestamp { get; }
		string CustomerId { get; }
		string HouseNumber { get; }
		string Street { get; }
		string City { get; }
		string State { get; }
		string PostalCode { get; }
	}
}