前一篇文章我們已經完成了基於RabbitMq實現的的訊息匯流排，這篇文章就來看看生產者(訂單微服務)與消費者(經銷商微服務)如何接入訊息匯流排實現訊息的傳送與訊息的接收處理。

定義需要傳送的訊息：

下單訊息要被髮送到訊息匯流排，並被經銷商微服務的處理器處理。經銷商微服務處理時，需要知道要對哪個經銷商處理多少的PV值與電子幣餘額。這些資訊就是事件訊息需要承載的重要資訊。

public class OrderCreatedProcessDealerEvent:BaseEvent
    {
        public decimal OrderTotalPrice { get; set; }
        
 
public decimal OrderTotalPV { get; set; }
        public Guid DealerId { get; set; }
        public Guid OrderId { get; set; }
        public OrderCreatedProcessDealerEvent(Guid dealerid,Guid orderid,decimal ordertotalprice,decimal
            ordertotalpv)
        {
            this.OrderTotalPrice = ordertotalprice;
            
 
this.OrderTotalPV = ordertotalpv;
            this.DealerId = dealerid;
            this.OrderId = orderid;
        }
    }

生產者(訂單微服務)連線到訊息匯流排：

生產者-訂單微服務通過Asp.net core WebApi自帶的依賴注入，連線到RabbitMq訊息匯流排。

            services.AddSingleton<IEventHandlerExecutionContext>(new EventHandlerExecutionContext(services));
            
 
var connectionFactory = new ConnectionFactory { HostName = "localhost" };
            services.AddSingleton<IEventBus>(sp => new RabbitMqEB(connectionFactory,
                sp.GetRequiredService<IEventHandlerExecutionContext>(), "exchange2", "direct", "ordereventqueue", 1));

從上面程式碼可以看出，生產者連線到了localhost的Rabbit伺服器，並通過呼叫訊息匯流排的建構函式，定義了傳送訊息的通道。建構函式具體內容可以檢視上一篇文章。

生產者(訂單微服務)傳送訊息到訊息匯流排：

ieventbus.Publish(new OrderCreatedProcessDealerEvent(orderdto.DealerId,
                        orderid, order.OrderTotalPrice.TotalPrice, order.OrderTotalPV.TotalPV));

ieventbus是注入到訂單微服務的建構函式中，並傳遞到訂單建立的用例中。 

實現消費者(經銷商微服務)的訊息處理器：

消費者會連線到訊息匯流排，接收到特定型別的訊息(這裡是OrderCreatedProcessDealerEvent)，會交給特定的處理器進行處理，所以需要先定義並實現訊息處理器。

public class OrderCreatedEventHandler : IEventHandler
    {
        ServiceLocator servicelocator = new ServiceLocator();
        public Task<bool> HandleAsync<TEvent>(TEvent @event) where TEvent : IEvent
        {
            var idealercontext = servicelocator.GetService<IDealerContext>();
            var irepository =
                servicelocator.GetService<IRepository>(new ParameterOverrides { { "context", idealercontext } });
            var idealerrepository = servicelocator.GetService<IDealerRepository>(new ParameterOverrides { { "context", idealercontext } });
  //先將接收到的訊息轉換成特定型別          
var ordercreatedevent = @event as OrderCreatedProcessDealerEvent;
            using (irepository)
            {
                try
                {
                  //根據訊息內容，處理自己的邏輯與持久化
                    idealerrepository.SubParentEleMoney(ordercreatedevent.DealerId, ordercreatedevent.OrderTotalPrice);
                    idealerrepository.AddDealerPV(ordercreatedevent.DealerId, ordercreatedevent.OrderTotalPV);
                    irepository.Commit();
                }
                catch (EleMoneyNotEnoughException)
                {
                     //先不處理電子幣餘額不足的情況                   

                }
            }
            return Task.FromResult(true);
        }
    }

消費者(經銷商微服務)連線到訊息匯流排：

需要在經銷商微服務指定需要連線到的訊息匯流排，並訂閱哪個型別的訊息交給哪個事件處理器進行處理。

            //用於偵聽訂單上下文傳遞的訊息
            services.AddSingleton<IEventHandlerExecutionContext>(new EventHandlerExecutionContext(services));
            var connectionFactory = new ConnectionFactory { HostName = "localhost" };
            services.AddSingleton<IEventBus>(sp => new RabbitMqEB(connectionFactory,
                sp.GetRequiredService<IEventHandlerExecutionContext>(), "exchange2", "direct", "ordereventqueue", 2));

            var eventbus = app.ApplicationServices.GetService<IEventBus>();
//訂閱訊息
                        eventbus.Subscribe<OrderCreatedProcessDealerEvent, OrderCreatedEventHandler>();

這樣，兩個微服務直接就能通過RabbitMq訊息匯流排進行訊息的傳送、訊息的接收與處理了，實現瞭解耦。

QQ討論群：309287205 

微服務實戰視訊請關注微信公眾號：