.NET 雲原生架構師訓練營（模組二 基礎鞏固 RabbitMQ Masstransit 介紹）--學習筆記

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; }
	}
}

消息類型

Command

  • 通過 send 發送到一個 endpoint

Event

  • 通過 publish，不直接發送到 endpoint，發布到多個消費者
  • 通常以名稱短語（過去式的形式來命名）比如 OrderCreatedEvent, OrderSubmitted, OrderPaid, OrderDeliveried

消息頭

最佳實踐

盡量使用介面來定義消息類型，使用消息初始化器（有點困難）

使用類以及繼承時需要特別注意：

  • 通過消費基類並利用多態行為來處理，總會遇到很多問題
  • 消息格式設計不是面向對象設計，消息中應該只包含狀態而不應該包含行為
  • 大的基類也會產生很多問題，特別是在支援消息版本的時候

GitHub源碼鏈接：

//github.com/MINGSON666/Personal-Learning-Library/tree/main/ArchitectTrainingCamp

知识共享许可协议

本作品採用知識共享署名-非商業性使用-相同方式共享 4.0 國際許可協議進行許可。

歡迎轉載、使用、重新發布，但務必保留文章署名 鄭子銘 （包含鏈接： //www.cnblogs.com/MingsonZheng/ ），不得用於商業目的，基於本文修改後的作品務必以相同的許可發布。

如有任何疑問，請與我聯繫 ([email protected]) 。

Tags:

VirMach 便宜 VPS