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

時間 2021-01-12

標籤 git github 併發框架 async 分佈式單元測試測試 spa 欄目 RabbitMQ 简体版

原文原文鏈接

2.6.6 RabbitMQ -- Masstransit 介紹

Masstransit 是什麼
Quickstart
消息 Message

Masstransit 是什麼

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

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

Quickstart

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

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 hostasync

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 方法測試

在不一樣項目裏面建立類來消費消息時確保命名空間一致，不然消費不到ui

命名空間：Company.Application.Contractsspa

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