[D29] : 一个Queue+Docker在Local的实作(3/4)

前面说过Passer如何把请求发到MQ去
今天讲Center怎麽去找MQ把请求取出来。

Center

Center 扮演一个讯息处理的角色，Passer会不断打大量Request上MQ，Center则是会不断的跟MQ索取事情来做，做完後会通知MQ完成，MQ会删除该笔Request。

我们一样建立一个MessageService连线，方式如同前面的Passer。

然後我们使用RabbitMQ中的/BasicGet/框架。
BasicGet框架是由服务端主动去向MQ索取Task来做。

此外另一种是/EventingBasicConsumer/框架。
/EventingBasicConsumer/则是服务端去向MQ订阅，之後MQ收到新的资讯都会一并推播给服务端。

一样要存取MQ，所以这个专案同样执行

dotnet add package RabbitMQ.Client

测试

使用前面提到过的指令
::brew services start rabbitmq::

dotnet run

依序启动MQService -> Passer -> Center

启动後你会看到因为先开了Passer所以MQ的讯息累积红线攀升
接着开了Center，瞬间处理掉大量请求，因此出现一条紫线，并在启动的时间点飙高，因为处理太快XD，届时红线累积量也降低。
黄现在这边则不太明显。

至於为什麽後面又起一个红线小波段是因为我发现我Code写错Center Service Down了一下QAQ。

目前为止我们已经确认Passer -> MQ <- Center之间的沟通是没问题的了。